Documentation
¶
Overview ¶
Code generated by mockery v1.0.0. DO NOT EDIT.
Index ¶
- type MessageConsumer
- type MockMessageConsumer
- func (_m *MockMessageConsumer) Assign(partitions []kafka.TopicPartition) error
- func (_m *MockMessageConsumer) Close() error
- func (_m *MockMessageConsumer) Committed(partitions []kafka.TopicPartition, timeoutMs int) ([]kafka.TopicPartition, error)
- func (_m *MockMessageConsumer) Events() chan kafka.Event
- func (_m *MockMessageConsumer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)
- func (_m *MockMessageConsumer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (int64, int64, error)
- func (_m *MockMessageConsumer) Subscribe(_a0 string, _a1 kafka.RebalanceCb) error
- func (_m *MockMessageConsumer) Unassign() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageConsumer ¶
type MessageConsumer interface {
Subscribe(string, kafka.RebalanceCb) error
Events() chan kafka.Event
Assign(partitions []kafka.TopicPartition) error
Unassign() (err error)
Committed(partitions []kafka.TopicPartition, timeoutMs int) (offsets []kafka.TopicPartition, err error)
QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (low, high int64, err error)
GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)
Close() (err error)
}
MessageConsumer is an interface for 'kafka.Consumer' to make it mockable. if that interface changes, the mock can be regenerated from this dir with:
mockery -name MessageConsumer -inpkg .
type MockMessageConsumer ¶
MockMessageConsumer is an autogenerated mock type for the MessageConsumer type
func (*MockMessageConsumer) Assign ¶
func (_m *MockMessageConsumer) Assign(partitions []kafka.TopicPartition) error
Assign provides a mock function with given fields: partitions
func (*MockMessageConsumer) Close ¶
func (_m *MockMessageConsumer) Close() error
Close provides a mock function with given fields:
func (*MockMessageConsumer) Committed ¶
func (_m *MockMessageConsumer) Committed(partitions []kafka.TopicPartition, timeoutMs int) ([]kafka.TopicPartition, error)
Committed provides a mock function with given fields: partitions, timeoutMs
func (*MockMessageConsumer) Events ¶
func (_m *MockMessageConsumer) Events() chan kafka.Event
Events provides a mock function with given fields:
func (*MockMessageConsumer) GetMetadata ¶
func (_m *MockMessageConsumer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)
GetMetadata provides a mock function with given fields: topic, allTopics, timeoutMs
func (*MockMessageConsumer) QueryWatermarkOffsets ¶
func (_m *MockMessageConsumer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (int64, int64, error)
QueryWatermarkOffsets provides a mock function with given fields: topic, partition, timeoutMs
func (*MockMessageConsumer) Subscribe ¶
func (_m *MockMessageConsumer) Subscribe(_a0 string, _a1 kafka.RebalanceCb) error
Subscribe provides a mock function with given fields: _a0, _a1
func (*MockMessageConsumer) Unassign ¶
func (_m *MockMessageConsumer) Unassign() error
Unassign provides a mock function with given fields:
Source Files