mock_zkafka

package
v2.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package mock_zkafka is a generated GoMock package.

Package mock_zkafka is a generated GoMock package.

Package mock_zkafka is a generated GoMock package.

Package mock_zkafka is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClientProvider

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

MockClientProvider is a mock of ClientProvider interface.

func NewMockClientProvider

func NewMockClientProvider(ctrl *gomock.Controller) *MockClientProvider

NewMockClientProvider creates a new mock instance.

func (*MockClientProvider) Close

func (m *MockClientProvider) Close() error

Close mocks base method.

func (*MockClientProvider) EXPECT

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

func (*MockClientProvider) Reader

Reader mocks base method.

func (*MockClientProvider) Writer

Writer mocks base method.

type MockClientProviderMockRecorder

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

MockClientProviderMockRecorder is the mock recorder for MockClientProvider.

func (*MockClientProviderMockRecorder) Close

Close indicates an expected call of Close.

func (*MockClientProviderMockRecorder) Reader

func (mr *MockClientProviderMockRecorder) Reader(ctx, topicConfig any, opts ...any) *gomock.Call

Reader indicates an expected call of Reader.

func (*MockClientProviderMockRecorder) Writer

func (mr *MockClientProviderMockRecorder) Writer(ctx, topicConfig any, opts ...any) *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) Debugw

func (m *MockLogger) Debugw(ctx context.Context, msg string, keysAndValues ...any)

Debugw mocks base method.

func (*MockLogger) EXPECT

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Errorw

func (m *MockLogger) Errorw(ctx context.Context, msg string, keysAndValues ...any)

Errorw mocks base method.

func (*MockLogger) Infow

func (m *MockLogger) Infow(ctx context.Context, msg string, keysAndValues ...any)

Infow mocks base method.

func (*MockLogger) Warnw

func (m *MockLogger) Warnw(ctx context.Context, msg string, keysAndValues ...any)

Warnw mocks base method.

type MockLoggerMockRecorder

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Debugw

func (mr *MockLoggerMockRecorder) Debugw(ctx, msg any, keysAndValues ...any) *gomock.Call

Debugw indicates an expected call of Debugw.

func (*MockLoggerMockRecorder) Errorw

func (mr *MockLoggerMockRecorder) Errorw(ctx, msg any, keysAndValues ...any) *gomock.Call

Errorw indicates an expected call of Errorw.

func (*MockLoggerMockRecorder) Infow

func (mr *MockLoggerMockRecorder) Infow(ctx, msg any, keysAndValues ...any) *gomock.Call

Infow indicates an expected call of Infow.

func (*MockLoggerMockRecorder) Warnw

func (mr *MockLoggerMockRecorder) Warnw(ctx, msg any, keysAndValues ...any) *gomock.Call

Warnw indicates an expected call of Warnw.

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

func (m *MockReader) Assignments(arg0 context.Context) ([]zkafka.Assignment, error)

Assignments mocks base method.

func (*MockReader) Close

func (m *MockReader) Close() error

Close mocks base method.

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) (*zkafka.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) Assignments

func (mr *MockReaderMockRecorder) Assignments(arg0 any) *gomock.Call

Assignments indicates an expected call of Assignments.

func (*MockReaderMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockReaderMockRecorder) Read

func (mr *MockReaderMockRecorder) Read(ctx any) *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) Close

func (m *MockWriter) Close()

Close mocks base method.

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, value any, opts ...zkafka.WriteOption) (zkafka.Response, error)

Write mocks base method.

func (*MockWriter) WriteKey

func (m *MockWriter) WriteKey(ctx context.Context, key string, value any, opts ...zkafka.WriteOption) (zkafka.Response, error)

WriteKey mocks base method.

func (*MockWriter) WriteRaw

func (m *MockWriter) WriteRaw(ctx context.Context, key *string, value []byte, opts ...zkafka.WriteOption) (zkafka.Response, error)

WriteRaw mocks base method.

type MockWriterMockRecorder

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

MockWriterMockRecorder is the mock recorder for MockWriter.

func (*MockWriterMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockWriterMockRecorder) Write

func (mr *MockWriterMockRecorder) Write(ctx, value any, opts ...any) *gomock.Call

Write indicates an expected call of Write.

func (*MockWriterMockRecorder) WriteKey

func (mr *MockWriterMockRecorder) WriteKey(ctx, key, value any, opts ...any) *gomock.Call

WriteKey indicates an expected call of WriteKey.

func (*MockWriterMockRecorder) WriteRaw

func (mr *MockWriterMockRecorder) WriteRaw(ctx, key, value any, opts ...any) *gomock.Call

WriteRaw indicates an expected call of WriteRaw.

Directories

Path Synopsis
Package mock_confluent is a generated GoMock package.
Package mock_confluent is a generated GoMock package.

Jump to

Keyboard shortcuts

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