Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoEventData = errors.New("Cannot scan, no event data")
Functions ¶
func NewMemoryEventStore ¶
func NewMemoryEventStore() cqrs.EventStore
func NewSnapshotStore ¶
func NewSnapshotStore() cqrs.SnapshotStore
Types ¶
type EventStore ¶
type EventStore struct {
// contains filtered or unexported fields
}
func (*EventStore) LoadStream ¶
func (s *EventStore) LoadStream(aggregateName string, aggregateId uuid.UUID, version int) (cqrs.EventStream, error)
func (*EventStore) WriteEvent ¶
func (s *EventStore) WriteEvent(aggregateName string, events ...cqrs.Event) error
type EventStream ¶
type EventStream struct {
// contains filtered or unexported fields
}
func (*EventStream) AggregateId ¶
func (s *EventStream) AggregateId() uuid.UUID
func (*EventStream) Error ¶
func (s *EventStream) Error() error
func (*EventStream) EventName ¶
func (s *EventStream) EventName() string
func (*EventStream) Next ¶
func (s *EventStream) Next() bool
func (*EventStream) OccurredAt ¶
func (s *EventStream) OccurredAt() time.Time
func (*EventStream) Scan ¶
func (s *EventStream) Scan(event cqrs.Event) error
func (*EventStream) Version ¶
func (s *EventStream) Version() int
Click to show internal directories.
Click to hide internal directories.