publisher

Documentation

Overview

Package publisher is a generated GoMock package.

Index

• type KafkaPublisher
  • func NewKafkaPublisher(kafkaBroker, kafkaTopic string, msgChan chan consumer.Message) *KafkaPublisher
  • func (publisher *KafkaPublisher) Init() error
  • func (publisher *KafkaPublisher) Start()
  • func (publisher *KafkaPublisher) Stop() error
• type MockPublisher
  • func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
  • func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
  • func (m *MockPublisher) Init() error
  • func (m *MockPublisher) Start()
  • func (m *MockPublisher) Stop() error
• type MockPublisherMockRecorder
  • func (mr *MockPublisherMockRecorder) Init() *gomock.Call
  • func (mr *MockPublisherMockRecorder) Start() *gomock.Call
  • func (mr *MockPublisherMockRecorder) Stop() *gomock.Call
• type Publisher

Types

type KafkaPublisher

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

func NewKafkaPublisher

func NewKafkaPublisher(kafkaBroker, kafkaTopic string, msgChan chan consumer.Message) *KafkaPublisher

func (*KafkaPublisher) Init

func (publisher *KafkaPublisher) Init() error

func (*KafkaPublisher) Start

func (publisher *KafkaPublisher) Start()

func (*KafkaPublisher) Stop

func (publisher *KafkaPublisher) Stop() error

type MockPublisher

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

MockPublisher is a mock of Publisher interface.

func NewMockPublisher

func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

NewMockPublisher creates a new mock instance.

func (*MockPublisher) EXPECT

func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

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

func (*MockPublisher) Init

func (m *MockPublisher) Init() error

Init mocks base method.

func (*MockPublisher) Start

func (m *MockPublisher) Start()

Start mocks base method.

func (*MockPublisher) Stop

func (m *MockPublisher) Stop() error

Stop mocks base method.

type MockPublisherMockRecorder

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

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) Init

func (mr *MockPublisherMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockPublisherMockRecorder) Start

func (mr *MockPublisherMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockPublisherMockRecorder) Stop

func (mr *MockPublisherMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type Publisher

type Publisher interface {
	Init() error
	Start()
	Stop() error
}