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) BeginTx(arg0 context.Context) (es.TxStorage, 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) BeginTx(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
- type MockTxStorage
- func (m *MockTxStorage) As(arg0 interface{}) error
- func (m *MockTxStorage) Commit(arg0 context.Context) error
- func (m *MockTxStorage) EXPECT() *MockTxStorageMockRecorder
- func (m *MockTxStorage) ErrorCode(arg0 error) cgerrors.ErrorCode
- func (m *MockTxStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*es.Snapshot, error)
- func (m *MockTxStorage) ListEvents(arg0 context.Context, arg1, arg2 string) ([]*es.Event, error)
- func (m *MockTxStorage) ListEventsAfterRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*es.Event, error)
- func (m *MockTxStorage) NewCursor(arg0 context.Context, arg1 string, arg2 int64) (es.Cursor, error)
- func (m *MockTxStorage) Rollback(arg0 context.Context) error
- func (m *MockTxStorage) SaveEvents(arg0 context.Context, arg1 []*es.Event) error
- func (m *MockTxStorage) SaveSnapshot(arg0 context.Context, arg1 *es.Snapshot) error
- func (m *MockTxStorage) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
- type MockTxStorageMockRecorder
- func (mr *MockTxStorageMockRecorder) As(arg0 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) Commit(arg0 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) ErrorCode(arg0 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) ListEvents(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) ListEventsAfterRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) NewCursor(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) Rollback(arg0 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) SaveEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTxStorageMockRecorder) 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) BeginTx ¶ added in v0.0.18
func (mr *MockStorageMockRecorder) BeginTx(arg0 interface{}) *gomock.Call
BeginTx indicates an expected call of BeginTx.
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.
type MockTxStorage ¶ added in v0.0.18
type MockTxStorage struct {
// contains filtered or unexported fields
}
MockTxStorage is a mock of TxStorage interface.
func NewMockTxStorage ¶ added in v0.0.18
func NewMockTxStorage(ctrl *gomock.Controller) *MockTxStorage
NewMockTxStorage creates a new mock instance.
func (*MockTxStorage) As ¶ added in v0.0.18
func (m *MockTxStorage) As(arg0 interface{}) error
As mocks base method.
func (*MockTxStorage) Commit ¶ added in v0.0.18
func (m *MockTxStorage) Commit(arg0 context.Context) error
Commit mocks base method.
func (*MockTxStorage) EXPECT ¶ added in v0.0.18
func (m *MockTxStorage) EXPECT() *MockTxStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTxStorage) ErrorCode ¶ added in v0.0.18
func (m *MockTxStorage) ErrorCode(arg0 error) cgerrors.ErrorCode
ErrorCode mocks base method.
func (*MockTxStorage) GetSnapshot ¶ added in v0.0.18
func (m *MockTxStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*es.Snapshot, error)
GetSnapshot mocks base method.
func (*MockTxStorage) ListEvents ¶ added in v0.0.18
ListEvents mocks base method.
func (*MockTxStorage) ListEventsAfterRevision ¶ added in v0.0.18
func (m *MockTxStorage) ListEventsAfterRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*es.Event, error)
ListEventsAfterRevision mocks base method.
func (*MockTxStorage) Rollback ¶ added in v0.0.18
func (m *MockTxStorage) Rollback(arg0 context.Context) error
Rollback mocks base method.
func (*MockTxStorage) SaveEvents ¶ added in v0.0.18
SaveEvents mocks base method.
func (*MockTxStorage) SaveSnapshot ¶ added in v0.0.18
SaveSnapshot mocks base method.
func (*MockTxStorage) StreamEvents ¶ added in v0.0.18
func (m *MockTxStorage) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
StreamEvents mocks base method.
type MockTxStorageMockRecorder ¶ added in v0.0.18
type MockTxStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockTxStorageMockRecorder is the mock recorder for MockTxStorage.
func (*MockTxStorageMockRecorder) As ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) As(arg0 interface{}) *gomock.Call
As indicates an expected call of As.
func (*MockTxStorageMockRecorder) Commit ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) Commit(arg0 interface{}) *gomock.Call
Commit indicates an expected call of Commit.
func (*MockTxStorageMockRecorder) ErrorCode ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) ErrorCode(arg0 interface{}) *gomock.Call
ErrorCode indicates an expected call of ErrorCode.
func (*MockTxStorageMockRecorder) GetSnapshot ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetSnapshot indicates an expected call of GetSnapshot.
func (*MockTxStorageMockRecorder) ListEvents ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) ListEvents(arg0, arg1, arg2 interface{}) *gomock.Call
ListEvents indicates an expected call of ListEvents.
func (*MockTxStorageMockRecorder) ListEventsAfterRevision ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) ListEventsAfterRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
ListEventsAfterRevision indicates an expected call of ListEventsAfterRevision.
func (*MockTxStorageMockRecorder) NewCursor ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) NewCursor(arg0, arg1, arg2 interface{}) *gomock.Call
NewCursor indicates an expected call of NewCursor.
func (*MockTxStorageMockRecorder) Rollback ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) Rollback(arg0 interface{}) *gomock.Call
Rollback indicates an expected call of Rollback.
func (*MockTxStorageMockRecorder) SaveEvents ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) SaveEvents(arg0, arg1 interface{}) *gomock.Call
SaveEvents indicates an expected call of SaveEvents.
func (*MockTxStorageMockRecorder) SaveSnapshot ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
SaveSnapshot indicates an expected call of SaveSnapshot.
func (*MockTxStorageMockRecorder) StreamEvents ¶ added in v0.0.18
func (mr *MockTxStorageMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
StreamEvents indicates an expected call of StreamEvents.