mock_events

Documentation

Overview

Package mock_events is a generated GoMock package.

Index

• type MockAggregatorMiddleware
  • func NewMockAggregatorMiddleware(ctrl *gomock.Controller) *MockAggregatorMiddleware
  • func (m *MockAggregatorMiddleware) AggregateMiddleware(h message.HandlerFunc) message.HandlerFunc
  • func (m *MockAggregatorMiddleware) EXPECT() *MockAggregatorMiddlewareMockRecorder
• type MockAggregatorMiddlewareMockRecorder
  • func (mr *MockAggregatorMiddlewareMockRecorder) AggregateMiddleware(h any) *gomock.Call
• type MockConsumer
  • func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
  • func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
  • func (m *MockConsumer) Register(arg0 events.Registrar)
• type MockConsumerMockRecorder
  • func (mr *MockConsumerMockRecorder) Register(arg0 any) *gomock.Call
• type MockInterface
  • func NewMockInterface(ctrl *gomock.Controller) *MockInterface
  • func (m *MockInterface) Close() error
  • func (m *MockInterface) ConsumeEvents(consumers ...events.Consumer)
  • func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder
  • func (m *MockInterface) Publish(topic string, messages ...*message.Message) error
  • func (m *MockInterface) Register(topic string, handler events.Handler, mdw ...message.HandlerMiddleware)
  • func (m *MockInterface) Run(ctx context.Context) error
  • func (m *MockInterface) Running() chan struct{}
• type MockInterfaceMockRecorder
  • func (mr *MockInterfaceMockRecorder) Close() *gomock.Call
  • func (mr *MockInterfaceMockRecorder) ConsumeEvents(consumers ...any) *gomock.Call
  • func (mr *MockInterfaceMockRecorder) Publish(topic any, messages ...any) *gomock.Call
  • func (mr *MockInterfaceMockRecorder) Register(topic, handler any, mdw ...any) *gomock.Call
  • func (mr *MockInterfaceMockRecorder) Run(ctx any) *gomock.Call
  • func (mr *MockInterfaceMockRecorder) Running() *gomock.Call
• type MockPublisher
  • func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
  • func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
  • func (m *MockPublisher) Publish(topic string, messages ...*message.Message) error
• type MockPublisherMockRecorder
  • func (mr *MockPublisherMockRecorder) Publish(topic any, messages ...any) *gomock.Call
• type MockRegistrar
  • func NewMockRegistrar(ctrl *gomock.Controller) *MockRegistrar
  • func (m *MockRegistrar) EXPECT() *MockRegistrarMockRecorder
  • func (m *MockRegistrar) Register(topic string, handler events.Handler, mdw ...message.HandlerMiddleware)
• type MockRegistrarMockRecorder
  • func (mr *MockRegistrarMockRecorder) Register(topic, handler any, mdw ...any) *gomock.Call
• type MockService
  • func NewMockService(ctrl *gomock.Controller) *MockService
  • func (m *MockService) Close() error
  • func (m *MockService) ConsumeEvents(consumers ...events.Consumer)
  • func (m *MockService) EXPECT() *MockServiceMockRecorder
  • func (m *MockService) Run(ctx context.Context) error
  • func (m *MockService) Running() chan struct{}
• type MockServiceMockRecorder
  • func (mr *MockServiceMockRecorder) Close() *gomock.Call
  • func (mr *MockServiceMockRecorder) ConsumeEvents(consumers ...any) *gomock.Call
  • func (mr *MockServiceMockRecorder) Run(ctx any) *gomock.Call
  • func (mr *MockServiceMockRecorder) Running() *gomock.Call

Types

type MockAggregatorMiddleware

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

MockAggregatorMiddleware is a mock of AggregatorMiddleware interface.

func NewMockAggregatorMiddleware

func NewMockAggregatorMiddleware(ctrl *gomock.Controller) *MockAggregatorMiddleware

NewMockAggregatorMiddleware creates a new mock instance.

func (*MockAggregatorMiddleware) AggregateMiddleware

func (m *MockAggregatorMiddleware) AggregateMiddleware(h message.HandlerFunc) message.HandlerFunc

AggregateMiddleware mocks base method.

func (*MockAggregatorMiddleware) EXPECT

func (m *MockAggregatorMiddleware) EXPECT() *MockAggregatorMiddlewareMockRecorder

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

type MockAggregatorMiddlewareMockRecorder

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

MockAggregatorMiddlewareMockRecorder is the mock recorder for MockAggregatorMiddleware.

func (*MockAggregatorMiddlewareMockRecorder) AggregateMiddleware

func (mr *MockAggregatorMiddlewareMockRecorder) AggregateMiddleware(h any) *gomock.Call

AggregateMiddleware indicates an expected call of AggregateMiddleware.

type MockConsumer

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

MockConsumer is a mock of Consumer interface.

func NewMockConsumer

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance.

func (*MockConsumer) EXPECT

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

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

func (*MockConsumer) Register

func (m *MockConsumer) Register(arg0 events.Registrar)

Register mocks base method.

type MockConsumerMockRecorder

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

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) Register

func (mr *MockConsumerMockRecorder) Register(arg0 any) *gomock.Call

Register indicates an expected call of Register.

type MockInterface

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

MockInterface is a mock of Interface interface.

func NewMockInterface

func NewMockInterface(ctrl *gomock.Controller) *MockInterface

NewMockInterface creates a new mock instance.

func (*MockInterface) Close

func (m *MockInterface) Close() error

Close mocks base method.

func (*MockInterface) ConsumeEvents

func (m *MockInterface) ConsumeEvents(consumers ...events.Consumer)

ConsumeEvents mocks base method.

func (*MockInterface) EXPECT

func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder

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

func (*MockInterface) Publish

func (m *MockInterface) Publish(topic string, messages ...*message.Message) error

Publish mocks base method.

func (*MockInterface) Register

func (m *MockInterface) Register(topic string, handler events.Handler, mdw ...message.HandlerMiddleware)

Register mocks base method.

func (*MockInterface) Run

func (m *MockInterface) Run(ctx context.Context) error

Run mocks base method.

func (*MockInterface) Running

func (m *MockInterface) Running() chan struct{}

Running mocks base method.

type MockInterfaceMockRecorder

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

MockInterfaceMockRecorder is the mock recorder for MockInterface.

func (*MockInterfaceMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockInterfaceMockRecorder) ConsumeEvents

func (mr *MockInterfaceMockRecorder) ConsumeEvents(consumers ...any) *gomock.Call

ConsumeEvents indicates an expected call of ConsumeEvents.

func (*MockInterfaceMockRecorder) Publish

func (mr *MockInterfaceMockRecorder) Publish(topic any, messages ...any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockInterfaceMockRecorder) Register

func (mr *MockInterfaceMockRecorder) Register(topic, handler any, mdw ...any) *gomock.Call

Register indicates an expected call of Register.

func (*MockInterfaceMockRecorder) Run

func (mr *MockInterfaceMockRecorder) Run(ctx any) *gomock.Call

Run indicates an expected call of Run.

func (*MockInterfaceMockRecorder) Running

func (mr *MockInterfaceMockRecorder) Running() *gomock.Call

Running indicates an expected call of Running.

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

func (m *MockPublisher) Publish(topic string, messages ...*message.Message) error

Publish mocks base method.

type MockPublisherMockRecorder

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

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) Publish

func (mr *MockPublisherMockRecorder) Publish(topic any, messages ...any) *gomock.Call

Publish indicates an expected call of Publish.

type MockRegistrar

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

MockRegistrar is a mock of Registrar interface.

func NewMockRegistrar

func NewMockRegistrar(ctrl *gomock.Controller) *MockRegistrar

NewMockRegistrar creates a new mock instance.

func (*MockRegistrar) EXPECT

func (m *MockRegistrar) EXPECT() *MockRegistrarMockRecorder

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

func (*MockRegistrar) Register

func (m *MockRegistrar) Register(topic string, handler events.Handler, mdw ...message.HandlerMiddleware)

Register mocks base method.

type MockRegistrarMockRecorder

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

MockRegistrarMockRecorder is the mock recorder for MockRegistrar.

func (*MockRegistrarMockRecorder) Register

func (mr *MockRegistrarMockRecorder) Register(topic, handler any, mdw ...any) *gomock.Call

Register indicates an expected call of Register.

type MockService

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

MockService is a mock of Service interface.

func NewMockService

func NewMockService(ctrl *gomock.Controller) *MockService

NewMockService creates a new mock instance.

func (*MockService) Close

func (m *MockService) Close() error

Close mocks base method.

func (*MockService) ConsumeEvents

func (m *MockService) ConsumeEvents(consumers ...events.Consumer)

ConsumeEvents mocks base method.

func (*MockService) EXPECT

func (m *MockService) EXPECT() *MockServiceMockRecorder

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

func (*MockService) Run

func (m *MockService) Run(ctx context.Context) error

Run mocks base method.

func (*MockService) Running

func (m *MockService) Running() chan struct{}

Running mocks base method.

type MockServiceMockRecorder

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

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockServiceMockRecorder) ConsumeEvents

func (mr *MockServiceMockRecorder) ConsumeEvents(consumers ...any) *gomock.Call

ConsumeEvents indicates an expected call of ConsumeEvents.

func (*MockServiceMockRecorder) Run

func (mr *MockServiceMockRecorder) Run(ctx any) *gomock.Call

Run indicates an expected call of Run.

func (*MockServiceMockRecorder) Running

func (mr *MockServiceMockRecorder) Running() *gomock.Call

Running indicates an expected call of Running.