Documentation
¶
Overview ¶
Package mockstream is a generated GoMock package.
Package mockstream is a generated GoMock package.
Package mockstream is a generated GoMock package.
Package mockstream is a generated GoMock package.
Index ¶
- type MockCommandController
- type MockCommandControllerMockRecorder
- type MockCommandSinker
- type MockCommandSinkerMockRecorder
- type MockEventController
- type MockEventControllerMockRecorder
- type MockEventErrorHandler
- type MockEventErrorHandlerMockRecorder
- type MockEventHandler
- type MockEventHandlerMockRecorder
- type MockEventSinker
- type MockEventSinkerMockRecorder
- type MockPublisher
- type MockPublisherMockRecorder
- type MockState
- type MockStateMockRecorder
- type MockStorage
- func (m *MockStorage) Drop(ctx context.Context, streamID uuid.UUID) error
- func (m *MockStorage) EXPECT() *MockStorageMockRecorder
- func (m *MockStorage) Load(ctx context.Context, streamID uuid.UUID) (*stream.Stream, error)
- func (m *MockStorage) NewStream() *stream.Stream
- func (m *MockStorage) Persist(ctx context.Context, s *stream.Stream) error
- func (m *MockStorage) StreamName() string
- type MockStorageMockRecorder
- func (mr *MockStorageMockRecorder) Drop(ctx, streamID interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) Load(ctx, streamID interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) NewStream() *gomock.Call
- func (mr *MockStorageMockRecorder) Persist(ctx, s interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) StreamName() *gomock.Call
- type MockSubscriber
- type MockSubscriberMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCommandController ¶
type MockCommandController struct {
// contains filtered or unexported fields
}
MockCommandController is a mock of CommandController interface
func NewMockCommandController ¶
func NewMockCommandController(ctrl *gomock.Controller) *MockCommandController
NewMockCommandController creates a new mock instance
func (*MockCommandController) CommandSink ¶
func (m *MockCommandController) CommandSink(arg0 context.Context, arg1 *stream.Stream, arg2 *command.Command) (*command.Reply, error)
CommandSink mocks base method
func (*MockCommandController) EXPECT ¶
func (m *MockCommandController) EXPECT() *MockCommandControllerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockCommandControllerMockRecorder ¶
type MockCommandControllerMockRecorder struct {
// contains filtered or unexported fields
}
MockCommandControllerMockRecorder is the mock recorder for MockCommandController
func (*MockCommandControllerMockRecorder) CommandSink ¶
func (mr *MockCommandControllerMockRecorder) CommandSink(arg0, arg1, arg2 interface{}) *gomock.Call
CommandSink indicates an expected call of CommandSink
type MockCommandSinker ¶
type MockCommandSinker struct {
// contains filtered or unexported fields
}
MockCommandSinker is a mock of CommandSinker interface
func NewMockCommandSinker ¶
func NewMockCommandSinker(ctrl *gomock.Controller) *MockCommandSinker
NewMockCommandSinker creates a new mock instance
func (*MockCommandSinker) CommandSink ¶
func (m *MockCommandSinker) CommandSink(ctx context.Context, cmd *command.Command) (*command.Reply, error)
CommandSink mocks base method
func (*MockCommandSinker) EXPECT ¶
func (m *MockCommandSinker) EXPECT() *MockCommandSinkerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockCommandSinkerMockRecorder ¶
type MockCommandSinkerMockRecorder struct {
// contains filtered or unexported fields
}
MockCommandSinkerMockRecorder is the mock recorder for MockCommandSinker
func (*MockCommandSinkerMockRecorder) CommandSink ¶
func (mr *MockCommandSinkerMockRecorder) CommandSink(ctx, cmd interface{}) *gomock.Call
CommandSink indicates an expected call of CommandSink
type MockEventController ¶
type MockEventController struct {
// contains filtered or unexported fields
}
MockEventController is a mock of EventController interface
func NewMockEventController ¶
func NewMockEventController(ctrl *gomock.Controller) *MockEventController
NewMockEventController creates a new mock instance
func (*MockEventController) EXPECT ¶
func (m *MockEventController) EXPECT() *MockEventControllerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEventController) EventSink ¶
func (m *MockEventController) EventSink(arg0 context.Context, arg1 *stream.Stream, arg2 *event.Event) error
EventSink mocks base method
func (*MockEventController) PickStream ¶
func (m *MockEventController) PickStream(arg0 *event.Event) stream.Picker
PickStream mocks base method
type MockEventControllerMockRecorder ¶
type MockEventControllerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventControllerMockRecorder is the mock recorder for MockEventController
func (*MockEventControllerMockRecorder) EventSink ¶
func (mr *MockEventControllerMockRecorder) EventSink(arg0, arg1, arg2 interface{}) *gomock.Call
EventSink indicates an expected call of EventSink
func (*MockEventControllerMockRecorder) PickStream ¶
func (mr *MockEventControllerMockRecorder) PickStream(arg0 interface{}) *gomock.Call
PickStream indicates an expected call of PickStream
type MockEventErrorHandler ¶
type MockEventErrorHandler struct {
// contains filtered or unexported fields
}
MockEventErrorHandler is a mock of EventErrorHandler interface
func NewMockEventErrorHandler ¶
func NewMockEventErrorHandler(ctrl *gomock.Controller) *MockEventErrorHandler
NewMockEventErrorHandler creates a new mock instance
func (*MockEventErrorHandler) EXPECT ¶
func (m *MockEventErrorHandler) EXPECT() *MockEventErrorHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEventErrorHandler) HandleError ¶
HandleError mocks base method
type MockEventErrorHandlerMockRecorder ¶
type MockEventErrorHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventErrorHandlerMockRecorder is the mock recorder for MockEventErrorHandler
func (*MockEventErrorHandlerMockRecorder) HandleError ¶
func (mr *MockEventErrorHandlerMockRecorder) HandleError(ctx, e, err interface{}) *gomock.Call
HandleError indicates an expected call of HandleError
type MockEventHandler ¶
type MockEventHandler struct {
// contains filtered or unexported fields
}
MockEventHandler is a mock of EventHandler interface
func NewMockEventHandler ¶
func NewMockEventHandler(ctrl *gomock.Controller) *MockEventHandler
NewMockEventHandler creates a new mock instance
func (*MockEventHandler) EXPECT ¶
func (m *MockEventHandler) EXPECT() *MockEventHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEventHandler) Match ¶
func (m *MockEventHandler) Match(eventName string) bool
Match mocks base method
type MockEventHandlerMockRecorder ¶
type MockEventHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventHandlerMockRecorder is the mock recorder for MockEventHandler
func (*MockEventHandlerMockRecorder) Handle ¶
func (mr *MockEventHandlerMockRecorder) Handle(arg0, arg1 interface{}) *gomock.Call
Handle indicates an expected call of Handle
func (*MockEventHandlerMockRecorder) Match ¶
func (mr *MockEventHandlerMockRecorder) Match(eventName interface{}) *gomock.Call
Match indicates an expected call of Match
func (*MockEventHandlerMockRecorder) Rollback ¶
func (mr *MockEventHandlerMockRecorder) Rollback(arg0, arg1 interface{}) *gomock.Call
Rollback indicates an expected call of Rollback
type MockEventSinker ¶
type MockEventSinker struct {
// contains filtered or unexported fields
}
MockEventSinker is a mock of EventSinker interface
func NewMockEventSinker ¶
func NewMockEventSinker(ctrl *gomock.Controller) *MockEventSinker
NewMockEventSinker creates a new mock instance
func (*MockEventSinker) EXPECT ¶
func (m *MockEventSinker) EXPECT() *MockEventSinkerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockEventSinkerMockRecorder ¶
type MockEventSinkerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventSinkerMockRecorder is the mock recorder for MockEventSinker
func (*MockEventSinkerMockRecorder) EventSink ¶
func (mr *MockEventSinkerMockRecorder) EventSink(ctx, e interface{}) *gomock.Call
EventSink indicates an expected call of EventSink
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
func (*MockPublisherMockRecorder) Publish ¶
func (mr *MockPublisherMockRecorder) Publish(event interface{}) *gomock.Call
Publish indicates an expected call of Publish
type MockState ¶
type MockState struct {
// contains filtered or unexported fields
}
MockState is a mock of State interface
func NewMockState ¶
func NewMockState(ctrl *gomock.Controller) *MockState
NewMockState creates a new mock instance
func (*MockState) EXPECT ¶
func (m *MockState) EXPECT() *MockStateMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockState) MarshalBinary ¶
MarshalBinary mocks base method
func (*MockState) UnmarshalBinary ¶
UnmarshalBinary mocks base method
type MockStateMockRecorder ¶
type MockStateMockRecorder struct {
// contains filtered or unexported fields
}
MockStateMockRecorder is the mock recorder for MockState
func (*MockStateMockRecorder) MarshalBinary ¶
func (mr *MockStateMockRecorder) MarshalBinary() *gomock.Call
MarshalBinary indicates an expected call of MarshalBinary
func (*MockStateMockRecorder) Mutate ¶
func (mr *MockStateMockRecorder) Mutate(arg0 interface{}) *gomock.Call
Mutate indicates an expected call of Mutate
func (*MockStateMockRecorder) UnmarshalBinary ¶
func (mr *MockStateMockRecorder) UnmarshalBinary(data interface{}) *gomock.Call
UnmarshalBinary indicates an expected call of UnmarshalBinary
type MockStorage ¶
type MockStorage struct {
// contains filtered or unexported fields
}
MockStorage is a mock of Storage interface
func NewMockStorage ¶
func NewMockStorage(ctrl *gomock.Controller) *MockStorage
NewMockStorage creates a new mock instance
func (*MockStorage) EXPECT ¶
func (m *MockStorage) EXPECT() *MockStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStorage) NewStream ¶
func (m *MockStorage) NewStream() *stream.Stream
NewStream mocks base method
func (*MockStorage) StreamName ¶
func (m *MockStorage) StreamName() string
StreamName mocks base method
type MockStorageMockRecorder ¶
type MockStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageMockRecorder is the mock recorder for MockStorage
func (*MockStorageMockRecorder) Drop ¶
func (mr *MockStorageMockRecorder) Drop(ctx, streamID interface{}) *gomock.Call
Drop indicates an expected call of Drop
func (*MockStorageMockRecorder) Load ¶
func (mr *MockStorageMockRecorder) Load(ctx, streamID interface{}) *gomock.Call
Load indicates an expected call of Load
func (*MockStorageMockRecorder) NewStream ¶
func (mr *MockStorageMockRecorder) NewStream() *gomock.Call
NewStream indicates an expected call of NewStream
func (*MockStorageMockRecorder) Persist ¶
func (mr *MockStorageMockRecorder) Persist(ctx, s interface{}) *gomock.Call
Persist indicates an expected call of Persist
func (*MockStorageMockRecorder) StreamName ¶
func (mr *MockStorageMockRecorder) StreamName() *gomock.Call
StreamName indicates an expected call of StreamName
type MockSubscriber ¶
type MockSubscriber struct {
// contains filtered or unexported fields
}
MockSubscriber is a mock of Subscriber interface
func NewMockSubscriber ¶
func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber
NewMockSubscriber creates a new mock instance
func (*MockSubscriber) EXPECT ¶
func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSubscriber) Subscribe ¶
func (m *MockSubscriber) Subscribe(streamName string, h ...stream.EventHandler)
Subscribe mocks base method
type MockSubscriberMockRecorder ¶
type MockSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberMockRecorder is the mock recorder for MockSubscriber
func (*MockSubscriberMockRecorder) Subscribe ¶
func (mr *MockSubscriberMockRecorder) Subscribe(streamName interface{}, h ...interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe
Source Files