Documentation
¶
Overview ¶
Package mock_kafka is a generated GoMock package.
Package mock_kafka 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) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) RefreshMetadata ¶
func (m *MockClient) RefreshMetadata(arg0 ...string) error
RefreshMetadata mocks base method.
func (*MockClient) Topics ¶
func (m *MockClient) Topics() ([]string, error)
Topics mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) Close ¶
func (mr *MockClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockClientMockRecorder) RefreshMetadata ¶
func (mr *MockClientMockRecorder) RefreshMetadata(arg0 ...interface{}) *gomock.Call
RefreshMetadata indicates an expected call of RefreshMetadata.
func (*MockClientMockRecorder) Topics ¶
func (mr *MockClientMockRecorder) Topics() *gomock.Call
Topics indicates an expected call of Topics.
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) 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.
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 interface{}) *gomock.Call
Consume indicates an expected call of Consume.
Source Files