Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockAsyncProducer
- func (m *MockAsyncProducer) Close() error
- func (m *MockAsyncProducer) EXPECT() *MockAsyncProducerMockRecorder
- func (m *MockAsyncProducer) Produce(topic string, message []byte, opts ...kafka.MessageOption)
- func (m *MockAsyncProducer) ProduceWithContext(ctx context.Context, topic string, message []byte, opts ...kafka.MessageOption)
- type MockAsyncProducerMockRecorder
- type MockConsumerGroup
- type MockConsumerGroupMockRecorder
- type MockSyncProducer
- func (m *MockSyncProducer) Close() error
- func (m *MockSyncProducer) EXPECT() *MockSyncProducerMockRecorder
- func (m *MockSyncProducer) Produce(topic string, message []byte, opts ...kafka.MessageOption) error
- func (m *MockSyncProducer) ProduceWithContext(ctx context.Context, topic string, message []byte, opts ...kafka.MessageOption) error
- type MockSyncProducerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAsyncProducer ¶
type MockAsyncProducer struct {
// contains filtered or unexported fields
}
MockAsyncProducer is a mock of AsyncProducer interface.
func NewMockAsyncProducer ¶
func NewMockAsyncProducer(ctrl *gomock.Controller) *MockAsyncProducer
NewMockAsyncProducer creates a new mock instance.
func (*MockAsyncProducer) Close ¶
func (m *MockAsyncProducer) Close() error
Close mocks base method.
func (*MockAsyncProducer) EXPECT ¶
func (m *MockAsyncProducer) EXPECT() *MockAsyncProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAsyncProducer) Produce ¶
func (m *MockAsyncProducer) Produce(topic string, message []byte, opts ...kafka.MessageOption)
Produce mocks base method.
func (*MockAsyncProducer) ProduceWithContext ¶
func (m *MockAsyncProducer) ProduceWithContext(ctx context.Context, topic string, message []byte, opts ...kafka.MessageOption)
ProduceWithContext mocks base method.
type MockAsyncProducerMockRecorder ¶
type MockAsyncProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockAsyncProducerMockRecorder is the mock recorder for MockAsyncProducer.
func (*MockAsyncProducerMockRecorder) Close ¶
func (mr *MockAsyncProducerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockAsyncProducerMockRecorder) Produce ¶
func (mr *MockAsyncProducerMockRecorder) Produce(topic, message interface{}, opts ...interface{}) *gomock.Call
Produce indicates an expected call of Produce.
func (*MockAsyncProducerMockRecorder) ProduceWithContext ¶
func (mr *MockAsyncProducerMockRecorder) ProduceWithContext(ctx, topic, message interface{}, opts ...interface{}) *gomock.Call
ProduceWithContext indicates an expected call of ProduceWithContext.
type MockConsumerGroup ¶
type MockConsumerGroup struct {
// contains filtered or unexported fields
}
MockConsumerGroup is a mock of ConsumerGroup interface.
func NewMockConsumerGroup ¶
func NewMockConsumerGroup(ctrl *gomock.Controller) *MockConsumerGroup
NewMockConsumerGroup creates a new mock instance.
func (*MockConsumerGroup) Close ¶
func (m *MockConsumerGroup) Close() error
Close mocks base method.
func (*MockConsumerGroup) Consume ¶
func (m *MockConsumerGroup) Consume(ctx context.Context, topic []string, handler kafka.Handler) error
Consume mocks base method.
func (*MockConsumerGroup) EXPECT ¶
func (m *MockConsumerGroup) EXPECT() *MockConsumerGroupMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockConsumerGroupMockRecorder ¶
type MockConsumerGroupMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerGroupMockRecorder is the mock recorder for MockConsumerGroup.
func (*MockConsumerGroupMockRecorder) Close ¶
func (mr *MockConsumerGroupMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockConsumerGroupMockRecorder) Consume ¶
func (mr *MockConsumerGroupMockRecorder) Consume(ctx, topic, handler interface{}) *gomock.Call
Consume indicates an expected call of Consume.
type MockSyncProducer ¶
type MockSyncProducer struct {
// contains filtered or unexported fields
}
MockSyncProducer is a mock of SyncProducer interface.
func NewMockSyncProducer ¶
func NewMockSyncProducer(ctrl *gomock.Controller) *MockSyncProducer
NewMockSyncProducer creates a new mock instance.
func (*MockSyncProducer) EXPECT ¶
func (m *MockSyncProducer) EXPECT() *MockSyncProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSyncProducer) Produce ¶
func (m *MockSyncProducer) Produce(topic string, message []byte, opts ...kafka.MessageOption) error
Produce mocks base method.
func (*MockSyncProducer) ProduceWithContext ¶
func (m *MockSyncProducer) ProduceWithContext(ctx context.Context, topic string, message []byte, opts ...kafka.MessageOption) error
ProduceWithContext mocks base method.
type MockSyncProducerMockRecorder ¶
type MockSyncProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockSyncProducerMockRecorder is the mock recorder for MockSyncProducer.
func (*MockSyncProducerMockRecorder) Close ¶
func (mr *MockSyncProducerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockSyncProducerMockRecorder) Produce ¶
func (mr *MockSyncProducerMockRecorder) Produce(topic, message interface{}, opts ...interface{}) *gomock.Call
Produce indicates an expected call of Produce.
func (*MockSyncProducerMockRecorder) ProduceWithContext ¶
func (mr *MockSyncProducerMockRecorder) ProduceWithContext(ctx, topic, message interface{}, opts ...interface{}) *gomock.Call
ProduceWithContext indicates an expected call of ProduceWithContext.
Source Files