mock_cqrs

Aug 13, 2020

Changes in this version

type MockCommand

+ func (m *MockCommand) Type() cqrs_es.CommandType

type MockCommandHandler

+ func (m *MockCommandHandler) Handle(arg0 context.Context, arg1 cqrs_es.Command) error

type MockCommandHandlerMockRecorder

+ func (mr *MockCommandHandlerMockRecorder) Handle(arg0, arg1 interface{}) *gomock.Call

type MockCommandMockRecorder

+ func (mr *MockCommandMockRecorder) Type() *gomock.Call

Apr 23, 2020

Changes in this version

type MockAggregateCursor

+ func (m *MockAggregateCursor) Version(arg0 context.Context, arg1 int) (cqrs_es.Aggregate, error)

type MockAggregateCursorMockRecorder

+ func (mr *MockAggregateCursorMockRecorder) Version(arg0, arg1 interface{}) *gomock.Call

type MockAggregateRepository

+ func (m *MockAggregateRepository) RemoveType(ctx context.Context, typ cqrs_es.AggregateType) error

type MockAggregateRepositoryMockRecorder

+ func (mr *MockAggregateRepositoryMockRecorder) RemoveType(ctx, typ interface{}) *gomock.Call

type MockEventStore

+ func (m *MockEventStore) RemoveAggregate(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID) error

+ func (m *MockEventStore) RemoveAggregateType(ctx context.Context, typ cqrs_es.AggregateType) error

type MockEventStoreMockRecorder

+ func (mr *MockEventStoreMockRecorder) RemoveAggregate(ctx, typ, id interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) RemoveAggregateType(ctx, typ interface{}) *gomock.Call

Apr 23, 2020

Changes in this version

+ type MockAggregateCursor struct

+ func NewMockAggregateCursor(ctrl *gomock.Controller) *MockAggregateCursor

+ func (m *MockAggregateCursor) Aggregate() cqrs_es.Aggregate

+ func (m *MockAggregateCursor) Close(arg0 context.Context) error

+ func (m *MockAggregateCursor) EXPECT() *MockAggregateCursorMockRecorder

+ func (m *MockAggregateCursor) Err() error

+ func (m *MockAggregateCursor) Next(arg0 context.Context) bool

+ type MockAggregateCursorMockRecorder struct

+ func (mr *MockAggregateCursorMockRecorder) Aggregate() *gomock.Call

+ func (mr *MockAggregateCursorMockRecorder) Close(arg0 interface{}) *gomock.Call

+ func (mr *MockAggregateCursorMockRecorder) Err() *gomock.Call

+ func (mr *MockAggregateCursorMockRecorder) Next(arg0 interface{}) *gomock.Call

+ type MockAggregateQuery struct

+ func NewMockAggregateQuery(ctrl *gomock.Controller) *MockAggregateQuery

+ func (m *MockAggregateQuery) EXPECT() *MockAggregateQueryMockRecorder

+ func (m *MockAggregateQuery) IDs() []uuid.UUID

+ func (m *MockAggregateQuery) Types() []cqrs_es.AggregateType

+ type MockAggregateQueryMockRecorder struct

+ func (mr *MockAggregateQueryMockRecorder) IDs() *gomock.Call

+ func (mr *MockAggregateQueryMockRecorder) Types() *gomock.Call

type MockAggregateRepository

+ func (m *MockAggregateRepository) Query(ctx context.Context, query cqrs_es.AggregateQuery) (cqrs_es.AggregateCursor, error)

type MockAggregateRepositoryMockRecorder

+ func (mr *MockAggregateRepositoryMockRecorder) Query(ctx, query interface{}) *gomock.Call

+ type MockEventCursor struct

+ func NewMockEventCursor(ctrl *gomock.Controller) *MockEventCursor

+ func (m *MockEventCursor) Close(arg0 context.Context) error

+ func (m *MockEventCursor) EXPECT() *MockEventCursorMockRecorder

+ func (m *MockEventCursor) Err() error

+ func (m *MockEventCursor) Event() cqrs_es.Event

+ func (m *MockEventCursor) Next(arg0 context.Context) bool

+ type MockEventCursorMockRecorder struct

+ func (mr *MockEventCursorMockRecorder) Close(arg0 interface{}) *gomock.Call

+ func (mr *MockEventCursorMockRecorder) Err() *gomock.Call

