producer

Documentation

Overview

Package producer is a generated GoMock package.

Index

• type Delivery
• type MockProducer
  • func NewMockProducer(ctrl *gomock.Controller) *MockProducer
  • func (m *MockProducer) Close()
  • func (m *MockProducer) Delivery(chDelivery chan Delivery)
  • func (m *MockProducer) EXPECT() *MockProducerMockRecorder
  • func (m *MockProducer) Flush(timeoutMs int) int
  • func (m *MockProducer) Produce(msg kafkamod.Message) error
• type MockProducerMockRecorder
  • func (mr *MockProducerMockRecorder) Close() *gomock.Call
  • func (mr *MockProducerMockRecorder) Delivery(chDelivery interface{}) *gomock.Call
  • func (mr *MockProducerMockRecorder) Flush(timeoutMs interface{}) *gomock.Call
  • func (mr *MockProducerMockRecorder) Produce(msg interface{}) *gomock.Call
• type Options
• type Producer
  • func New(opts Options) (p Producer, err error)

Types

type Delivery

type Delivery struct {
	TopicPartition kafkamod.TopicPartition
	Error          error
}

type MockProducer

type MockProducer struct {
	// contains filtered or unexported fields
}

MockProducer is a mock of Producer interface.

func NewMockProducer

func NewMockProducer(ctrl *gomock.Controller) *MockProducer

NewMockProducer creates a new mock instance.

func (*MockProducer) Close

func (m *MockProducer) Close()

Close mocks base method.

func (*MockProducer) Delivery

func (m *MockProducer) Delivery(chDelivery chan Delivery)

Delivery mocks base method.

func (*MockProducer) EXPECT

func (m *MockProducer) EXPECT() *MockProducerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProducer) Flush

func (m *MockProducer) Flush(timeoutMs int) int

Flush mocks base method.

func (*MockProducer) Produce

func (m *MockProducer) Produce(msg kafkamod.Message) error

Produce mocks base method.

type MockProducerMockRecorder

type MockProducerMockRecorder struct {
	// contains filtered or unexported fields
}

MockProducerMockRecorder is the mock recorder for MockProducer.

func (*MockProducerMockRecorder) Close

func (mr *MockProducerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockProducerMockRecorder) Delivery

func (mr *MockProducerMockRecorder) Delivery(chDelivery interface{}) *gomock.Call

Delivery indicates an expected call of Delivery.

func (*MockProducerMockRecorder) Flush

func (mr *MockProducerMockRecorder) Flush(timeoutMs interface{}) *gomock.Call

Flush indicates an expected call of Flush.

func (*MockProducerMockRecorder) Produce

func (mr *MockProducerMockRecorder) Produce(msg interface{}) *gomock.Call

Produce indicates an expected call of Produce.

type Options

type Options struct {
	Configs map[string]interface{}
}

type Producer

type Producer interface {
	Produce(msg kafkamod.Message) error
	Delivery(chDelivery chan Delivery)
	Flush(timeoutMs int) int
	Close()
}

func New

func New(opts Options) (p Producer, err error)