Documentation
¶
Index ¶
- type MockConsumer
- func (_m *MockConsumer) AddGroupPartition(_param0 int32)
- func (_m *MockConsumer) AddPartition(_param0 string, _param1 int32, _param2 int64)
- func (_m *MockConsumer) Close() error
- func (_m *MockConsumer) Commit(_param0 string, _param1 int32, _param2 int64) error
- func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder
- func (_m *MockConsumer) Events() <-chan kafka.Event
- func (_m *MockConsumer) RemovePartition(_param0 string, _param1 int32)
- func (_m *MockConsumer) Subscribe(_param0 map[string]int64) error
- type MockContext
- func (_m *MockContext) EXPECT() *_MockContextRecorder
- func (_m *MockContext) Emit(_param0 string, _param1 string, _param2 interface{})
- func (_m *MockContext) Fail(_param0 error)
- func (_m *MockContext) Join(_param0 string) interface{}
- func (_m *MockContext) Key() string
- func (_m *MockContext) Lookup(_param0 string, _param1 string) interface{}
- func (_m *MockContext) Loopback(_param0 string, _param1 interface{})
- func (_m *MockContext) SetValue(_param0 interface{})
- func (_m *MockContext) Topic() string
- func (_m *MockContext) Value() interface{}
- type MockProducer
- type MockStorage
- func (_m *MockStorage) Close() error
- func (_m *MockStorage) Delete(_param0 string) error
- func (_m *MockStorage) EXPECT() *_MockStorageRecorder
- func (_m *MockStorage) Get(_param0 string) (interface{}, error)
- func (_m *MockStorage) GetOffset(_param0 int64) (int64, error)
- func (_m *MockStorage) Has(_param0 string) (bool, error)
- func (_m *MockStorage) Iterator() storage.Iterator
- func (_m *MockStorage) Open() error
- func (_m *MockStorage) Set(_param0 string, _param1 interface{}) error
- func (_m *MockStorage) SetEncoded(_param0 string, _param1 []byte) error
- func (_m *MockStorage) SetOffset(_param0 int64) error
- func (_m *MockStorage) Sync()
- type MockTopicManager
- func (_m *MockTopicManager) Close() error
- func (_m *MockTopicManager) EXPECT() *_MockTopicManagerRecorder
- func (_m *MockTopicManager) EnsureStreamExists(_param0 string, _param1 int) error
- func (_m *MockTopicManager) EnsureTableExists(_param0 string, _param1 int) error
- func (_m *MockTopicManager) Partitions(_param0 string) ([]int32, error)
- type MockkafkaProxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
Mock of Consumer interface
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
func (*MockConsumer) AddGroupPartition ¶
func (_m *MockConsumer) AddGroupPartition(_param0 int32)
func (*MockConsumer) AddPartition ¶
func (_m *MockConsumer) AddPartition(_param0 string, _param1 int32, _param2 int64)
func (*MockConsumer) Close ¶
func (_m *MockConsumer) Close() error
func (*MockConsumer) Commit ¶
func (_m *MockConsumer) Commit(_param0 string, _param1 int32, _param2 int64) error
func (*MockConsumer) EXPECT ¶
func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder
func (*MockConsumer) Events ¶
func (_m *MockConsumer) Events() <-chan kafka.Event
func (*MockConsumer) RemovePartition ¶
func (_m *MockConsumer) RemovePartition(_param0 string, _param1 int32)
type MockContext ¶
type MockContext struct {
// contains filtered or unexported fields
}
Mock of Context interface
func NewMockContext ¶
func NewMockContext(ctrl *gomock.Controller) *MockContext
func (*MockContext) EXPECT ¶
func (_m *MockContext) EXPECT() *_MockContextRecorder
func (*MockContext) Emit ¶
func (_m *MockContext) Emit(_param0 string, _param1 string, _param2 interface{})
func (*MockContext) Fail ¶
func (_m *MockContext) Fail(_param0 error)
func (*MockContext) Join ¶
func (_m *MockContext) Join(_param0 string) interface{}
func (*MockContext) Key ¶
func (_m *MockContext) Key() string
func (*MockContext) Lookup ¶
func (_m *MockContext) Lookup(_param0 string, _param1 string) interface{}
func (*MockContext) Loopback ¶
func (_m *MockContext) Loopback(_param0 string, _param1 interface{})
func (*MockContext) SetValue ¶
func (_m *MockContext) SetValue(_param0 interface{})
func (*MockContext) Topic ¶
func (_m *MockContext) Topic() string
func (*MockContext) Value ¶
func (_m *MockContext) Value() interface{}
type MockProducer ¶
type MockProducer struct {
// contains filtered or unexported fields
}
Mock of Producer interface
func NewMockProducer ¶
func NewMockProducer(ctrl *gomock.Controller) *MockProducer
func (*MockProducer) Close ¶
func (_m *MockProducer) Close() error
func (*MockProducer) EXPECT ¶
func (_m *MockProducer) EXPECT() *_MockProducerRecorder
type MockStorage ¶
type MockStorage struct {
// contains filtered or unexported fields
}
Mock of Storage interface
func NewMockStorage ¶
func NewMockStorage(ctrl *gomock.Controller) *MockStorage
func (*MockStorage) Close ¶
func (_m *MockStorage) Close() error
func (*MockStorage) Delete ¶
func (_m *MockStorage) Delete(_param0 string) error
func (*MockStorage) EXPECT ¶
func (_m *MockStorage) EXPECT() *_MockStorageRecorder
func (*MockStorage) Get ¶
func (_m *MockStorage) Get(_param0 string) (interface{}, error)
func (*MockStorage) Iterator ¶
func (_m *MockStorage) Iterator() storage.Iterator
func (*MockStorage) Open ¶
func (_m *MockStorage) Open() error
func (*MockStorage) Set ¶
func (_m *MockStorage) Set(_param0 string, _param1 interface{}) error
func (*MockStorage) SetEncoded ¶
func (_m *MockStorage) SetEncoded(_param0 string, _param1 []byte) error
func (*MockStorage) SetOffset ¶
func (_m *MockStorage) SetOffset(_param0 int64) error
func (*MockStorage) Sync ¶
func (_m *MockStorage) Sync()
type MockTopicManager ¶
type MockTopicManager struct {
// contains filtered or unexported fields
}
Mock of TopicManager interface
func NewMockTopicManager ¶
func NewMockTopicManager(ctrl *gomock.Controller) *MockTopicManager
func (*MockTopicManager) Close ¶
func (_m *MockTopicManager) Close() error
func (*MockTopicManager) EXPECT ¶
func (_m *MockTopicManager) EXPECT() *_MockTopicManagerRecorder
func (*MockTopicManager) EnsureStreamExists ¶
func (_m *MockTopicManager) EnsureStreamExists(_param0 string, _param1 int) error
func (*MockTopicManager) EnsureTableExists ¶
func (_m *MockTopicManager) EnsureTableExists(_param0 string, _param1 int) error
func (*MockTopicManager) Partitions ¶
func (_m *MockTopicManager) Partitions(_param0 string) ([]int32, error)
type MockkafkaProxy ¶
type MockkafkaProxy struct {
// contains filtered or unexported fields
}
Mock of kafkaProxy interface
func NewMockkafkaProxy ¶
func NewMockkafkaProxy(ctrl *gomock.Controller) *MockkafkaProxy
func (*MockkafkaProxy) Add ¶
func (_m *MockkafkaProxy) Add(_param0 string, _param1 int64)
func (*MockkafkaProxy) AddGroup ¶
func (_m *MockkafkaProxy) AddGroup()
func (*MockkafkaProxy) EXPECT ¶
func (_m *MockkafkaProxy) EXPECT() *_MockkafkaProxyRecorder
func (*MockkafkaProxy) Remove ¶
func (_m *MockkafkaProxy) Remove(_param0 string)
func (*MockkafkaProxy) Stop ¶
func (_m *MockkafkaProxy) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.