+ func (mr *MockEventCursorMockRecorder) Event() *gomock.Call

+ func (mr *MockEventCursorMockRecorder) Next(arg0 interface{}) *gomock.Call

+ type MockEventQuery struct

+ func NewMockEventQuery(ctrl *gomock.Controller) *MockEventQuery

+ func (m *MockEventQuery) AggregateIDs() []uuid.UUID

+ func (m *MockEventQuery) AggregateTypes() []cqrs_es.AggregateType

+ func (m *MockEventQuery) EXPECT() *MockEventQueryMockRecorder

+ func (m *MockEventQuery) EventTypes() []cqrs_es.EventType

+ func (m *MockEventQuery) VersionRanges() [][2]int

+ func (m *MockEventQuery) Versions() []int

+ type MockEventQueryMockRecorder struct

+ func (mr *MockEventQueryMockRecorder) AggregateIDs() *gomock.Call

+ func (mr *MockEventQueryMockRecorder) AggregateTypes() *gomock.Call

+ func (mr *MockEventQueryMockRecorder) EventTypes() *gomock.Call

+ func (mr *MockEventQueryMockRecorder) VersionRanges() *gomock.Call

+ func (mr *MockEventQueryMockRecorder) Versions() *gomock.Call

type MockEventStore

+ func (m *MockEventStore) Query(ctx context.Context, query cqrs_es.EventQuery) (cqrs_es.EventCursor, error)

type MockEventStoreMockRecorder

+ func (mr *MockEventStoreMockRecorder) Query(ctx, query interface{}) *gomock.Call

Mar 24, 2020

Changes in this version

type MockAggregateRepository

+ func (m *MockAggregateRepository) FetchLatestWithBase(ctx context.Context, aggregate cqrs_es.Aggregate) (cqrs_es.Aggregate, error)

+ func (m *MockAggregateRepository) FetchWithBase(ctx context.Context, aggregate cqrs_es.Aggregate, version int) (cqrs_es.Aggregate, error)

type MockAggregateRepositoryMockRecorder

+ func (mr *MockAggregateRepositoryMockRecorder) FetchLatestWithBase(ctx, aggregate interface{}) *gomock.Call

+ func (mr *MockAggregateRepositoryMockRecorder) FetchWithBase(ctx, aggregate, version interface{}) *gomock.Call

type MockContainer

+ func (m *MockContainer) EventPublisher() cqrs_es.EventPublisher

+ func (m *MockContainer) EventSubscriber() cqrs_es.EventSubscriber

+ func (m *MockContainer) SetAggregateConfig(arg0 cqrs_es.AggregateConfig)

+ func (m *MockContainer) SetAggregates(arg0 cqrs_es.AggregateRepository)

+ func (m *MockContainer) SetCommandBus(arg0 cqrs_es.CommandBus)

+ func (m *MockContainer) SetCommandConfig(arg0 cqrs_es.CommandConfig)

+ func (m *MockContainer) SetEventBus(arg0 cqrs_es.EventBus)

+ func (m *MockContainer) SetEventConfig(arg0 cqrs_es.EventConfig)

+ func (m *MockContainer) SetEventStore(arg0 cqrs_es.EventStore)

+ func (m *MockContainer) SetSnapshots(arg0 cqrs_es.SnapshotRepository)

type MockContainerMockRecorder

+ func (mr *MockContainerMockRecorder) EventPublisher() *gomock.Call

+ func (mr *MockContainerMockRecorder) EventSubscriber() *gomock.Call

