mocks

Sep 19, 2018

Changes in this version

+ type Consumer struct

+ func (_m *Consumer) Close() error

+ func (_m *Consumer) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)

+ func (_m *Consumer) Partitions() <-chan cluster.PartitionConsumer

+ type Message struct

+ func (_m *Message) Key() []byte

+ func (_m *Message) Offset() int64

+ func (_m *Message) Partition() int32

+ func (_m *Message) Topic() string

+ func (_m *Message) Value() []byte

+ type PartitionConsumer struct

+ func (_m *PartitionConsumer) AsyncClose()

+ func (_m *PartitionConsumer) Close() error

+ func (_m *PartitionConsumer) Errors() <-chan *sarama.ConsumerError

+ func (_m *PartitionConsumer) HighWaterMarkOffset() int64

+ func (_m *PartitionConsumer) Messages() <-chan *sarama.ConsumerMessage

+ func (_m *PartitionConsumer) Partition() int32

+ func (_m *PartitionConsumer) Topic() string