mock_sarama

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package mock_sarama 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 

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 

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

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

RefreshController 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 

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

MockClientMockRecorder is the mock recorder for MockClient

func (*MockClientMockRecorder) Brokers 

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

Brokers indicates an expected call of Brokers

func (*MockClientMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockClientMockRecorder) Closed 

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

Closed indicates an expected call of Closed

func (*MockClientMockRecorder) Config 

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

Config indicates an expected call of Config

func (*MockClientMockRecorder) Controller 

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

Controller indicates an expected call of Controller

func (*MockClientMockRecorder) Coordinator 

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

Coordinator indicates an expected call of Coordinator

func (*MockClientMockRecorder) GetOffset 

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

GetOffset indicates an expected call of GetOffset

func (*MockClientMockRecorder) InSyncReplicas 

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

InSyncReplicas indicates an expected call of InSyncReplicas

func (*MockClientMockRecorder) InitProducerID 

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

InitProducerID indicates an expected call of InitProducerID

func (*MockClientMockRecorder) Leader 

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

Leader indicates an expected call of Leader

func (*MockClientMockRecorder) OfflineReplicas 

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

OfflineReplicas indicates an expected call of OfflineReplicas

func (*MockClientMockRecorder) Partitions 

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

Partitions indicates an expected call of Partitions

func (*MockClientMockRecorder) RefreshController 

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

RefreshController indicates an expected call of RefreshController

func (*MockClientMockRecorder) RefreshCoordinator 

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

RefreshCoordinator indicates an expected call of RefreshCoordinator

func (*MockClientMockRecorder) RefreshMetadata 

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

RefreshMetadata indicates an expected call of RefreshMetadata

func (*MockClientMockRecorder) Replicas 

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

Replicas indicates an expected call of Replicas

func (*MockClientMockRecorder) Topics 

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

Topics indicates an expected call of Topics

func (*MockClientMockRecorder) WritablePartitions 

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

WritablePartitions indicates an expected call of WritablePartitions

type MockConsumerGroup 

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

MockConsumerGroup is a mock of ConsumerGroup interface

func NewMockConsumerGroup 

func NewMockConsumerGroup(ctrl *gomock.Controller) *MockConsumerGroup

NewMockConsumerGroup creates a new mock instance

func (*MockConsumerGroup) Close 

func (m *MockConsumerGroup) Close() error

Close mocks base method

func (*MockConsumerGroup) Consume 

func (m *MockConsumerGroup) Consume(arg0 context.Context, arg1 []string, arg2 sarama.ConsumerGroupHandler) error

Consume mocks base method

func (*MockConsumerGroup) EXPECT 

func (m *MockConsumerGroup) EXPECT() *MockConsumerGroupMockRecorder

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

func (*MockConsumerGroup) Errors 

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

Errors mocks base method

type MockConsumerGroupClaim 

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

MockConsumerGroupClaim is a mock of ConsumerGroupClaim interface

func NewMockConsumerGroupClaim 

func NewMockConsumerGroupClaim(ctrl *gomock.Controller) *MockConsumerGroupClaim

NewMockConsumerGroupClaim creates a new mock instance

func (*MockConsumerGroupClaim) EXPECT 

func (m *MockConsumerGroupClaim) EXPECT() *MockConsumerGroupClaimMockRecorder

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

func (*MockConsumerGroupClaim) HighWaterMarkOffset 

func (m *MockConsumerGroupClaim) HighWaterMarkOffset() int64

HighWaterMarkOffset mocks base method

func (*MockConsumerGroupClaim) InitialOffset 

func (m *MockConsumerGroupClaim) InitialOffset() int64

InitialOffset mocks base method

func (*MockConsumerGroupClaim) Messages 

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

Messages mocks base method

func (*MockConsumerGroupClaim) Partition 

func (m *MockConsumerGroupClaim) Partition() int32

Partition mocks base method

func (*MockConsumerGroupClaim) Topic 

func (m *MockConsumerGroupClaim) Topic() string

Topic mocks base method

type MockConsumerGroupClaimMockRecorder 

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

MockConsumerGroupClaimMockRecorder is the mock recorder for MockConsumerGroupClaim

func (*MockConsumerGroupClaimMockRecorder) HighWaterMarkOffset 

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

HighWaterMarkOffset indicates an expected call of HighWaterMarkOffset

func (*MockConsumerGroupClaimMockRecorder) InitialOffset 

