mock

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2020 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

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
}

MockClient is a mock of Client interface

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance

func (*MockClient) Brokers 

func (m *MockClient) Brokers() []*sarama.Broker

Brokers mocks base method

func (*MockClient) Close 

func (m *MockClient) Close() error

Close mocks base method

func (*MockClient) Closed 

func (m *MockClient) Closed() bool

Closed mocks base method

func (*MockClient) Config 

func (m *MockClient) Config() *sarama.Config

Config mocks base method

func (*MockClient) Controller 

func (m *MockClient) Controller() (*sarama.Broker, error)

Controller mocks base method

func (*MockClient) Coordinator 

func (m *MockClient) Coordinator(arg0 string) (*sarama.Broker, error)

Coordinator mocks base method

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockClient) GetOffset 

func (m *MockClient) GetOffset(arg0 string, arg1 int32, arg2 int64) (int64, error)

GetOffset mocks base method

func (*MockClient) InSyncReplicas 

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

InSyncReplicas mocks base method

func (*MockClient) InitProducerID added in v0.1.1 

func (m *MockClient) InitProducerID() (*sarama.InitProducerIDResponse, error)

InitProducerID mocks base method

func (*MockClient) Leader 

func (m *MockClient) Leader(arg0 string, arg1 int32) (*sarama.Broker, error)

Leader mocks base method

func (*MockClient) OfflineReplicas added in v0.1.2 

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

OfflineReplicas mocks base method

func (*MockClient) Partitions 

func (m *MockClient) Partitions(arg0 string) ([]int32, error)

Partitions mocks base method

func (*MockClient) RefreshCoordinator 

func (m *MockClient) RefreshCoordinator(arg0 string) error

RefreshCoordinator mocks base method

func (*MockClient) RefreshMetadata 

func (m *MockClient) RefreshMetadata(arg0 ...string) error

RefreshMetadata mocks base method

func (*MockClient) Replicas 

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

Replicas mocks base method

func (*MockClient) Topics 

func (m *MockClient) Topics() ([]string, error)

Topics mocks base method

func (*MockClient) WritablePartitions 

func (m *MockClient) WritablePartitions(arg0 string) ([]int32, error)

WritablePartitions mocks base method

type MockClientMockRecorder added in v0.1.2 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient

func (*MockClientMockRecorder) Brokers added in v0.1.2 

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

Brokers indicates an expected call of Brokers

func (*MockClientMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockClientMockRecorder) Closed added in v0.1.2 

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

Closed indicates an expected call of Closed

func (*MockClientMockRecorder) Config added in v0.1.2 

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

Config indicates an expected call of Config

func (*MockClientMockRecorder) Controller added in v0.1.2 

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

Controller indicates an expected call of Controller

func (*MockClientMockRecorder) Coordinator added in v0.1.2 

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

Coordinator indicates an expected call of Coordinator

func (*MockClientMockRecorder) GetOffset added in v0.1.2 

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

GetOffset indicates an expected call of GetOffset

func (*MockClientMockRecorder) InSyncReplicas added in v0.1.2 

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

InSyncReplicas indicates an expected call of InSyncReplicas

func (*MockClientMockRecorder) InitProducerID added in v0.1.2 

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

InitProducerID indicates an expected call of InitProducerID

func (*MockClientMockRecorder) Leader added in v0.1.2 

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

Leader indicates an expected call of Leader

func (*MockClientMockRecorder) OfflineReplicas added in v0.1.2 

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

OfflineReplicas indicates an expected call of OfflineReplicas

func (*MockClientMockRecorder) Partitions added in v0.1.2 

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

Partitions indicates an expected call of Partitions

func (*MockClientMockRecorder) RefreshCoordinator added in v0.1.2 

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

RefreshCoordinator indicates an expected call of RefreshCoordinator

func (*MockClientMockRecorder) RefreshMetadata added in v0.1.2 

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

RefreshMetadata indicates an expected call of RefreshMetadata

func (*MockClientMockRecorder) Replicas added in v0.1.2 

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

Replicas indicates an expected call of Replicas

func (*MockClientMockRecorder) Topics added in v0.1.2 

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

Topics indicates an expected call of Topics

func (*MockClientMockRecorder) WritablePartitions added in v0.1.2 

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

WritablePartitions indicates an expected call of WritablePartitions

type MockConsumer 

type MockConsumer struct {
	// contains filtered or unexported fields
}

