Documentation
¶
Overview ¶
Package mockkafka is a generated GoMock package.
Package mockkafka is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) AsyncSendMessage(ctx context.Context, topic string, key, value []byte, ...) error
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) Produce(ctx context.Context, key, value []byte, headers ...sarama.RecordHeader) error
- func (m *MockClient) SendMessage(ctx context.Context, topic string, key, value []byte, ...) (int32, int64, error)
- func (m *MockClient) SendSaramaMessage(ctx context.Context, sMsg sarama.ProducerMessage) (int32, int64, error)
- type MockClientConversation
- type MockClientConversationMockRecorder
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) AsyncSendMessage(ctx, topic, key, value interface{}, headers ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Produce(ctx, key, value interface{}, headers ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SendMessage(ctx, topic, key, value interface{}, headers ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SendSaramaMessage(ctx, sMsg interface{}) *gomock.Call
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) AsyncSendMessage ¶
func (m *MockClient) AsyncSendMessage(ctx context.Context, topic string, key, value []byte, headers ...sarama.RecordHeader) error
AsyncSendMessage 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) Produce ¶
func (m *MockClient) Produce(ctx context.Context, key, value []byte, headers ...sarama.RecordHeader) error
Produce mocks base method
func (*MockClient) SendMessage ¶
func (m *MockClient) SendMessage(ctx context.Context, topic string, key, value []byte, headers ...sarama.RecordHeader) (int32, int64, error)
SendMessage mocks base method
func (*MockClient) SendSaramaMessage ¶
func (m *MockClient) SendSaramaMessage(ctx context.Context, sMsg sarama.ProducerMessage) (int32, int64, error)
SendSaramaMessage mocks base method
type MockClientConversation ¶
type MockClientConversation struct {
// contains filtered or unexported fields
}
MockClientConversation is a mock of ClientConversation interface.
func NewMockClientConversation ¶
func NewMockClientConversation(ctrl *gomock.Controller) *MockClientConversation
NewMockClientConversation creates a new mock instance.
func (*MockClientConversation) Done ¶
func (m *MockClientConversation) Done() bool
Done mocks base method.
func (*MockClientConversation) EXPECT ¶
func (m *MockClientConversation) EXPECT() *MockClientConversationMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockClientConversationMockRecorder ¶
type MockClientConversationMockRecorder struct {
// contains filtered or unexported fields
}
MockClientConversationMockRecorder is the mock recorder for MockClientConversation.
func (*MockClientConversationMockRecorder) Done ¶
func (mr *MockClientConversationMockRecorder) Done() *gomock.Call
Done indicates an expected call of Done.
func (*MockClientConversationMockRecorder) Step ¶
func (mr *MockClientConversationMockRecorder) Step(challenge interface{}) *gomock.Call
Step indicates an expected call of Step.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient
func (*MockClientMockRecorder) AsyncSendMessage ¶
func (mr *MockClientMockRecorder) AsyncSendMessage(ctx, topic, key, value interface{}, headers ...interface{}) *gomock.Call
AsyncSendMessage indicates an expected call of AsyncSendMessage
func (*MockClientMockRecorder) Produce ¶
func (mr *MockClientMockRecorder) Produce(ctx, key, value interface{}, headers ...interface{}) *gomock.Call
Produce indicates an expected call of Produce
func (*MockClientMockRecorder) SendMessage ¶
func (mr *MockClientMockRecorder) SendMessage(ctx, topic, key, value interface{}, headers ...interface{}) *gomock.Call
SendMessage indicates an expected call of SendMessage
func (*MockClientMockRecorder) SendSaramaMessage ¶
func (mr *MockClientMockRecorder) SendSaramaMessage(ctx, sMsg interface{}) *gomock.Call
SendSaramaMessage indicates an expected call of SendSaramaMessage
Source Files