Versions in this module Expand all Collapse all v0 v0.1.0 Nov 18, 2021 Changes in this version + type MockEventStore struct + func NewMockEventStore(ctrl *gomock.Controller) *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 struct + 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 struct + func NewMockStorage(ctrl *gomock.Controller) *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 struct + 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 struct + func NewMockTxStorage(ctrl *gomock.Controller) *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 struct + 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
Go to main page