MockConsumer is a mock of Consumer interface

func NewMockConsumer 

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance

func (*MockConsumer) Close 

func (m *MockConsumer) Close() error

Close mocks base method

func (*MockConsumer) ConsumePartition 

func (m *MockConsumer) ConsumePartition(arg0 string, arg1 int32, arg2 int64) (sarama.PartitionConsumer, error)

ConsumePartition mocks base method

func (*MockConsumer) EXPECT 

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConsumer) HighWaterMarks 

func (m *MockConsumer) HighWaterMarks() map[string]map[int32]int64

HighWaterMarks mocks base method

func (*MockConsumer) Partitions 

func (m *MockConsumer) Partitions(arg0 string) ([]int32, error)

Partitions mocks base method

func (*MockConsumer) Topics 

func (m *MockConsumer) Topics() ([]string, error)

Topics mocks base method

type MockConsumerMockRecorder added in v0.1.2 

type MockConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerMockRecorder is the mock recorder for MockConsumer

func (*MockConsumerMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockConsumerMockRecorder) ConsumePartition added in v0.1.2 

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

ConsumePartition indicates an expected call of ConsumePartition

func (*MockConsumerMockRecorder) HighWaterMarks added in v0.1.2 

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

HighWaterMarks indicates an expected call of HighWaterMarks

func (*MockConsumerMockRecorder) Partitions added in v0.1.2 

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

Partitions indicates an expected call of Partitions

func (*MockConsumerMockRecorder) Topics added in v0.1.2 

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

Topics indicates an expected call of Topics

type MockPartitionConsumer 

type MockPartitionConsumer struct {
	// contains filtered or unexported fields
}

MockPartitionConsumer is a mock of PartitionConsumer interface

func NewMockPartitionConsumer 

func NewMockPartitionConsumer(ctrl *gomock.Controller) *MockPartitionConsumer

NewMockPartitionConsumer creates a new mock instance

func (*MockPartitionConsumer) AsyncClose 

func (m *MockPartitionConsumer) AsyncClose()

AsyncClose mocks base method

func (*MockPartitionConsumer) Close 

func (m *MockPartitionConsumer) Close() error

Close mocks base method

func (*MockPartitionConsumer) EXPECT 

func (m *MockPartitionConsumer) EXPECT() *MockPartitionConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPartitionConsumer) Errors 

func (m *MockPartitionConsumer) Errors() <-chan *sarama.ConsumerError

Errors mocks base method

func (*MockPartitionConsumer) HighWaterMarkOffset 

func (m *MockPartitionConsumer) HighWaterMarkOffset() int64

HighWaterMarkOffset mocks base method

func (*MockPartitionConsumer) Messages 

func (m *MockPartitionConsumer) Messages() <-chan *sarama.ConsumerMessage

Messages mocks base method

type MockPartitionConsumerMockRecorder added in v0.1.2 

type MockPartitionConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockPartitionConsumerMockRecorder is the mock recorder for MockPartitionConsumer

func (*MockPartitionConsumerMockRecorder) AsyncClose added in v0.1.2 

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

AsyncClose indicates an expected call of AsyncClose

func (*MockPartitionConsumerMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockPartitionConsumerMockRecorder) Errors added in v0.1.2 

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

Errors indicates an expected call of Errors

func (*MockPartitionConsumerMockRecorder) HighWaterMarkOffset added in v0.1.2 

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

HighWaterMarkOffset indicates an expected call of HighWaterMarkOffset

func (*MockPartitionConsumerMockRecorder) Messages added in v0.1.2 

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

Messages indicates an expected call of Messages

type MockTopicManager 

type MockTopicManager struct {
	// contains filtered or unexported fields
}

MockTopicManager is a mock of TopicManager interface

func NewMockTopicManager 

func NewMockTopicManager(ctrl *gomock.Controller) *MockTopicManager

NewMockTopicManager creates a new mock instance

func (*MockTopicManager) Close 

func (m *MockTopicManager) Close() error

Close mocks base method

func (*MockTopicManager) EXPECT 

func (m *MockTopicManager) EXPECT() *MockTopicManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTopicManager) EnsureStreamExists 

func (m *MockTopicManager) EnsureStreamExists(topic string, npar int) error

EnsureStreamExists mocks base method

func (*MockTopicManager) EnsureTableExists 

func (m *MockTopicManager) EnsureTableExists(topic string, npar int) error

