Versions in this module Expand all Collapse all v1 v1.0.0 Oct 17, 2023 Changes in this version + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *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 struct + func NewMockClientConversation(ctrl *gomock.Controller) *MockClientConversation + func (m *MockClientConversation) Done() bool + func (m *MockClientConversation) EXPECT() *MockClientConversationMockRecorder + func (m *MockClientConversation) Step(challenge string) (string, error) + type MockClientConversationMockRecorder struct + func (mr *MockClientConversationMockRecorder) Done() *gomock.Call + func (mr *MockClientConversationMockRecorder) Step(challenge interface{}) *gomock.Call + type MockClientMockRecorder struct + 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