Versions in this module Expand all Collapse all v0 v0.2.2 Jul 24, 2020 Changes in this version type MockEntity + ID string v0.2.1 Apr 23, 2020 Changes in this version type MockProvider + func (p *MockProvider) Close() v0.2.0 Apr 12, 2020 Changes in this version + type EntityCreatedEvent struct + AggregatorId string + CreateTime string + Message string + Payload string + Version int32 + func (e *EntityCreatedEvent) GetAggregatorId() string + func (e *EntityCreatedEvent) GetCreateTime() time.Time + func (e *EntityCreatedEvent) GetPayload() string + func (e *EntityCreatedEvent) GetType() string + func (e *EntityCreatedEvent) GetVersion() int32 + func (e *EntityCreatedEvent) InitBy(event cerk.Event) + func (e *EntityCreatedEvent) LoadPayload() error + func (e *EntityCreatedEvent) SavePayload() error + type MockEntity struct + Id string + Message string + func (e *MockEntity) GetId() string + type MockProvider struct + Events []cerk.Event + func (p *MockProvider) FetchAllEvents(batch int) (<-chan []cerk.Event, error) + func (p *MockProvider) SendEvents(events []cerk.Event) error + func (p *MockProvider) SetInitEvents(events []cerk.Event) + type MockRepository struct + func (r *MockRepository) CreateFakeEvent() + func (r *MockRepository) Replay(events []cerk.Event) error
Go to main page