EnsureTableExists mocks base method

func (*MockTopicManager) EnsureTopicExists added in v0.1.1 

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

EnsureTopicExists mocks base method

func (*MockTopicManager) Partitions 

func (m *MockTopicManager) Partitions(topic string) ([]int32, error)

Partitions mocks base method

type MockTopicManagerMockRecorder added in v0.1.2 

type MockTopicManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopicManagerMockRecorder is the mock recorder for MockTopicManager

func (*MockTopicManagerMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockTopicManagerMockRecorder) EnsureStreamExists added in v0.1.2 

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

EnsureStreamExists indicates an expected call of EnsureStreamExists

func (*MockTopicManagerMockRecorder) EnsureTableExists added in v0.1.2 

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

EnsureTableExists indicates an expected call of EnsureTableExists

func (*MockTopicManagerMockRecorder) EnsureTopicExists added in v0.1.2 

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

EnsureTopicExists indicates an expected call of EnsureTopicExists

func (*MockTopicManagerMockRecorder) Partitions added in v0.1.2 

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

Partitions indicates an expected call of Partitions

type MockclusterConsumer 

type MockclusterConsumer struct {
	// contains filtered or unexported fields
}

MockclusterConsumer is a mock of clusterConsumer interface

func NewMockclusterConsumer 

func NewMockclusterConsumer(ctrl *gomock.Controller) *MockclusterConsumer

NewMockclusterConsumer creates a new mock instance

func (*MockclusterConsumer) Close 

func (m *MockclusterConsumer) Close() error

Close mocks base method

func (*MockclusterConsumer) EXPECT 

func (m *MockclusterConsumer) EXPECT() *MockclusterConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockclusterConsumer) Errors 

func (m *MockclusterConsumer) Errors() <-chan error

Errors mocks base method

func (*MockclusterConsumer) MarkPartitionOffset 

func (m *MockclusterConsumer) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)

MarkPartitionOffset mocks base method

func (*MockclusterConsumer) Messages 

func (m *MockclusterConsumer) Messages() <-chan *sarama.ConsumerMessage

Messages mocks base method

func (*MockclusterConsumer) Notifications 

func (m *MockclusterConsumer) Notifications() <-chan *sarama_cluster.Notification

Notifications mocks base method

type MockclusterConsumerMockRecorder added in v0.1.2 

type MockclusterConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockclusterConsumerMockRecorder is the mock recorder for MockclusterConsumer

func (*MockclusterConsumerMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockclusterConsumerMockRecorder) Errors added in v0.1.2 

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

Errors indicates an expected call of Errors

func (*MockclusterConsumerMockRecorder) MarkPartitionOffset added in v0.1.2 

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

MarkPartitionOffset indicates an expected call of MarkPartitionOffset

func (*MockclusterConsumerMockRecorder) Messages added in v0.1.2 

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

Messages indicates an expected call of Messages

func (*MockclusterConsumerMockRecorder) Notifications added in v0.1.2 

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

Notifications indicates an expected call of Notifications

type Mockkzoo 

type Mockkzoo struct {
	// contains filtered or unexported fields
}

Mockkzoo is a mock of kzoo interface

func NewMockkzoo 

func NewMockkzoo(ctrl *gomock.Controller) *Mockkzoo

NewMockkzoo creates a new mock instance

func (*Mockkzoo) Close 

func (m *Mockkzoo) Close() error

Close mocks base method

func (*Mockkzoo) CreateTopic 

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

CreateTopic mocks base method

func (*Mockkzoo) EXPECT 

func (m *Mockkzoo) EXPECT() *MockkzooMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*Mockkzoo) Topic 

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

Topic mocks base method

func (*Mockkzoo) Topics 

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

Topics mocks base method

type MockkzooMockRecorder added in v0.1.2 

type MockkzooMockRecorder struct {
	// contains filtered or unexported fields
}

MockkzooMockRecorder is the mock recorder for Mockkzoo

func (*MockkzooMockRecorder) Close added in v0.1.2 

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

Close indicates an expected call of Close

func (*MockkzooMockRecorder) CreateTopic added in v0.1.2 

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

CreateTopic indicates an expected call of CreateTopic

func (*MockkzooMockRecorder) Topic added in v0.1.2 

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

Topic indicates an expected call of Topic

func (*MockkzooMockRecorder) Topics added in v0.1.2 

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

Topics indicates an expected call of Topics

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.