+ func (mr *MockContainerMockRecorder) SetAggregateConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetAggregates(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetCommandBus(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetCommandConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetEventBus(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetEventConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetEventStore(arg0 interface{}) *gomock.Call

+ func (mr *MockContainerMockRecorder) SetSnapshots(arg0 interface{}) *gomock.Call

type MockEventConfig

+ func (m *MockEventConfig) Protos() map[cqrs_es.EventType]cqrs_es.EventData

type MockEventConfigMockRecorder

+ func (mr *MockEventConfigMockRecorder) Protos() *gomock.Call

type MockSnapshotRepository

+ func (m *MockSnapshotRepository) Remove(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID, version int) error

+ func (m *MockSnapshotRepository) RemoveAll(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID) error

type MockSnapshotRepositoryMockRecorder

+ func (mr *MockSnapshotRepositoryMockRecorder) Remove(ctx, typ, id, version interface{}) *gomock.Call

+ func (mr *MockSnapshotRepositoryMockRecorder) RemoveAll(ctx, typ, id interface{}) *gomock.Call

Jan 15, 2020

Changes in this version

type MockAggregateRepository

+ func (m *MockAggregateRepository) Remove(ctx context.Context, aggregate cqrs_es.Aggregate) error

type MockAggregateRepositoryMockRecorder

+ func (mr *MockAggregateRepositoryMockRecorder) Remove(ctx, aggregate interface{}) *gomock.Call

type MockEventStore

+ func (m *MockEventStore) RemoveAll(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) error

type MockEventStoreMockRecorder

+ func (mr *MockEventStoreMockRecorder) RemoveAll(ctx, aggregateType, aggregateID interface{}) *gomock.Call

Jan 6, 2020

Changes in this version

type MockAggregate

+ func (m *MockAggregate) TrackChange(arg0 ...cqrs_es.Event)

type MockAggregateMockRecorder

+ func (mr *MockAggregateMockRecorder) TrackChange(arg0 ...interface{}) *gomock.Call

Jan 6, 2020

Changes in this version

type MockAggregate

+ func (m *MockAggregate) TrackChanges(arg0 ...cqrs_es.Event)

type MockAggregateMockRecorder

+ func (mr *MockAggregateMockRecorder) TrackChanges(arg0 ...interface{}) *gomock.Call

Jan 3, 2020

Changes in this version

type MockAggregate

+ func (m *MockAggregate) FlushChanges()

type MockAggregateMockRecorder

+ func (mr *MockAggregateMockRecorder) FlushChanges() *gomock.Call

Dec 29, 2019

Changes in this version

type MockAggregate

+ func (m *MockAggregate) ApplyEvent(arg0 cqrs_es.Event) error

type MockAggregateMockRecorder

+ func (mr *MockAggregateMockRecorder) ApplyEvent(arg0 interface{}) *gomock.Call

+ type MockEventApplier struct

+ func NewMockEventApplier(ctrl *gomock.Controller) *MockEventApplier

+ func (m *MockEventApplier) Apply(arg0 cqrs_es.Aggregate, arg1 cqrs_es.Event) error

+ func (m *MockEventApplier) EXPECT() *MockEventApplierMockRecorder

+ type MockEventApplierMockRecorder struct

+ func (mr *MockEventApplierMockRecorder) Apply(arg0, arg1 interface{}) *gomock.Call

Dec 29, 2019

Changes in this version

+ type MockContainer struct

+ func NewMockContainer(ctrl *gomock.Controller) *MockContainer

+ func (m *MockContainer) AggregateConfig() cqrs_es.AggregateConfig

+ func (m *MockContainer) Aggregates() cqrs_es.AggregateRepository

+ func (m *MockContainer) CommandBus() cqrs_es.CommandBus

+ func (m *MockContainer) CommandConfig() cqrs_es.CommandConfig

+ func (m *MockContainer) EXPECT() *MockContainerMockRecorder

+ func (m *MockContainer) EventBus() cqrs_es.EventBus

+ func (m *MockContainer) EventConfig() cqrs_es.EventConfig

+ func (m *MockContainer) EventStore() cqrs_es.EventStore

+ func (m *MockContainer) Snapshots() cqrs_es.SnapshotRepository

+ type MockContainerMockRecorder struct

+ func (mr *MockContainerMockRecorder) AggregateConfig() *gomock.Call

+ func (mr *MockContainerMockRecorder) Aggregates() *gomock.Call

+ func (mr *MockContainerMockRecorder) CommandBus() *gomock.Call

+ func (mr *MockContainerMockRecorder) CommandConfig() *gomock.Call

+ func (mr *MockContainerMockRecorder) EventBus() *gomock.Call

+ func (mr *MockContainerMockRecorder) EventConfig() *gomock.Call

+ func (mr *MockContainerMockRecorder) EventStore() *gomock.Call

+ func (mr *MockContainerMockRecorder) Snapshots() *gomock.Call

Dec 22, 2019

Changes in this version

type MockSetup

+ func (m *MockSetup) AddCommandHandlerFactory(arg0 ...cqrs_es.CommandHandlerFactory)

+ func (m *MockSetup) SetSnapshotConfig(arg0 cqrs_es.SnapshotConfig)

type MockSetupMockRecorder

+ func (mr *MockSetupMockRecorder) AddCommandHandlerFactory(arg0 ...interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetSnapshotConfig(arg0 interface{}) *gomock.Call

Dec 15, 2019

Changes in this version

+ type MockAggregate struct

+ func NewMockAggregate(ctrl *gomock.Controller) *MockAggregate

+ func (m *MockAggregate) AggregateID() uuid.UUID

+ func (m *MockAggregate) AggregateType() cqrs_es.AggregateType

+ func (m *MockAggregate) ApplyEvents(arg0 ...cqrs_es.EventData) error

+ func (m *MockAggregate) ApplyHistory(arg0 ...cqrs_es.EventData) error

+ func (m *MockAggregate) Changes() []cqrs_es.EventData

+ func (m *MockAggregate) CurrentVersion() int

+ func (m *MockAggregate) EXPECT() *MockAggregateMockRecorder

+ func (m *MockAggregate) OriginalVersion() int

+ type MockAggregateConfig struct

+ func NewMockAggregateConfig(ctrl *gomock.Controller) *MockAggregateConfig

+ func (m *MockAggregateConfig) EXPECT() *MockAggregateConfigMockRecorder

+ func (m *MockAggregateConfig) Factories() map[cqrs_es.AggregateType]cqrs_es.AggregateFactory

+ func (m *MockAggregateConfig) New(arg0 cqrs_es.AggregateType, arg1 uuid.UUID) (cqrs_es.Aggregate, error)

+ func (m *MockAggregateConfig) Register(arg0 cqrs_es.AggregateType, arg1 cqrs_es.AggregateFactory)

+ type MockAggregateConfigMockRecorder struct

+ func (mr *MockAggregateConfigMockRecorder) Factories() *gomock.Call

+ func (mr *MockAggregateConfigMockRecorder) New(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAggregateConfigMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

+ type MockAggregateMockRecorder struct

+ func (mr *MockAggregateMockRecorder) AggregateID() *gomock.Call

+ func (mr *MockAggregateMockRecorder) AggregateType() *gomock.Call

+ func (mr *MockAggregateMockRecorder) ApplyEvents(arg0 ...interface{}) *gomock.Call

+ func (mr *MockAggregateMockRecorder) ApplyHistory(arg0 ...interface{}) *gomock.Call

+ func (mr *MockAggregateMockRecorder) Changes() *gomock.Call

+ func (mr *MockAggregateMockRecorder) CurrentVersion() *gomock.Call

+ func (mr *MockAggregateMockRecorder) OriginalVersion() *gomock.Call

+ type MockAggregateRepository struct

+ func NewMockAggregateRepository(ctrl *gomock.Controller) *MockAggregateRepository

+ func (m *MockAggregateRepository) EXPECT() *MockAggregateRepositoryMockRecorder

+ func (m *MockAggregateRepository) Fetch(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID, version int) (cqrs_es.Aggregate, error)

+ func (m *MockAggregateRepository) FetchLatest(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID) (cqrs_es.Aggregate, error)

+ func (m *MockAggregateRepository) Save(ctx context.Context, aggregate cqrs_es.Aggregate) error

+ type MockAggregateRepositoryMockRecorder struct

+ func (mr *MockAggregateRepositoryMockRecorder) Fetch(ctx, typ, id, version interface{}) *gomock.Call

+ func (mr *MockAggregateRepositoryMockRecorder) FetchLatest(ctx, typ, id interface{}) *gomock.Call

+ func (mr *MockAggregateRepositoryMockRecorder) Save(ctx, aggregate interface{}) *gomock.Call

+ type MockCommand struct

+ func NewMockCommand(ctrl *gomock.Controller) *MockCommand

+ func (m *MockCommand) AggregateID() uuid.UUID

+ func (m *MockCommand) AggregateType() cqrs_es.AggregateType

+ func (m *MockCommand) CommandType() cqrs_es.CommandType

+ func (m *MockCommand) EXPECT() *MockCommandMockRecorder

+ type MockCommandBus struct

+ func NewMockCommandBus(ctrl *gomock.Controller) *MockCommandBus

+ func (m *MockCommandBus) Dispatch(arg0 context.Context, arg1 cqrs_es.Command) error

+ func (m *MockCommandBus) EXPECT() *MockCommandBusMockRecorder

+ type MockCommandBusMockRecorder struct

+ func (mr *MockCommandBusMockRecorder) Dispatch(arg0, arg1 interface{}) *gomock.Call

+ type MockCommandConfig struct

+ func NewMockCommandConfig(ctrl *gomock.Controller) *MockCommandConfig

+ func (m *MockCommandConfig) EXPECT() *MockCommandConfigMockRecorder

+ func (m *MockCommandConfig) Handler(arg0 cqrs_es.CommandType) (cqrs_es.CommandHandler, error)

+ func (m *MockCommandConfig) Handlers() map[cqrs_es.CommandType]cqrs_es.CommandHandler

+ func (m *MockCommandConfig) Register(arg0 cqrs_es.CommandType, arg1 cqrs_es.CommandHandler)

+ type MockCommandConfigMockRecorder struct

+ func (mr *MockCommandConfigMockRecorder) Handler(arg0 interface{}) *gomock.Call

+ func (mr *MockCommandConfigMockRecorder) Handlers() *gomock.Call

+ func (mr *MockCommandConfigMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

+ type MockCommandHandler struct

+ func NewMockCommandHandler(ctrl *gomock.Controller) *MockCommandHandler

+ func (m *MockCommandHandler) EXPECT() *MockCommandHandlerMockRecorder

+ func (m *MockCommandHandler) HandleCommand(arg0 context.Context, arg1 cqrs_es.Command) error

+ type MockCommandHandlerMockRecorder struct

+ func (mr *MockCommandHandlerMockRecorder) HandleCommand(arg0, arg1 interface{}) *gomock.Call

+ type MockCommandMockRecorder struct

+ func (mr *MockCommandMockRecorder) AggregateID() *gomock.Call

+ func (mr *MockCommandMockRecorder) AggregateType() *gomock.Call

+ func (mr *MockCommandMockRecorder) CommandType() *gomock.Call

+ type MockCore struct

+ func NewMockCore(ctrl *gomock.Controller) *MockCore

+ func (m *MockCore) AggregateConfig() cqrs_es.AggregateConfig

+ func (m *MockCore) Aggregates() cqrs_es.AggregateRepository

+ func (m *MockCore) CommandBus() cqrs_es.CommandBus

+ func (m *MockCore) CommandConfig() cqrs_es.CommandConfig

+ func (m *MockCore) EXPECT() *MockCoreMockRecorder

+ func (m *MockCore) EventBus() cqrs_es.EventBus

+ func (m *MockCore) EventConfig() cqrs_es.EventConfig

+ func (m *MockCore) EventStore() cqrs_es.EventStore

+ func (m *MockCore) Snapshots() cqrs_es.SnapshotRepository

+ type MockCoreMockRecorder struct

+ func (mr *MockCoreMockRecorder) AggregateConfig() *gomock.Call

+ func (mr *MockCoreMockRecorder) Aggregates() *gomock.Call

+ func (mr *MockCoreMockRecorder) CommandBus() *gomock.Call

+ func (mr *MockCoreMockRecorder) CommandConfig() *gomock.Call

+ func (mr *MockCoreMockRecorder) EventBus() *gomock.Call

+ func (mr *MockCoreMockRecorder) EventConfig() *gomock.Call

+ func (mr *MockCoreMockRecorder) EventStore() *gomock.Call

+ func (mr *MockCoreMockRecorder) Snapshots() *gomock.Call

+ type MockEvent struct

+ func NewMockEvent(ctrl *gomock.Controller) *MockEvent

+ func (m *MockEvent) AggregateID() uuid.UUID

+ func (m *MockEvent) AggregateType() cqrs_es.AggregateType

+ func (m *MockEvent) Data() cqrs_es.EventData

+ func (m *MockEvent) EXPECT() *MockEventMockRecorder

+ func (m *MockEvent) Time() time.Time

+ func (m *MockEvent) Type() cqrs_es.EventType

+ func (m *MockEvent) Version() int

+ type MockEventBus struct

+ func NewMockEventBus(ctrl *gomock.Controller) *MockEventBus

+ func (m *MockEventBus) EXPECT() *MockEventBusMockRecorder

+ func (m *MockEventBus) Publish(ctx context.Context, events ...cqrs_es.Event) error

+ func (m *MockEventBus) Subscribe(ctx context.Context, typ cqrs_es.EventType) (<-chan cqrs_es.Event, error)

+ type MockEventBusMockRecorder struct

+ func (mr *MockEventBusMockRecorder) Publish(ctx interface{}, events ...interface{}) *gomock.Call

+ func (mr *MockEventBusMockRecorder) Subscribe(ctx, typ interface{}) *gomock.Call

+ type MockEventConfig struct

+ func NewMockEventConfig(ctrl *gomock.Controller) *MockEventConfig

+ func (m *MockEventConfig) EXPECT() *MockEventConfigMockRecorder

+ func (m *MockEventConfig) Factories() map[cqrs_es.EventType]cqrs_es.EventDataFactory

+ func (m *MockEventConfig) NewData(arg0 cqrs_es.EventType) (cqrs_es.EventData, error)

+ func (m *MockEventConfig) Register(arg0 cqrs_es.EventType, arg1 cqrs_es.EventDataFactory)

+ type MockEventConfigMockRecorder struct

+ func (mr *MockEventConfigMockRecorder) Factories() *gomock.Call

+ func (mr *MockEventConfigMockRecorder) NewData(arg0 interface{}) *gomock.Call

+ func (mr *MockEventConfigMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

+ type MockEventData struct

+ func NewMockEventData(ctrl *gomock.Controller) *MockEventData

+ func (m *MockEventData) EXPECT() *MockEventDataMockRecorder

+ func (m *MockEventData) EventTime() time.Time

+ func (m *MockEventData) EventType() cqrs_es.EventType

+ type MockEventDataMockRecorder struct

+ func (mr *MockEventDataMockRecorder) EventTime() *gomock.Call

+ func (mr *MockEventDataMockRecorder) EventType() *gomock.Call

+ type MockEventMockRecorder struct

+ func (mr *MockEventMockRecorder) AggregateID() *gomock.Call

+ func (mr *MockEventMockRecorder) AggregateType() *gomock.Call

+ func (mr *MockEventMockRecorder) Data() *gomock.Call

+ func (mr *MockEventMockRecorder) Time() *gomock.Call

+ func (mr *MockEventMockRecorder) Type() *gomock.Call

+ func (mr *MockEventMockRecorder) Version() *gomock.Call

+ type MockEventPublisher struct

+ func NewMockEventPublisher(ctrl *gomock.Controller) *MockEventPublisher

+ func (m *MockEventPublisher) EXPECT() *MockEventPublisherMockRecorder

+ func (m *MockEventPublisher) Publish(ctx context.Context, events ...cqrs_es.Event) error

+ type MockEventPublisherMockRecorder struct

+ func (mr *MockEventPublisherMockRecorder) Publish(ctx interface{}, events ...interface{}) *gomock.Call

+ type MockEventStore struct

+ func NewMockEventStore(ctrl *gomock.Controller) *MockEventStore

+ func (m *MockEventStore) EXPECT() *MockEventStoreMockRecorder

+ func (m *MockEventStore) Fetch(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) ([]cqrs_es.Event, error)

+ func (m *MockEventStore) FetchAll(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) ([]cqrs_es.Event, error)

+ func (m *MockEventStore) FetchFrom(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) ([]cqrs_es.Event, error)

+ func (m *MockEventStore) FetchTo(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) ([]cqrs_es.Event, error)

+ func (m *MockEventStore) Find(ctx context.Context, aggregateType cqrs_es.AggregateType, ...) (cqrs_es.Event, error)

+ func (m *MockEventStore) Save(ctx context.Context, originalVersion int, events ...cqrs_es.Event) error

+ type MockEventStoreMockRecorder struct

+ func (mr *MockEventStoreMockRecorder) Fetch(ctx, aggregateType, aggregateID, from, to interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) FetchAll(ctx, aggregateType, aggregateID interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) FetchFrom(ctx, aggregateType, aggregateID, from interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) FetchTo(ctx, aggregateType, aggregateID, to interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) Find(ctx, aggregateType, aggregateID, version interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) Save(ctx, originalVersion interface{}, events ...interface{}) *gomock.Call

+ type MockEventSubscriber struct

+ func NewMockEventSubscriber(ctrl *gomock.Controller) *MockEventSubscriber

+ func (m *MockEventSubscriber) EXPECT() *MockEventSubscriberMockRecorder

+ func (m *MockEventSubscriber) Subscribe(ctx context.Context, typ cqrs_es.EventType) (<-chan cqrs_es.Event, error)

+ type MockEventSubscriberMockRecorder struct

+ func (mr *MockEventSubscriberMockRecorder) Subscribe(ctx, typ interface{}) *gomock.Call

+ type MockSetup struct

+ func NewMockSetup(ctrl *gomock.Controller) *MockSetup

+ func (m *MockSetup) EXPECT() *MockSetupMockRecorder

+ func (m *MockSetup) RegisterAggregate(arg0 cqrs_es.AggregateType, arg1 cqrs_es.AggregateFactory)

+ func (m *MockSetup) RegisterCommand(arg0 cqrs_es.CommandType, arg1 cqrs_es.CommandHandler)

+ func (m *MockSetup) RegisterEvent(arg0 cqrs_es.EventType, arg1 cqrs_es.EventDataFactory)

+ func (m *MockSetup) SetAggregateConfig(arg0 cqrs_es.AggregateConfig)

+ func (m *MockSetup) SetAggregateRepositoryFactory(arg0 cqrs_es.AggregateRepositoryFactory)

+ func (m *MockSetup) SetCommandBusFactory(arg0 cqrs_es.CommandBusFactory)

+ func (m *MockSetup) SetCommandConfig(arg0 cqrs_es.CommandConfig)

+ func (m *MockSetup) SetEventBusFactory(arg0 cqrs_es.EventBusFactory)

+ func (m *MockSetup) SetEventConfig(arg0 cqrs_es.EventConfig)

+ func (m *MockSetup) SetEventStoreFactory(arg0 cqrs_es.EventStoreFactory)

+ func (m *MockSetup) SetLogger(arg0 *log.Logger)

+ func (m *MockSetup) SetSnapshotRepositoryFactory(arg0 cqrs_es.SnapshotRepositoryFactory)

+ type MockSetupMockRecorder struct

+ func (mr *MockSetupMockRecorder) RegisterAggregate(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) RegisterCommand(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) RegisterEvent(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetAggregateConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetAggregateRepositoryFactory(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetCommandBusFactory(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetCommandConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetEventBusFactory(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetEventConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetEventStoreFactory(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetLogger(arg0 interface{}) *gomock.Call

+ func (mr *MockSetupMockRecorder) SetSnapshotRepositoryFactory(arg0 interface{}) *gomock.Call

+ type MockSnapshotConfig struct

+ func NewMockSnapshotConfig(ctrl *gomock.Controller) *MockSnapshotConfig

+ func (m *MockSnapshotConfig) EXPECT() *MockSnapshotConfigMockRecorder

+ func (m *MockSnapshotConfig) IsDue(arg0 cqrs_es.Aggregate) bool

+ type MockSnapshotConfigMockRecorder struct

+ func (mr *MockSnapshotConfigMockRecorder) IsDue(arg0 interface{}) *gomock.Call

+ type MockSnapshotRepository struct

+ func NewMockSnapshotRepository(ctrl *gomock.Controller) *MockSnapshotRepository

+ func (m *MockSnapshotRepository) EXPECT() *MockSnapshotRepositoryMockRecorder

+ func (m *MockSnapshotRepository) Find(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID, version int) (cqrs_es.Aggregate, error)

+ func (m *MockSnapshotRepository) Latest(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID) (cqrs_es.Aggregate, error)

+ func (m *MockSnapshotRepository) MaxVersion(ctx context.Context, typ cqrs_es.AggregateType, id uuid.UUID, maxVersion int) (cqrs_es.Aggregate, error)

+ func (m *MockSnapshotRepository) Save(ctx context.Context, snap cqrs_es.Aggregate) error

+ type MockSnapshotRepositoryMockRecorder struct

+ func (mr *MockSnapshotRepositoryMockRecorder) Find(ctx, typ, id, version interface{}) *gomock.Call

+ func (mr *MockSnapshotRepositoryMockRecorder) Latest(ctx, typ, id interface{}) *gomock.Call

+ func (mr *MockSnapshotRepositoryMockRecorder) MaxVersion(ctx, typ, id, maxVersion interface{}) *gomock.Call

+ func (mr *MockSnapshotRepositoryMockRecorder) Save(ctx, snap interface{}) *gomock.Call