mock

package
v0.0.0-...-a83ac41 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2018 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

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

func (_m *MockClient) InitProducerID() (*sarama.InitProducerIDResponse, 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) EnsureTopicExists 

func (_m *MockTopicManager) EnsureTopicExists(topic string, npar int, rfactor int, config map[string]string) 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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.