kafka

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

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

type MockMessageConsumer struct {
	mock.Mock
}

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: