Documentation
¶
Overview ¶
Package mock_events is a generated GoMock package.
Index ¶
- type MockAggregatorMiddleware
- type MockAggregatorMiddlewareMockRecorder
- type MockConsumer
- type MockConsumerMockRecorder
- type 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
- type MockPublisherMockRecorder
- type MockRegistrar
- type MockRegistrarMockRecorder
- type MockService
- type MockServiceMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
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) 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.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
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.
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) 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.
Source Files