mock

package

Go to main page

Versions in this module

v0

v0.1.4

Jan 22, 2020

v0.1.3

Jun 28, 2019

v0.1.2

Jun 18, 2019

Changes in this version

type MockClient

+ func (m *MockClient) OfflineReplicas(arg0 string, arg1 int32) ([]int32, error)

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) Brokers() *gomock.Call

+ func (mr *MockClientMockRecorder) Close() *gomock.Call

+ func (mr *MockClientMockRecorder) Closed() *gomock.Call

+ func (mr *MockClientMockRecorder) Config() *gomock.Call

+ func (mr *MockClientMockRecorder) Controller() *gomock.Call

+ func (mr *MockClientMockRecorder) Coordinator(arg0 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetOffset(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) InSyncReplicas(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) InitProducerID() *gomock.Call

+ func (mr *MockClientMockRecorder) Leader(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) OfflineReplicas(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) Partitions(arg0 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) RefreshCoordinator(arg0 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) RefreshMetadata(arg0 ...interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) Replicas(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) Topics() *gomock.Call

+ func (mr *MockClientMockRecorder) WritablePartitions(arg0 interface{}) *gomock.Call

+ type MockConsumerMockRecorder struct

+ func (mr *MockConsumerMockRecorder) Close() *gomock.Call

+ func (mr *MockConsumerMockRecorder) ConsumePartition(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockConsumerMockRecorder) HighWaterMarks() *gomock.Call

+ func (mr *MockConsumerMockRecorder) Partitions(arg0 interface{}) *gomock.Call

+ func (mr *MockConsumerMockRecorder) Topics() *gomock.Call

+ type MockPartitionConsumerMockRecorder struct

+ func (mr *MockPartitionConsumerMockRecorder) AsyncClose() *gomock.Call

+ func (mr *MockPartitionConsumerMockRecorder) Close() *gomock.Call

+ func (mr *MockPartitionConsumerMockRecorder) Errors() *gomock.Call

+ func (mr *MockPartitionConsumerMockRecorder) HighWaterMarkOffset() *gomock.Call

+ func (mr *MockPartitionConsumerMockRecorder) Messages() *gomock.Call

+ type MockTopicManagerMockRecorder struct

+ func (mr *MockTopicManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockTopicManagerMockRecorder) EnsureStreamExists(topic, npar interface{}) *gomock.Call

+ func (mr *MockTopicManagerMockRecorder) EnsureTableExists(topic, npar interface{}) *gomock.Call

+ func (mr *MockTopicManagerMockRecorder) EnsureTopicExists(topic, npar, rfactor, config interface{}) *gomock.Call

+ func (mr *MockTopicManagerMockRecorder) Partitions(topic interface{}) *gomock.Call

+ type MockclusterConsumerMockRecorder struct

+ func (mr *MockclusterConsumerMockRecorder) Close() *gomock.Call

+ func (mr *MockclusterConsumerMockRecorder) Errors() *gomock.Call

+ func (mr *MockclusterConsumerMockRecorder) MarkPartitionOffset(topic, partition, offset, metadata interface{}) *gomock.Call

+ func (mr *MockclusterConsumerMockRecorder) Messages() *gomock.Call

+ func (mr *MockclusterConsumerMockRecorder) Notifications() *gomock.Call

+ type MockkzooMockRecorder struct

+ func (mr *MockkzooMockRecorder) Close() *gomock.Call

+ func (mr *MockkzooMockRecorder) CreateTopic(topic, npar, rep, config interface{}) *gomock.Call

+ func (mr *MockkzooMockRecorder) Topic(topic interface{}) *gomock.Call

+ func (mr *MockkzooMockRecorder) Topics() *gomock.Call

v0.1.1

Jan 29, 2019

Changes in this version

type MockClient

+ func (_m *MockClient) InitProducerID() (*sarama.InitProducerIDResponse, error)

type MockTopicManager

+ func (_m *MockTopicManager) EnsureTopicExists(topic string, npar int, rfactor int, config map[string]string) error

v0.1.0

Aug 3, 2018

Changes in this version

+ type MockClient struct

+ 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) 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL