Versions in this module Expand all Collapse all v0 v0.2.0 Mar 21, 2018 v0.1.0 Mar 21, 2018 Changes in this version + var ErrCouldNotClearDB = errors.New("could not clear database") + var ErrCouldNotLoadAggregate = errors.New("could not load aggregate") + var ErrCouldNotMarshalEvent = errors.New("could not marshal event") + var ErrCouldNotSaveAggregate = errors.New("could not save aggregate") + var ErrCouldNotUnmarshalEvent = errors.New("could not unmarshal event") + type EventStore struct + func NewEventStore(config *EventStoreConfig) (*EventStore, error) + func (s *EventStore) CreateTable(ctx context.Context) error + func (s *EventStore) DeleteTable(ctx context.Context) error + func (s *EventStore) Load(ctx context.Context, id eh.UUID) ([]eh.Event, error) + func (s *EventStore) RenameEvent(ctx context.Context, from, to eh.EventType) error + func (s *EventStore) Replace(ctx context.Context, event eh.Event) error + func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersion int) error + type EventStoreConfig struct + Endpoint string + Region string + TablePrefix string
Go to main page