mocks

Dec 13, 2024

Changes in this version

+ type MockBrokerCQRS struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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