forked from lovoo/goka
/
cluster_consumer.go
103 lines (87 loc) · 3.51 KB
/
cluster_consumer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
// Code generated by MockGen. DO NOT EDIT.
// Source: group_consumer.go
// Package mock is a generated GoMock package.
package mock
import (
sarama "github.com/Shopify/sarama"
sarama_cluster "github.com/bsm/sarama-cluster"
gomock "github.com/golang/mock/gomock"
reflect "reflect"
)
// MockclusterConsumer is a mock of clusterConsumer interface
type MockclusterConsumer struct {
ctrl *gomock.Controller
recorder *MockclusterConsumerMockRecorder
}
// MockclusterConsumerMockRecorder is the mock recorder for MockclusterConsumer
type MockclusterConsumerMockRecorder struct {
mock *MockclusterConsumer
}
// NewMockclusterConsumer creates a new mock instance
func NewMockclusterConsumer(ctrl *gomock.Controller) *MockclusterConsumer {
mock := &MockclusterConsumer{ctrl: ctrl}
mock.recorder = &MockclusterConsumerMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use
func (m *MockclusterConsumer) EXPECT() *MockclusterConsumerMockRecorder {
return m.recorder
}
// Close mocks base method
func (m *MockclusterConsumer) Close() error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Close")
ret0, _ := ret[0].(error)
return ret0
}
// Close indicates an expected call of Close
func (mr *MockclusterConsumerMockRecorder) Close() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Close", reflect.TypeOf((*MockclusterConsumer)(nil).Close))
}
// MarkPartitionOffset mocks base method
func (m *MockclusterConsumer) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string) {
m.ctrl.T.Helper()
m.ctrl.Call(m, "MarkPartitionOffset", topic, partition, offset, metadata)
}
// MarkPartitionOffset indicates an expected call of MarkPartitionOffset
func (mr *MockclusterConsumerMockRecorder) MarkPartitionOffset(topic, partition, offset, metadata interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "MarkPartitionOffset", reflect.TypeOf((*MockclusterConsumer)(nil).MarkPartitionOffset), topic, partition, offset, metadata)
}
// Notifications mocks base method
func (m *MockclusterConsumer) Notifications() <-chan *sarama_cluster.Notification {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Notifications")
ret0, _ := ret[0].(<-chan *sarama_cluster.Notification)
return ret0
}
// Notifications indicates an expected call of Notifications
func (mr *MockclusterConsumerMockRecorder) Notifications() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Notifications", reflect.TypeOf((*MockclusterConsumer)(nil).Notifications))
}
// Messages mocks base method
func (m *MockclusterConsumer) Messages() <-chan *sarama.ConsumerMessage {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Messages")
ret0, _ := ret[0].(<-chan *sarama.ConsumerMessage)
return ret0
}
// Messages indicates an expected call of Messages
func (mr *MockclusterConsumerMockRecorder) Messages() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Messages", reflect.TypeOf((*MockclusterConsumer)(nil).Messages))
}
// Errors mocks base method
func (m *MockclusterConsumer) Errors() <-chan error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Errors")
ret0, _ := ret[0].(<-chan error)
return ret0
}
// Errors indicates an expected call of Errors
func (mr *MockclusterConsumerMockRecorder) Errors() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Errors", reflect.TypeOf((*MockclusterConsumer)(nil).Errors))
}