Documentation
¶
Index ¶
- func NewMockController(t gomock.TestReporter) *gomock.Controller
- type MockConsumer
- func (_m *MockConsumer) AddGroupPartition(_param0 int32)
- func (_m *MockConsumer) AddPartition(_param0 string, _param1 int32, _param2 int64) error
- 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) error
- func (_m *MockConsumer) Subscribe(_param0 map[string]int64) error
- 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) ([]byte, error)
- func (_m *MockStorage) GetOffset(_param0 int64) (int64, error)
- func (_m *MockStorage) Has(_param0 string) (bool, error)
- func (_m *MockStorage) Iterator() (storage.Iterator, error)
- func (_m *MockStorage) IteratorWithRange(_param0 []byte, _param1 []byte) (storage.Iterator, error)
- func (_m *MockStorage) MarkRecovered() error
- func (_m *MockStorage) Open() error
- func (_m *MockStorage) Recovered() bool
- func (_m *MockStorage) Set(_param0 string, _param1 []byte) error
- func (_m *MockStorage) SetOffset(_param0 int64) error
- 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) EnsureTopicExists(_param0 string, _param1 int, _param2 int, _param3 map[string]string) error
- func (_m *MockTopicManager) Partitions(_param0 string) ([]int32, error)
- type MockkafkaProxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMockController ¶
func NewMockController(t gomock.TestReporter) *gomock.Controller
NewMockController returns a *gomock.Controller using a wrapped testing.T (or whatever) which panics on a Fatalf. This is necessary when using a mock in kafkamock. Otherwise it will freeze on an unexpected call.
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) error
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) error
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) IteratorWithRange ¶
func (*MockStorage) MarkRecovered ¶
func (_m *MockStorage) MarkRecovered() error
func (*MockStorage) Open ¶
func (_m *MockStorage) Open() error
func (*MockStorage) Recovered ¶
func (_m *MockStorage) Recovered() bool
func (*MockStorage) SetOffset ¶
func (_m *MockStorage) SetOffset(_param0 int64) error
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) EnsureTopicExists ¶
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) AddGroup ¶
func (_m *MockkafkaProxy) AddGroup()
func (*MockkafkaProxy) EXPECT ¶
func (_m *MockkafkaProxy) EXPECT() *_MockkafkaProxyRecorder
func (*MockkafkaProxy) Remove ¶
func (_m *MockkafkaProxy) Remove(_param0 string) error
func (*MockkafkaProxy) Stop ¶
func (_m *MockkafkaProxy) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.