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 

func (m *MockClientProvider) EXPECT() *MockClientProviderMockRecorder

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

func (*MockClientProvider) Reader 

func (m *MockClientProvider) Reader(ctx context.Context, topicConfig zkafka.ConsumerTopicConfig, opts ...zkafka.ReaderOption) (zkafka.Reader, error)

Reader mocks base method.

func (*MockClientProvider) Writer 

func (m *MockClientProvider) Writer(ctx context.Context, topicConfig zkafka.ProducerTopicConfig, opts ...zkafka.WriterOption) (zkafka.Writer, error)

Writer mocks base method.

type MockClientProviderMockRecorder 

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

MockClientProviderMockRecorder is the mock recorder for MockClientProvider.

func (*MockClientProviderMockRecorder) Close 

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

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.

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.