Documentation
¶
Overview ¶
Package mockes is a generated GoMock package.
Package mockes is a generated GoMock package.
Index ¶
- type MockCursor
- type MockCursorMockRecorder
- type MockStorage
- func (m *MockStorage) EXPECT() *MockStorageMockRecorder
- func (m *MockStorage) GetEventStream(arg0 context.Context, arg1, arg2 string) ([]*eventsource.Event, error)
- func (m *MockStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*eventsource.Snapshot, error)
- func (m *MockStorage) GetStreamFromRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*eventsource.Event, error)
- func (m *MockStorage) NewCursor(arg0 context.Context, arg1 string, arg2 int64) (eventsource.Cursor, error)
- func (m *MockStorage) SaveEvents(arg0 context.Context, arg1 []*eventsource.Event) error
- func (m *MockStorage) SaveSnapshot(arg0 context.Context, arg1 *eventsource.Snapshot) error
- func (m *MockStorage) StreamEvents(arg0 context.Context, arg1 *eventsource.StreamEventsRequest) (<-chan *eventsource.Event, error)
- type MockStorageMockRecorder
- func (mr *MockStorageMockRecorder) GetEventStream(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) GetStreamFromRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) NewCursor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) SaveEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCursor ¶
type MockCursor struct {
// contains filtered or unexported fields
}
MockCursor is a mock of Cursor interface.
func NewMockCursor ¶
func NewMockCursor(ctrl *gomock.Controller) *MockCursor
NewMockCursor creates a new mock instance.
func (*MockCursor) EXPECT ¶
func (m *MockCursor) EXPECT() *MockCursorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCursor) OpenChannel ¶
func (m *MockCursor) OpenChannel(arg0 bool) (<-chan *eventsource.CursorAggregate, error)
OpenChannel mocks base method.
type MockCursorMockRecorder ¶
type MockCursorMockRecorder struct {
// contains filtered or unexported fields
}
MockCursorMockRecorder is the mock recorder for MockCursor.
func (*MockCursorMockRecorder) OpenChannel ¶
func (mr *MockCursorMockRecorder) OpenChannel(arg0 interface{}) *gomock.Call
OpenChannel indicates an expected call of OpenChannel.
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) GetEventStream ¶
func (m *MockStorage) GetEventStream(arg0 context.Context, arg1, arg2 string) ([]*eventsource.Event, error)
GetEventStream mocks base method.
func (*MockStorage) GetSnapshot ¶
func (m *MockStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*eventsource.Snapshot, error)
GetSnapshot mocks base method.
func (*MockStorage) GetStreamFromRevision ¶
func (m *MockStorage) GetStreamFromRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*eventsource.Event, error)
GetStreamFromRevision mocks base method.
func (*MockStorage) NewCursor ¶
func (m *MockStorage) NewCursor(arg0 context.Context, arg1 string, arg2 int64) (eventsource.Cursor, error)
NewCursor mocks base method.
func (*MockStorage) SaveEvents ¶
func (m *MockStorage) SaveEvents(arg0 context.Context, arg1 []*eventsource.Event) error
SaveEvents mocks base method.
func (*MockStorage) SaveSnapshot ¶
func (m *MockStorage) SaveSnapshot(arg0 context.Context, arg1 *eventsource.Snapshot) error
SaveSnapshot mocks base method.
func (*MockStorage) StreamEvents ¶
func (m *MockStorage) StreamEvents(arg0 context.Context, arg1 *eventsource.StreamEventsRequest) (<-chan *eventsource.Event, error)
StreamEvents mocks base method.
type MockStorageMockRecorder ¶
type MockStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageMockRecorder is the mock recorder for MockStorage.
func (*MockStorageMockRecorder) GetEventStream ¶
func (mr *MockStorageMockRecorder) GetEventStream(arg0, arg1, arg2 interface{}) *gomock.Call
GetEventStream indicates an expected call of GetEventStream.
func (*MockStorageMockRecorder) GetSnapshot ¶
func (mr *MockStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetSnapshot indicates an expected call of GetSnapshot.
func (*MockStorageMockRecorder) GetStreamFromRevision ¶
func (mr *MockStorageMockRecorder) GetStreamFromRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetStreamFromRevision indicates an expected call of GetStreamFromRevision.
func (*MockStorageMockRecorder) NewCursor ¶
func (mr *MockStorageMockRecorder) NewCursor(arg0, arg1, arg2 interface{}) *gomock.Call
NewCursor indicates an expected call of NewCursor.
func (*MockStorageMockRecorder) SaveEvents ¶
func (mr *MockStorageMockRecorder) SaveEvents(arg0, arg1 interface{}) *gomock.Call
SaveEvents indicates an expected call of SaveEvents.
func (*MockStorageMockRecorder) SaveSnapshot ¶
func (mr *MockStorageMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
SaveSnapshot indicates an expected call of SaveSnapshot.
func (*MockStorageMockRecorder) StreamEvents ¶
func (mr *MockStorageMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
StreamEvents indicates an expected call of StreamEvents.
Source Files