mock_kafka

package
v0.0.0-...-3e16b6b Latest Latest
Warning

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

Go to latest
Published: Dec 18, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

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

func (m *MockClient) Reader(ctx context.Context, topicConfig kafka.Config) (kafka.Reader, error)

Reader mocks base method.

func (*MockClient) Writer

func (m *MockClient) Writer(ctx context.Context, topicConfig kafka.Config) (kafka.Writer, error)

Writer mocks base method.

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Reader

func (mr *MockClientMockRecorder) Reader(ctx, topicConfig interface{}) *gomock.Call

Reader indicates an expected call of Reader.

func (*MockClientMockRecorder) Writer

func (mr *MockClientMockRecorder) Writer(ctx, topicConfig interface{}) *gomock.Call

Writer indicates an expected call of Writer.

type MockLogger

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

MockLogger is a mock of Logger interface.

func NewMockLogger

func NewMockLogger(ctrl *gomock.Controller) *MockLogger

NewMockLogger creates a new mock instance.

func (*MockLogger) EXPECT

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Error

func (m *MockLogger) Error(ctx context.Context, msg string, keysAndValues ...interface{})

Error mocks base method.

func (*MockLogger) Info

func (m *MockLogger) Info(ctx context.Context, msg string, keysAndValues ...interface{})

Info mocks base method.

type MockLoggerMockRecorder

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Error

func (mr *MockLoggerMockRecorder) Error(ctx, msg interface{}, keysAndValues ...interface{}) *gomock.Call

Error indicates an expected call of Error.

func (*MockLoggerMockRecorder) Info

func (mr *MockLoggerMockRecorder) Info(ctx, msg interface{}, keysAndValues ...interface{}) *gomock.Call

Info indicates an expected call of Info.

type MockReader

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

MockReader is a mock of Reader interface.

func NewMockReader

func NewMockReader(ctrl *gomock.Controller) *MockReader

NewMockReader creates a new mock instance.

func (*MockReader) EXPECT

func (m *MockReader) EXPECT() *MockReaderMockRecorder

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

func (*MockReader) Read

func (m *MockReader) Read(ctx context.Context) (*kafka.Message, error)

Read mocks base method.

type MockReaderMockRecorder

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

MockReaderMockRecorder is the mock recorder for MockReader.

func (*MockReaderMockRecorder) Read

func (mr *MockReaderMockRecorder) Read(ctx interface{}) *gomock.Call

Read indicates an expected call of Read.

type MockWriter

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

MockWriter is a mock of Writer interface.

func NewMockWriter

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance.

func (*MockWriter) EXPECT

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Write

func (m *MockWriter) Write(ctx context.Context, key string, value []byte) (kafka.Response, error)

Write mocks base method.

type MockWriterMockRecorder

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

MockWriterMockRecorder is the mock recorder for MockWriter.

func (*MockWriterMockRecorder) Write

func (mr *MockWriterMockRecorder) Write(ctx, key, value interface{}) *gomock.Call

Write indicates an expected call of Write.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL