mocks

Documentation

Overview

Package mocks is a generated GoMock package.

Index

• type MockBrokerCQRS
  • func NewMockBrokerCQRS(ctrl *gomock.Controller) *MockBrokerCQRS
  • func (m *MockBrokerCQRS) AddCommandHandlers(ctx context.Context, handlers ...cqrs.CommandHandler) error
  • func (m *MockBrokerCQRS) AddEventHandlers(ctx context.Context, handlers ...cqrs.EventHandler) error
  • func (m *MockBrokerCQRS) EXPECT() *MockBrokerCQRSMockRecorder
  • func (m *MockBrokerCQRS) Running(ctx context.Context) chan struct{}
  • func (m *MockBrokerCQRS) SendCommand(ctx context.Context, command any) error
  • func (m *MockBrokerCQRS) SendEvent(ctx context.Context, event any) error
  • func (m *MockBrokerCQRS) Start(ctx context.Context) error
  • func (m *MockBrokerCQRS) Stop(ctx context.Context) error
• type MockBrokerCQRSMockRecorder
  • func (mr *MockBrokerCQRSMockRecorder) AddCommandHandlers(ctx any, handlers ...any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) AddEventHandlers(ctx any, handlers ...any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) Running(ctx any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) SendCommand(ctx, command any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) SendEvent(ctx, event any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) Start(ctx any) *gomock.Call
  • func (mr *MockBrokerCQRSMockRecorder) Stop(ctx any) *gomock.Call
• type MockPubSub
  • func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub
  • func (m *MockPubSub) Close() error
  • func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder
  • func (m *MockPubSub) Publish(topic string, messages ...*message.Message) error
  • func (m *MockPubSub) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
• type MockPubSubMockRecorder
  • func (mr *MockPubSubMockRecorder) Close() *gomock.Call
  • func (mr *MockPubSubMockRecorder) Publish(topic any, messages ...any) *gomock.Call
  • func (mr *MockPubSubMockRecorder) Subscribe(ctx, topic any) *gomock.Call

Types

type MockBrokerCQRS

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

MockBrokerCQRS is a mock of BrokerCQRS interface.

func NewMockBrokerCQRS

func NewMockBrokerCQRS(ctrl *gomock.Controller) *MockBrokerCQRS

NewMockBrokerCQRS creates a new mock instance.

func (*MockBrokerCQRS) AddCommandHandlers

func (m *MockBrokerCQRS) AddCommandHandlers(ctx context.Context, handlers ...cqrs.CommandHandler) error

AddCommandHandlers mocks base method.

func (*MockBrokerCQRS) AddEventHandlers

func (m *MockBrokerCQRS) AddEventHandlers(ctx context.Context, handlers ...cqrs.EventHandler) error

AddEventHandlers mocks base method.

func (*MockBrokerCQRS) EXPECT

func (m *MockBrokerCQRS) EXPECT() *MockBrokerCQRSMockRecorder

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

func (*MockBrokerCQRS) Running

func (m *MockBrokerCQRS) Running(ctx context.Context) chan struct{}

Running mocks base method.

func (*MockBrokerCQRS) SendCommand

func (m *MockBrokerCQRS) SendCommand(ctx context.Context, command any) error

SendCommand mocks base method.

func (*MockBrokerCQRS) SendEvent

func (m *MockBrokerCQRS) SendEvent(ctx context.Context, event any) error

SendEvent mocks base method.

func (*MockBrokerCQRS) Start

func (m *MockBrokerCQRS) Start(ctx context.Context) error

Start mocks base method.

func (*MockBrokerCQRS) Stop

func (m *MockBrokerCQRS) Stop(ctx context.Context) error

Stop mocks base method.

type MockBrokerCQRSMockRecorder

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

MockBrokerCQRSMockRecorder is the mock recorder for MockBrokerCQRS.

func (*MockBrokerCQRSMockRecorder) AddCommandHandlers

func (mr *MockBrokerCQRSMockRecorder) AddCommandHandlers(ctx any, handlers ...any) *gomock.Call

AddCommandHandlers indicates an expected call of AddCommandHandlers.

func (*MockBrokerCQRSMockRecorder) AddEventHandlers

func (mr *MockBrokerCQRSMockRecorder) AddEventHandlers(ctx any, handlers ...any) *gomock.Call

AddEventHandlers indicates an expected call of AddEventHandlers.

func (*MockBrokerCQRSMockRecorder) Running

func (mr *MockBrokerCQRSMockRecorder) Running(ctx any) *gomock.Call

Running indicates an expected call of Running.

func (*MockBrokerCQRSMockRecorder) SendCommand

func (mr *MockBrokerCQRSMockRecorder) SendCommand(ctx, command any) *gomock.Call

SendCommand indicates an expected call of SendCommand.

func (*MockBrokerCQRSMockRecorder) SendEvent

func (mr *MockBrokerCQRSMockRecorder) SendEvent(ctx, event any) *gomock.Call

SendEvent indicates an expected call of SendEvent.

func (*MockBrokerCQRSMockRecorder) Start

func (mr *MockBrokerCQRSMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockBrokerCQRSMockRecorder) Stop

func (mr *MockBrokerCQRSMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

type MockPubSub

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

MockPubSub is a mock of PubSub interface.

func NewMockPubSub

func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub

NewMockPubSub creates a new mock instance.

func (*MockPubSub) Close

func (m *MockPubSub) Close() error

Close mocks base method.

func (*MockPubSub) EXPECT

func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder

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

func (*MockPubSub) Publish

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

Publish mocks base method.

func (*MockPubSub) Subscribe

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

Subscribe mocks base method.

type MockPubSubMockRecorder

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

MockPubSubMockRecorder is the mock recorder for MockPubSub.

func (*MockPubSubMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockPubSubMockRecorder) Publish

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

Publish indicates an expected call of Publish.

func (*MockPubSubMockRecorder) Subscribe

func (mr *MockPubSubMockRecorder) Subscribe(ctx, topic any) *gomock.Call

Subscribe indicates an expected call of Subscribe.