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) As(arg0 interface{}) error
- func (m *MockStorage) EXPECT() *MockStorageMockRecorder
- func (m *MockStorage) ErrorCode(arg0 error) cgerrors.ErrorCode
- func (m *MockStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*es.Snapshot, error)
- func (m *MockStorage) ListEvents(arg0 context.Context, arg1, arg2 string) ([]*es.Event, error)
- func (m *MockStorage) ListEventsAfterRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*es.Event, error)
- func (m *MockStorage) NewCursor(arg0 context.Context, arg1 string, arg2 int64) (es.Cursor, error)
- func (m *MockStorage) SaveEvents(arg0 context.Context, arg1 []*es.Event) error
- func (m *MockStorage) SaveSnapshot(arg0 context.Context, arg1 *es.Snapshot) error
- func (m *MockStorage) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
- type MockStorageMockRecorder
- func (mr *MockStorageMockRecorder) As(arg0 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) ErrorCode(arg0 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) ListEvents(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageMockRecorder) ListEventsAfterRevision(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) GetAggregateStream ¶
func (m *MockCursor) GetAggregateStream(arg0 bool) (<-chan *es.CursorAggregate, error)
GetAggregateStream mocks base method.
type MockCursorMockRecorder ¶
type MockCursorMockRecorder struct {
// contains filtered or unexported fields
}
MockCursorMockRecorder is the mock recorder for MockCursor.
func (*MockCursorMockRecorder) GetAggregateStream ¶
func (mr *MockCursorMockRecorder) GetAggregateStream(arg0 interface{}) *gomock.Call
GetAggregateStream indicates an expected call of GetAggregateStream.
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) ErrorCode ¶
func (m *MockStorage) ErrorCode(arg0 error) cgerrors.ErrorCode
ErrorCode mocks base method.
func (*MockStorage) GetSnapshot ¶
func (m *MockStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*es.Snapshot, error)
GetSnapshot mocks base method.
func (*MockStorage) ListEvents ¶
ListEvents mocks base method.
func (*MockStorage) ListEventsAfterRevision ¶
func (m *MockStorage) ListEventsAfterRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*es.Event, error)
ListEventsAfterRevision mocks base method.
func (*MockStorage) SaveEvents ¶
SaveEvents mocks base method.
func (*MockStorage) SaveSnapshot ¶
SaveSnapshot mocks base method.
func (*MockStorage) StreamEvents ¶
func (m *MockStorage) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.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) As ¶
func (mr *MockStorageMockRecorder) As(arg0 interface{}) *gomock.Call
As indicates an expected call of As.
func (*MockStorageMockRecorder) ErrorCode ¶
func (mr *MockStorageMockRecorder) ErrorCode(arg0 interface{}) *gomock.Call
ErrorCode indicates an expected call of ErrorCode.
func (*MockStorageMockRecorder) GetSnapshot ¶
func (mr *MockStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetSnapshot indicates an expected call of GetSnapshot.
func (*MockStorageMockRecorder) ListEvents ¶
func (mr *MockStorageMockRecorder) ListEvents(arg0, arg1, arg2 interface{}) *gomock.Call
ListEvents indicates an expected call of ListEvents.
func (*MockStorageMockRecorder) ListEventsAfterRevision ¶
func (mr *MockStorageMockRecorder) ListEventsAfterRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
ListEventsAfterRevision indicates an expected call of ListEventsAfterRevision.
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