func (mr *MockConsumerGroupClaimMockRecorder) InitialOffset() *gomock.Call

InitialOffset indicates an expected call of InitialOffset

func (*MockConsumerGroupClaimMockRecorder) Messages 

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

Messages indicates an expected call of Messages

func (*MockConsumerGroupClaimMockRecorder) Partition 

func (mr *MockConsumerGroupClaimMockRecorder) Partition() *gomock.Call

Partition indicates an expected call of Partition

func (*MockConsumerGroupClaimMockRecorder) Topic 

func (mr *MockConsumerGroupClaimMockRecorder) Topic() *gomock.Call

Topic indicates an expected call of Topic

type MockConsumerGroupMockRecorder 

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

MockConsumerGroupMockRecorder is the mock recorder for MockConsumerGroup

func (*MockConsumerGroupMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockConsumerGroupMockRecorder) Consume 

func (mr *MockConsumerGroupMockRecorder) Consume(arg0, arg1, arg2 interface{}) *gomock.Call

Consume indicates an expected call of Consume

func (*MockConsumerGroupMockRecorder) Errors 

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

Errors indicates an expected call of Errors

type MockConsumerGroupSession 

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

MockConsumerGroupSession is a mock of ConsumerGroupSession interface

func NewMockConsumerGroupSession 

func NewMockConsumerGroupSession(ctrl *gomock.Controller) *MockConsumerGroupSession

NewMockConsumerGroupSession creates a new mock instance

func (*MockConsumerGroupSession) Claims 

func (m *MockConsumerGroupSession) Claims() map[string][]int32

Claims mocks base method

func (*MockConsumerGroupSession) Context 

func (m *MockConsumerGroupSession) Context() context.Context

Context mocks base method

func (*MockConsumerGroupSession) EXPECT 

func (m *MockConsumerGroupSession) EXPECT() *MockConsumerGroupSessionMockRecorder

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

func (*MockConsumerGroupSession) GenerationID 

func (m *MockConsumerGroupSession) GenerationID() int32

GenerationID mocks base method

func (*MockConsumerGroupSession) MarkMessage 

func (m *MockConsumerGroupSession) MarkMessage(arg0 *sarama.ConsumerMessage, arg1 string)

MarkMessage mocks base method

func (*MockConsumerGroupSession) MarkOffset 

func (m *MockConsumerGroupSession) MarkOffset(arg0 string, arg1 int32, arg2 int64, arg3 string)

MarkOffset mocks base method

func (*MockConsumerGroupSession) MemberID 

func (m *MockConsumerGroupSession) MemberID() string

MemberID mocks base method

func (*MockConsumerGroupSession) ResetOffset 

func (m *MockConsumerGroupSession) ResetOffset(arg0 string, arg1 int32, arg2 int64, arg3 string)

ResetOffset mocks base method

type MockConsumerGroupSessionMockRecorder 

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

MockConsumerGroupSessionMockRecorder is the mock recorder for MockConsumerGroupSession

func (*MockConsumerGroupSessionMockRecorder) Claims 

func (mr *MockConsumerGroupSessionMockRecorder) Claims() *gomock.Call

Claims indicates an expected call of Claims

func (*MockConsumerGroupSessionMockRecorder) Context 

func (mr *MockConsumerGroupSessionMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConsumerGroupSessionMockRecorder) GenerationID 

func (mr *MockConsumerGroupSessionMockRecorder) GenerationID() *gomock.Call

GenerationID indicates an expected call of GenerationID

func (*MockConsumerGroupSessionMockRecorder) MarkMessage 

func (mr *MockConsumerGroupSessionMockRecorder) MarkMessage(arg0, arg1 interface{}) *gomock.Call

MarkMessage indicates an expected call of MarkMessage

func (*MockConsumerGroupSessionMockRecorder) MarkOffset 

func (mr *MockConsumerGroupSessionMockRecorder) MarkOffset(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

MarkOffset indicates an expected call of MarkOffset

func (*MockConsumerGroupSessionMockRecorder) MemberID 

func (mr *MockConsumerGroupSessionMockRecorder) MemberID() *gomock.Call

MemberID indicates an expected call of MemberID

func (*MockConsumerGroupSessionMockRecorder) ResetOffset 

func (mr *MockConsumerGroupSessionMockRecorder) ResetOffset(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

ResetOffset indicates an expected call of ResetOffset

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.