mocks

package
v0.0.0-...-2a2fe1c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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:

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL