mock

Documentation

Index

• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *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) 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 NewMockConsumer(ctrl *gomock.Controller) *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 NewMockPartitionConsumer(ctrl *gomock.Controller) *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 NewMockTopicManager(ctrl *gomock.Controller) *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 NewMockclusterConsumer(ctrl *gomock.Controller) *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
  • func NewMockkzoo(ctrl *gomock.Controller) *Mockkzoo
  • func (_m *Mockkzoo) Close() error
  • func (_m *Mockkzoo) CreateTopic(topic string, npar int, rep int, config map[string]string) error
  • func (_m *Mockkzoo) EXPECT() *_MockkzooRecorder
  • func (_m *Mockkzoo) Topic(topic string) *kazoo_go.Topic
  • func (_m *Mockkzoo) Topics() (kazoo_go.TopicList, error)

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) Coordinator

func (_m *MockClient) Coordinator(_param0 string) (*sarama.Broker, error)

func (*MockClient) EXPECT

func (_m *MockClient) EXPECT() *_MockClientRecorder

func (*MockClient) GetOffset

func (_m *MockClient) GetOffset(_param0 string, _param1 int32, _param2 int64) (int64, error)

func (*MockClient) InSyncReplicas

func (_m *MockClient) InSyncReplicas(_param0 string, _param1 int32) ([]int32, error)

func (*MockClient) Leader

func (_m *MockClient) Leader(_param0 string, _param1 int32) (*sarama.Broker, 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) Close

func (_m *Mockkzoo) Close() error

func (*Mockkzoo) CreateTopic

func (_m *Mockkzoo) CreateTopic(topic string, npar int, rep int, config map[string]string) error

func (*Mockkzoo) EXPECT

func (_m *Mockkzoo) EXPECT() *_MockkzooRecorder

func (*Mockkzoo) Topic

func (_m *Mockkzoo) Topic(topic string) *kazoo_go.Topic

func (*Mockkzoo) Topics

func (_m *Mockkzoo) Topics() (kazoo_go.TopicList, error)