mock_eaa

Documentation

Overview

Package mock_eaa is a generated GoMock package.

Package mock_eaa is a generated GoMock package.

Index

• type MockKafkaInterface
  • func NewMockKafkaInterface(ctrl *gomock.Controller) *MockKafkaInterface
  • func (m *MockKafkaInterface) DefaultSaramaSubscriberConfig() *sarama.Config
  • func (m *MockKafkaInterface) DefaultSaramaSyncPublisherConfig() *sarama.Config
  • func (m *MockKafkaInterface) EXPECT() *MockKafkaInterfaceMockRecorder
  • func (m *MockKafkaInterface) NewPublisher(config kafka.PublisherConfig, logger watermill.LoggerAdapter) (*kafka.Publisher, error)
  • func (m *MockKafkaInterface) NewSubscriber(config kafka.SubscriberConfig, logger watermill.LoggerAdapter) (*kafka.Subscriber, error)
  • func (m *MockKafkaInterface) NewWithPartitioningMarshaler(generatePartitionKey kafka.GeneratePartitionKey) kafka.MarshalerUnmarshaler
• type MockKafkaInterfaceMockRecorder
  • func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig() *gomock.Call
  • func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig() *gomock.Call
  • func (mr *MockKafkaInterfaceMockRecorder) NewPublisher(config, logger interface{}) *gomock.Call
  • func (mr *MockKafkaInterfaceMockRecorder) NewSubscriber(config, logger interface{}) *gomock.Call
  • func (mr *MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler(generatePartitionKey interface{}) *gomock.Call
• type MockKafkaPublisher
  • func NewMockKafkaPublisher(ctrl *gomock.Controller) *MockKafkaPublisher
  • func (m *MockKafkaPublisher) Close() error
  • func (m *MockKafkaPublisher) EXPECT() *MockKafkaPublisherMockRecorder
  • func (m *MockKafkaPublisher) Publish(topic string, msgs ...*message.Message) error
• type MockKafkaPublisherMockRecorder
  • func (mr *MockKafkaPublisherMockRecorder) Close() *gomock.Call
  • func (mr *MockKafkaPublisherMockRecorder) Publish(topic interface{}, msgs ...interface{}) *gomock.Call
• type MockKafkaSubscriber
  • func NewMockKafkaSubscriber(ctrl *gomock.Controller) *MockKafkaSubscriber
  • func (m *MockKafkaSubscriber) Close() error
  • func (m *MockKafkaSubscriber) EXPECT() *MockKafkaSubscriberMockRecorder
  • func (m *MockKafkaSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
• type MockKafkaSubscriberMockRecorder
  • func (mr *MockKafkaSubscriberMockRecorder) Close() *gomock.Call
  • func (mr *MockKafkaSubscriberMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call

Types

type MockKafkaInterface

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

MockKafkaInterface is a mock of KafkaInterface interface

func NewMockKafkaInterface

func NewMockKafkaInterface(ctrl *gomock.Controller) *MockKafkaInterface

NewMockKafkaInterface creates a new mock instance

func (*MockKafkaInterface) DefaultSaramaSubscriberConfig

func (m *MockKafkaInterface) DefaultSaramaSubscriberConfig() *sarama.Config

DefaultSaramaSubscriberConfig mocks base method

func (*MockKafkaInterface) DefaultSaramaSyncPublisherConfig

func (m *MockKafkaInterface) DefaultSaramaSyncPublisherConfig() *sarama.Config

DefaultSaramaSyncPublisherConfig mocks base method

func (*MockKafkaInterface) EXPECT

func (m *MockKafkaInterface) EXPECT() *MockKafkaInterfaceMockRecorder

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

func (*MockKafkaInterface) NewPublisher

func (m *MockKafkaInterface) NewPublisher(config kafka.PublisherConfig, logger watermill.LoggerAdapter) (*kafka.Publisher, error)

NewPublisher mocks base method

func (*MockKafkaInterface) NewSubscriber

func (m *MockKafkaInterface) NewSubscriber(config kafka.SubscriberConfig, logger watermill.LoggerAdapter) (*kafka.Subscriber, error)

NewSubscriber mocks base method

func (*MockKafkaInterface) NewWithPartitioningMarshaler

func (m *MockKafkaInterface) NewWithPartitioningMarshaler(generatePartitionKey kafka.GeneratePartitionKey) kafka.MarshalerUnmarshaler

NewWithPartitioningMarshaler mocks base method

type MockKafkaInterfaceMockRecorder

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

MockKafkaInterfaceMockRecorder is the mock recorder for MockKafkaInterface

func (*MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig

func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig() *gomock.Call

DefaultSaramaSubscriberConfig indicates an expected call of DefaultSaramaSubscriberConfig

func (*MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig

func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig() *gomock.Call

DefaultSaramaSyncPublisherConfig indicates an expected call of DefaultSaramaSyncPublisherConfig

func (*MockKafkaInterfaceMockRecorder) NewPublisher

func (mr *MockKafkaInterfaceMockRecorder) NewPublisher(config, logger interface{}) *gomock.Call

NewPublisher indicates an expected call of NewPublisher

func (*MockKafkaInterfaceMockRecorder) NewSubscriber

func (mr *MockKafkaInterfaceMockRecorder) NewSubscriber(config, logger interface{}) *gomock.Call

NewSubscriber indicates an expected call of NewSubscriber

func (*MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler

func (mr *MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler(generatePartitionKey interface{}) *gomock.Call

NewWithPartitioningMarshaler indicates an expected call of NewWithPartitioningMarshaler

type MockKafkaPublisher

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

MockKafkaPublisher is a mock of KafkaPublisher interface

func NewMockKafkaPublisher

func NewMockKafkaPublisher(ctrl *gomock.Controller) *MockKafkaPublisher

NewMockKafkaPublisher creates a new mock instance

func (*MockKafkaPublisher) Close

func (m *MockKafkaPublisher) Close() error

Close mocks base method

func (*MockKafkaPublisher) EXPECT

func (m *MockKafkaPublisher) EXPECT() *MockKafkaPublisherMockRecorder

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

func (*MockKafkaPublisher) Publish

func (m *MockKafkaPublisher) Publish(topic string, msgs ...*message.Message) error

Publish mocks base method

type MockKafkaPublisherMockRecorder

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

MockKafkaPublisherMockRecorder is the mock recorder for MockKafkaPublisher

func (*MockKafkaPublisherMockRecorder) Close

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

Close indicates an expected call of Close

func (*MockKafkaPublisherMockRecorder) Publish

func (mr *MockKafkaPublisherMockRecorder) Publish(topic interface{}, msgs ...interface{}) *gomock.Call

Publish indicates an expected call of Publish

type MockKafkaSubscriber

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

MockKafkaSubscriber is a mock of KafkaSubscriber interface

func NewMockKafkaSubscriber

func NewMockKafkaSubscriber(ctrl *gomock.Controller) *MockKafkaSubscriber

NewMockKafkaSubscriber creates a new mock instance

func (*MockKafkaSubscriber) Close

func (m *MockKafkaSubscriber) Close() error

Close mocks base method

func (*MockKafkaSubscriber) EXPECT

func (m *MockKafkaSubscriber) EXPECT() *MockKafkaSubscriberMockRecorder

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

func (*MockKafkaSubscriber) Subscribe

func (m *MockKafkaSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

Subscribe mocks base method

type MockKafkaSubscriberMockRecorder

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

MockKafkaSubscriberMockRecorder is the mock recorder for MockKafkaSubscriber

func (*MockKafkaSubscriberMockRecorder) Close

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

Close indicates an expected call of Close

func (*MockKafkaSubscriberMockRecorder) Subscribe

func (mr *MockKafkaSubscriberMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe