Documentation
¶
Overview ¶
Package mockes is a generated GoMock package.
Package mockes is a generated GoMock package.
Index ¶
- type MockEventStore
- func (m *MockEventStore) Commit(arg0 context.Context, arg1 es.Aggregate) error
- func (m *MockEventStore) EXPECT() *MockEventStoreMockRecorder
- func (m *MockEventStore) LoadEvents(arg0 context.Context, arg1 es.Aggregate) error
- func (m *MockEventStore) LoadEventsWithSnapshot(arg0 context.Context, arg1 es.Aggregate) error
- func (m *MockEventStore) SaveSnapshot(arg0 context.Context, arg1 es.Aggregate) error
- func (m *MockEventStore) SetAggregateBase(arg0 es.Aggregate, arg1, arg2 string, arg3 int64)
- func (m *MockEventStore) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
- type MockEventStoreMockRecorder
- func (mr *MockEventStoreMockRecorder) Commit(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventStoreMockRecorder) LoadEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventStoreMockRecorder) LoadEventsWithSnapshot(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventStoreMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventStoreMockRecorder) SetAggregateBase(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockEventStoreMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
- 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) 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) 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) 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) 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 MockEventStore ¶
type MockEventStore struct {
// contains filtered or unexported fields
}
MockEventStore is a mock of EventStore interface.
func NewMockEventStore ¶
func NewMockEventStore(ctrl *gomock.Controller) *MockEventStore
NewMockEventStore creates a new mock instance.
func (*MockEventStore) EXPECT ¶
func (m *MockEventStore) EXPECT() *MockEventStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventStore) LoadEvents ¶
LoadEvents mocks base method.
func (*MockEventStore) LoadEventsWithSnapshot ¶
LoadEventsWithSnapshot mocks base method.
func (*MockEventStore) SaveSnapshot ¶
SaveSnapshot mocks base method.
func (*MockEventStore) SetAggregateBase ¶
func (m *MockEventStore) SetAggregateBase(arg0 es.Aggregate, arg1, arg2 string, arg3 int64)
SetAggregateBase mocks base method.
func (*MockEventStore) StreamEvents ¶
func (m *MockEventStore) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
StreamEvents mocks base method.
type MockEventStoreMockRecorder ¶
type MockEventStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockEventStoreMockRecorder is the mock recorder for MockEventStore.
func (*MockEventStoreMockRecorder) Commit ¶
func (mr *MockEventStoreMockRecorder) Commit(arg0, arg1 interface{}) *gomock.Call
Commit indicates an expected call of Commit.
func (*MockEventStoreMockRecorder) LoadEvents ¶
func (mr *MockEventStoreMockRecorder) LoadEvents(arg0, arg1 interface{}) *gomock.Call
LoadEvents indicates an expected call of LoadEvents.
func (*MockEventStoreMockRecorder) LoadEventsWithSnapshot ¶
func (mr *MockEventStoreMockRecorder) LoadEventsWithSnapshot(arg0, arg1 interface{}) *gomock.Call
LoadEventsWithSnapshot indicates an expected call of LoadEventsWithSnapshot.
func (*MockEventStoreMockRecorder) SaveSnapshot ¶
func (mr *MockEventStoreMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
SaveSnapshot indicates an expected call of SaveSnapshot.
func (*MockEventStoreMockRecorder) SetAggregateBase ¶
func (mr *MockEventStoreMockRecorder) SetAggregateBase(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
SetAggregateBase indicates an expected call of SetAggregateBase.
func (*MockEventStoreMockRecorder) StreamEvents ¶
func (mr *MockEventStoreMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
StreamEvents indicates an expected call of StreamEvents.
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 ¶
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) 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 ¶
type MockTxStorage struct {
// contains filtered or unexported fields
}
MockTxStorage is a mock of TxStorage interface.
func NewMockTxStorage ¶
func NewMockTxStorage(ctrl *gomock.Controller) *MockTxStorage
NewMockTxStorage creates a new mock instance.
func (*MockTxStorage) Commit ¶
func (m *MockTxStorage) Commit(arg0 context.Context) error
Commit mocks base method.
func (*MockTxStorage) EXPECT ¶
func (m *MockTxStorage) EXPECT() *MockTxStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTxStorage) ErrorCode ¶
func (m *MockTxStorage) ErrorCode(arg0 error) cgerrors.ErrorCode
ErrorCode mocks base method.
func (*MockTxStorage) GetSnapshot ¶
func (m *MockTxStorage) GetSnapshot(arg0 context.Context, arg1, arg2 string, arg3 int64) (*es.Snapshot, error)
GetSnapshot mocks base method.
func (*MockTxStorage) ListEvents ¶
ListEvents mocks base method.
func (*MockTxStorage) ListEventsAfterRevision ¶
func (m *MockTxStorage) ListEventsAfterRevision(arg0 context.Context, arg1, arg2 string, arg3 int64) ([]*es.Event, error)
ListEventsAfterRevision mocks base method.
func (*MockTxStorage) Rollback ¶
func (m *MockTxStorage) Rollback(arg0 context.Context) error
Rollback mocks base method.
func (*MockTxStorage) SaveEvents ¶
SaveEvents mocks base method.
func (*MockTxStorage) SaveSnapshot ¶
SaveSnapshot mocks base method.
func (*MockTxStorage) StreamEvents ¶
func (m *MockTxStorage) StreamEvents(arg0 context.Context, arg1 *es.StreamEventsRequest) (<-chan *es.Event, error)
StreamEvents mocks base method.
type MockTxStorageMockRecorder ¶
type MockTxStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockTxStorageMockRecorder is the mock recorder for MockTxStorage.
func (*MockTxStorageMockRecorder) As ¶
func (mr *MockTxStorageMockRecorder) As(arg0 interface{}) *gomock.Call
As indicates an expected call of As.
func (*MockTxStorageMockRecorder) Commit ¶
func (mr *MockTxStorageMockRecorder) Commit(arg0 interface{}) *gomock.Call
Commit indicates an expected call of Commit.
func (*MockTxStorageMockRecorder) ErrorCode ¶
func (mr *MockTxStorageMockRecorder) ErrorCode(arg0 interface{}) *gomock.Call
ErrorCode indicates an expected call of ErrorCode.
func (*MockTxStorageMockRecorder) GetSnapshot ¶
func (mr *MockTxStorageMockRecorder) GetSnapshot(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetSnapshot indicates an expected call of GetSnapshot.
func (*MockTxStorageMockRecorder) ListEvents ¶
func (mr *MockTxStorageMockRecorder) ListEvents(arg0, arg1, arg2 interface{}) *gomock.Call
ListEvents indicates an expected call of ListEvents.
func (*MockTxStorageMockRecorder) ListEventsAfterRevision ¶
func (mr *MockTxStorageMockRecorder) ListEventsAfterRevision(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
ListEventsAfterRevision indicates an expected call of ListEventsAfterRevision.
func (*MockTxStorageMockRecorder) Rollback ¶
func (mr *MockTxStorageMockRecorder) Rollback(arg0 interface{}) *gomock.Call
Rollback indicates an expected call of Rollback.
func (*MockTxStorageMockRecorder) SaveEvents ¶
func (mr *MockTxStorageMockRecorder) SaveEvents(arg0, arg1 interface{}) *gomock.Call
SaveEvents indicates an expected call of SaveEvents.
func (*MockTxStorageMockRecorder) SaveSnapshot ¶
func (mr *MockTxStorageMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call
SaveSnapshot indicates an expected call of SaveSnapshot.
func (*MockTxStorageMockRecorder) StreamEvents ¶
func (mr *MockTxStorageMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call
StreamEvents indicates an expected call of StreamEvents.