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 ¶
- type MockClientProvider
- func (m *MockClientProvider) Close() error
- func (m *MockClientProvider) EXPECT() *MockClientProviderMockRecorder
- func (m *MockClientProvider) Reader(ctx context.Context, topicConfig zkafka.ConsumerTopicConfig, ...) (zkafka.Reader, error)
- func (m *MockClientProvider) Writer(ctx context.Context, topicConfig zkafka.ProducerTopicConfig, ...) (zkafka.Writer, error)
- type MockClientProviderMockRecorder
- type MockLogger
- func (m *MockLogger) Debugw(ctx context.Context, msg string, keysAndValues ...any)
- func (m *MockLogger) EXPECT() *MockLoggerMockRecorder
- func (m *MockLogger) Errorw(ctx context.Context, msg string, keysAndValues ...any)
- func (m *MockLogger) Infow(ctx context.Context, msg string, keysAndValues ...any)
- func (m *MockLogger) Warnw(ctx context.Context, msg string, keysAndValues ...any)
- type MockLoggerMockRecorder
- func (mr *MockLoggerMockRecorder) Debugw(ctx, msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Errorw(ctx, msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Infow(ctx, msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Warnw(ctx, msg any, keysAndValues ...any) *gomock.Call
- type MockReader
- type MockReaderMockRecorder
- type MockWriter
- func (m *MockWriter) Close()
- func (m *MockWriter) EXPECT() *MockWriterMockRecorder
- func (m *MockWriter) Write(ctx context.Context, value any, opts ...zkafka.WriteOption) (zkafka.Response, error)
- func (m *MockWriter) WriteKey(ctx context.Context, key string, value any, opts ...zkafka.WriteOption) (zkafka.Response, error)
- func (m *MockWriter) WriteRaw(ctx context.Context, key *string, value []byte, opts ...zkafka.WriteOption) (zkafka.Response, error)
- type MockWriterMockRecorder
- func (mr *MockWriterMockRecorder) Close() *gomock.Call
- func (mr *MockWriterMockRecorder) Write(ctx, value any, opts ...any) *gomock.Call
- func (mr *MockWriterMockRecorder) WriteKey(ctx, key, value any, opts ...any) *gomock.Call
- func (mr *MockWriterMockRecorder) WriteRaw(ctx, key, value any, opts ...any) *gomock.Call
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.
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.
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.
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) EXPECT ¶
func (m *MockReader) EXPECT() *MockReaderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
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.
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, value any, opts ...zkafka.WriteOption) (zkafka.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) 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.