Documentation ¶
Index ¶
- type MockClient
- func (_m *MockClient) Brokers() []*sarama.Broker
- func (_m *MockClient) Close() error
- func (_m *MockClient) Closed() bool
- func (_m *MockClient) Config() *sarama.Config
- func (_m *MockClient) Controller() (*sarama.Broker, error)
- func (_m *MockClient) Coordinator(_param0 string) (*sarama.Broker, error)
- func (_m *MockClient) EXPECT() *_MockClientRecorder
- func (_m *MockClient) GetOffset(_param0 string, _param1 int32, _param2 int64) (int64, error)
- func (_m *MockClient) InSyncReplicas(_param0 string, _param1 int32) ([]int32, error)
- func (_m *MockClient) Leader(_param0 string, _param1 int32) (*sarama.Broker, error)
- func (_m *MockClient) Partitions(_param0 string) ([]int32, error)
- func (_m *MockClient) RefreshCoordinator(_param0 string) error
- func (_m *MockClient) RefreshMetadata(_param0 ...string) error
- func (_m *MockClient) Replicas(_param0 string, _param1 int32) ([]int32, error)
- func (_m *MockClient) Topics() ([]string, error)
- func (_m *MockClient) WritablePartitions(_param0 string) ([]int32, error)
- type MockConsumer
- func (_m *MockConsumer) Close() error
- func (_m *MockConsumer) ConsumePartition(_param0 string, _param1 int32, _param2 int64) (sarama.PartitionConsumer, error)
- func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder
- func (_m *MockConsumer) HighWaterMarks() map[string]map[int32]int64
- func (_m *MockConsumer) Partitions(_param0 string) ([]int32, error)
- func (_m *MockConsumer) Topics() ([]string, error)
- type MockPartitionConsumer
- func (_m *MockPartitionConsumer) AsyncClose()
- func (_m *MockPartitionConsumer) Close() error
- func (_m *MockPartitionConsumer) EXPECT() *_MockPartitionConsumerRecorder
- func (_m *MockPartitionConsumer) Errors() <-chan *sarama.ConsumerError
- func (_m *MockPartitionConsumer) HighWaterMarkOffset() int64
- func (_m *MockPartitionConsumer) Messages() <-chan *sarama.ConsumerMessage
- type MockTopicManager
- func (_m *MockTopicManager) Close() error
- func (_m *MockTopicManager) EXPECT() *_MockTopicManagerRecorder
- func (_m *MockTopicManager) EnsureStreamExists(topic string, npar int) error
- func (_m *MockTopicManager) EnsureTableExists(topic string, npar int) error
- func (_m *MockTopicManager) Partitions(topic string) ([]int32, error)
- type MockclusterConsumer
- func (_m *MockclusterConsumer) Close() error
- func (_m *MockclusterConsumer) EXPECT() *_MockclusterConsumerRecorder
- func (_m *MockclusterConsumer) Errors() <-chan error
- func (_m *MockclusterConsumer) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)
- func (_m *MockclusterConsumer) Messages() <-chan *sarama.ConsumerMessage
- func (_m *MockclusterConsumer) Notifications() <-chan *sarama_cluster.Notification
- type Mockkzoo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
Mock of Client interface
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
func (*MockClient) Brokers ¶
func (_m *MockClient) Brokers() []*sarama.Broker
func (*MockClient) Close ¶
func (_m *MockClient) Close() error
func (*MockClient) Closed ¶
func (_m *MockClient) Closed() bool
func (*MockClient) Config ¶
func (_m *MockClient) Config() *sarama.Config
func (*MockClient) Controller ¶
func (_m *MockClient) Controller() (*sarama.Broker, error)
func (*MockClient) Coordinator ¶
func (_m *MockClient) Coordinator(_param0 string) (*sarama.Broker, error)
func (*MockClient) EXPECT ¶
func (_m *MockClient) EXPECT() *_MockClientRecorder
func (*MockClient) InSyncReplicas ¶
func (_m *MockClient) InSyncReplicas(_param0 string, _param1 int32) ([]int32, error)
func (*MockClient) Partitions ¶
func (_m *MockClient) Partitions(_param0 string) ([]int32, error)
func (*MockClient) RefreshCoordinator ¶
func (_m *MockClient) RefreshCoordinator(_param0 string) error
func (*MockClient) RefreshMetadata ¶
func (_m *MockClient) RefreshMetadata(_param0 ...string) error
func (*MockClient) Replicas ¶
func (_m *MockClient) Replicas(_param0 string, _param1 int32) ([]int32, error)
func (*MockClient) Topics ¶
func (_m *MockClient) Topics() ([]string, error)
func (*MockClient) WritablePartitions ¶
func (_m *MockClient) WritablePartitions(_param0 string) ([]int32, error)
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
Mock of Consumer interface
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
func (*MockConsumer) Close ¶
func (_m *MockConsumer) Close() error
func (*MockConsumer) ConsumePartition ¶
func (_m *MockConsumer) ConsumePartition(_param0 string, _param1 int32, _param2 int64) (sarama.PartitionConsumer, error)
func (*MockConsumer) EXPECT ¶
func (_m *MockConsumer) EXPECT() *_MockConsumerRecorder
func (*MockConsumer) HighWaterMarks ¶
func (_m *MockConsumer) HighWaterMarks() map[string]map[int32]int64
func (*MockConsumer) Partitions ¶
func (_m *MockConsumer) Partitions(_param0 string) ([]int32, error)
func (*MockConsumer) Topics ¶
func (_m *MockConsumer) Topics() ([]string, error)
type MockPartitionConsumer ¶
type MockPartitionConsumer struct {
// contains filtered or unexported fields
}
Mock of PartitionConsumer interface
func NewMockPartitionConsumer ¶
func NewMockPartitionConsumer(ctrl *gomock.Controller) *MockPartitionConsumer
func (*MockPartitionConsumer) AsyncClose ¶
func (_m *MockPartitionConsumer) AsyncClose()
func (*MockPartitionConsumer) Close ¶
func (_m *MockPartitionConsumer) Close() error
func (*MockPartitionConsumer) EXPECT ¶
func (_m *MockPartitionConsumer) EXPECT() *_MockPartitionConsumerRecorder
func (*MockPartitionConsumer) Errors ¶
func (_m *MockPartitionConsumer) Errors() <-chan *sarama.ConsumerError
func (*MockPartitionConsumer) HighWaterMarkOffset ¶
func (_m *MockPartitionConsumer) HighWaterMarkOffset() int64
func (*MockPartitionConsumer) Messages ¶
func (_m *MockPartitionConsumer) Messages() <-chan *sarama.ConsumerMessage
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(topic string, npar int) error
func (*MockTopicManager) EnsureTableExists ¶
func (_m *MockTopicManager) EnsureTableExists(topic string, npar int) error
func (*MockTopicManager) Partitions ¶
func (_m *MockTopicManager) Partitions(topic string) ([]int32, error)
type MockclusterConsumer ¶
type MockclusterConsumer struct {
// contains filtered or unexported fields
}
Mock of clusterConsumer interface
func NewMockclusterConsumer ¶
func NewMockclusterConsumer(ctrl *gomock.Controller) *MockclusterConsumer
func (*MockclusterConsumer) Close ¶
func (_m *MockclusterConsumer) Close() error
func (*MockclusterConsumer) EXPECT ¶
func (_m *MockclusterConsumer) EXPECT() *_MockclusterConsumerRecorder
func (*MockclusterConsumer) Errors ¶
func (_m *MockclusterConsumer) Errors() <-chan error
func (*MockclusterConsumer) MarkPartitionOffset ¶
func (_m *MockclusterConsumer) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)
func (*MockclusterConsumer) Messages ¶
func (_m *MockclusterConsumer) Messages() <-chan *sarama.ConsumerMessage
func (*MockclusterConsumer) Notifications ¶
func (_m *MockclusterConsumer) Notifications() <-chan *sarama_cluster.Notification
type Mockkzoo ¶
type Mockkzoo struct {
// contains filtered or unexported fields
}
Mock of kzoo interface
func NewMockkzoo ¶
func NewMockkzoo(ctrl *gomock.Controller) *Mockkzoo
func (*Mockkzoo) CreateTopic ¶
Click to show internal directories.
Click to hide internal directories.