Documentation
¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: ./abstract.go
Generated by this command:
mockgen -source ./abstract.go -package writer -destination ./writer_mock.go
Package writer is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AbstractWriter ¶
type AbstractWriter interface {
WriteMessages(ctx context.Context, lgr log.Logger, topicName string, currMessages []serializer.SerializedMessage) error
Close() error
}
type AbstractWriterFactory ¶
type MockAbstractWriter ¶
type MockAbstractWriter struct {
// contains filtered or unexported fields
}
MockAbstractWriter is a mock of AbstractWriter interface.
func NewMockAbstractWriter ¶
func NewMockAbstractWriter(ctrl *gomock.Controller) *MockAbstractWriter
NewMockAbstractWriter creates a new mock instance.
func (*MockAbstractWriter) Close ¶
func (m *MockAbstractWriter) Close() error
Close mocks base method.
func (*MockAbstractWriter) EXPECT ¶
func (m *MockAbstractWriter) EXPECT() *MockAbstractWriterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAbstractWriter) WriteMessages ¶
func (m *MockAbstractWriter) WriteMessages(ctx context.Context, lgr log.Logger, topicName string, currMessages []queue.SerializedMessage) error
WriteMessages mocks base method.
type MockAbstractWriterFactory ¶
type MockAbstractWriterFactory struct {
// contains filtered or unexported fields
}
MockAbstractWriterFactory is a mock of AbstractWriterFactory interface.
func NewMockAbstractWriterFactory ¶
func NewMockAbstractWriterFactory(ctrl *gomock.Controller) *MockAbstractWriterFactory
NewMockAbstractWriterFactory creates a new mock instance.
func (*MockAbstractWriterFactory) BuildWriter ¶
func (m *MockAbstractWriterFactory) BuildWriter(brokers []string, compression kafka.Compression, saslMechanism sasl.Mechanism, tlsConfig *tls.Config, topicConfig [][2]string, batchBytes int64) AbstractWriter
BuildWriter mocks base method.
func (*MockAbstractWriterFactory) EXPECT ¶
func (m *MockAbstractWriterFactory) EXPECT() *MockAbstractWriterFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockAbstractWriterFactoryMockRecorder ¶
type MockAbstractWriterFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockAbstractWriterFactoryMockRecorder is the mock recorder for MockAbstractWriterFactory.
func (*MockAbstractWriterFactoryMockRecorder) BuildWriter ¶
func (mr *MockAbstractWriterFactoryMockRecorder) BuildWriter(brokers, compression, saslMechanism, tlsConfig, topicConfig, batchBytes any) *gomock.Call
BuildWriter indicates an expected call of BuildWriter.
type MockAbstractWriterMockRecorder ¶
type MockAbstractWriterMockRecorder struct {
// contains filtered or unexported fields
}
MockAbstractWriterMockRecorder is the mock recorder for MockAbstractWriter.
func (*MockAbstractWriterMockRecorder) Close ¶
func (mr *MockAbstractWriterMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockAbstractWriterMockRecorder) WriteMessages ¶
func (mr *MockAbstractWriterMockRecorder) WriteMessages(ctx, lgr, topicName, currMessages any) *gomock.Call
WriteMessages indicates an expected call of WriteMessages.
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) WriteMessages ¶
func (w *Writer) WriteMessages(ctx context.Context, lgr log.Logger, topicName string, currMessages []serializer.SerializedMessage) error
type WriterFactory ¶
type WriterFactory struct {
// contains filtered or unexported fields
}
func NewWriterFactory ¶
func NewWriterFactory(lgr log.Logger) *WriterFactory
func (*WriterFactory) BuildWriter ¶
func (c *WriterFactory) BuildWriter(brokers []string, compression kafka.Compression, saslMechanism sasl.Mechanism, tlsConfig *tls.Config, topicConfig [][2]string, batchBytes int64) AbstractWriter
Source Files