mocks

Documentation

Index

• type Consumer
  • 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
  • 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
  • func (_m *PartitionConsumer) AsyncClose()
  • func (_m *PartitionConsumer) Close() error
  • func (_m *PartitionConsumer) Errors() <-chan *sarama.ConsumerError
  • func (_m *PartitionConsumer) HighWaterMarkOffset() int64
  • func (_m *PartitionConsumer) IsPaused() bool
  • func (_m *PartitionConsumer) Messages() <-chan *sarama.ConsumerMessage
  • func (_m *PartitionConsumer) Partition() int32
  • func (_m *PartitionConsumer) Pause()
  • func (_m *PartitionConsumer) Resume()
  • func (_m *PartitionConsumer) Topic() string

Types

type Consumer

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func (*Consumer) Close

func (_m *Consumer) Close() error

Close provides a mock function with given fields:

func (*Consumer) MarkPartitionOffset

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

MarkPartitionOffset provides a mock function with given fields: topic, partition, offset, metadata

func (*Consumer) Partitions

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

Partitions provides a mock function with given fields:

type Message

type Message struct {
	mock.Mock
}

Message is an autogenerated mock type for the Message type

func (*Message) Key

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

Key provides a mock function with given fields:

func (*Message) Offset

func (_m *Message) Offset() int64

Offset provides a mock function with given fields:

func (*Message) Partition

func (_m *Message) Partition() int32

Partition provides a mock function with given fields:

func (*Message) Topic

func (_m *Message) Topic() string

Topic provides a mock function with given fields:

func (*Message) Value

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

Value provides a mock function with given fields:

type PartitionConsumer

type PartitionConsumer struct {
	mock.Mock
}

PartitionConsumer is an autogenerated mock type for the PartitionConsumer type

func (*PartitionConsumer) AsyncClose

func (_m *PartitionConsumer) AsyncClose()

AsyncClose provides a mock function with given fields:

func (*PartitionConsumer) Close

func (_m *PartitionConsumer) Close() error

Close provides a mock function with given fields:

func (*PartitionConsumer) Errors

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

Errors provides a mock function with given fields:

func (*PartitionConsumer) HighWaterMarkOffset

func (_m *PartitionConsumer) HighWaterMarkOffset() int64

HighWaterMarkOffset provides a mock function with given fields:

func (*PartitionConsumer) IsPaused

func (_m *PartitionConsumer) IsPaused() bool

IsPaused mocked.

func (*PartitionConsumer) Messages

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

Messages provides a mock function with given fields:

func (*PartitionConsumer) Partition

func (_m *PartitionConsumer) Partition() int32

Partition provides a mock function with given fields:

func (*PartitionConsumer) Pause

func (_m *PartitionConsumer) Pause()

Pause mocked.

func (*PartitionConsumer) Resume

func (_m *PartitionConsumer) Resume()

Resume mocked.

func (*PartitionConsumer) Topic

func (_m *PartitionConsumer) Topic() string

Topic provides a mock function with given fields: