mocks

Documentation

Index

• type ClientFactory
  • func (_m *ClientFactory) NewConsumer(config kafka.ConfigMap) (pkgkafka.Consumer, error)
  • func (_m *ClientFactory) NewProducer(config kafka.ConfigMap) (pkgkafka.Producer, error)
• type Consumer
  • func (_m *Consumer) Close() error
  • func (_m *Consumer) Commit() ([]confluent_kafka_gokafka.TopicPartition, error)
  • func (_m *Consumer) CommitOffsets(offsets []confluent_kafka_gokafka.TopicPartition) ([]confluent_kafka_gokafka.TopicPartition, error)
  • func (_m *Consumer) ReadMessage(timeout time.Duration) (*confluent_kafka_gokafka.Message, error)
  • func (_m *Consumer) Subscribe(topic string, rebalanceCb confluent_kafka_gokafka.RebalanceCb) error
• type Producer
  • func (_m *Producer) Close()
  • func (_m *Producer) Flush(timoutMs int) int
  • func (_m *Producer) Produce(msg *confluent_kafka_gokafka.Message, ...) error

Types

type ClientFactory

type ClientFactory struct {
	mock.Mock
}

ClientFactory is an autogenerated mock type for the ClientFactory type

func (*ClientFactory) NewConsumer

func (_m *ClientFactory) NewConsumer(config kafka.ConfigMap) (pkgkafka.Consumer, error)

NewConsumer provides a mock function with given fields: config

func (*ClientFactory) NewProducer

func (_m *ClientFactory) NewProducer(config kafka.ConfigMap) (pkgkafka.Producer, error)

NewProducer provides a mock function with given fields: config

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) Commit

func (_m *Consumer) Commit() ([]confluent_kafka_gokafka.TopicPartition, error)

Commit provides a mock function with given fields:

func (*Consumer) CommitOffsets

func (_m *Consumer) CommitOffsets(offsets []confluent_kafka_gokafka.TopicPartition) ([]confluent_kafka_gokafka.TopicPartition, error)

CommitOffsets provides a mock function with given fields: offsets

func (*Consumer) ReadMessage

func (_m *Consumer) ReadMessage(timeout time.Duration) (*confluent_kafka_gokafka.Message, error)

ReadMessage provides a mock function with given fields: timeout

func (*Consumer) Subscribe

func (_m *Consumer) Subscribe(topic string, rebalanceCb confluent_kafka_gokafka.RebalanceCb) error

Subscribe provides a mock function with given fields: topic, rebalanceCb

type Producer

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func (*Producer) Close

func (_m *Producer) Close()

Close provides a mock function with given fields:

func (*Producer) Flush

func (_m *Producer) Flush(timoutMs int) int

Flush provides a mock function with given fields: timoutMs

func (*Producer) Produce

func (_m *Producer) Produce(msg *confluent_kafka_gokafka.Message, deliveryChan chan confluent_kafka_gokafka.Event) error

Produce provides a mock function with given fields: msg, deliveryChan