Versions in this module Expand all Collapse all v0 v0.15.6 Jun 13, 2022 Changes in this version + const DefaultNamespace + func FromContext(ctx context.Context) string + func NewContext(ctx context.Context, namespace string) context.Context + type Error struct + Err error + Namespace string + func (e *Error) Cause() error + func (e *Error) Error() string + func (e *Error) Unwrap() error + type EventStore struct + func NewEventStore(factory func(ns string) (eh.EventStore, error)) *EventStore + func (s *EventStore) Close() error + func (s *EventStore) Load(ctx context.Context, id uuid.UUID) ([]eh.Event, error) + func (s *EventStore) PreRegisterNamespace(ns string) error + func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersion int) error + type Outbox struct + func NewOutbox(factory func(ns string) (eh.Outbox, error)) *Outbox + func (o *Outbox) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error + func (o *Outbox) Close() error + func (o *Outbox) Errors() <-chan error + func (o *Outbox) HandleEvent(ctx context.Context, event eh.Event) error + func (o *Outbox) HandlerType() eh.EventHandlerType + func (o *Outbox) PreRegisterNamespace(ns string) error + func (o *Outbox) Start() + type Repo struct + func IntoRepo(ctx context.Context, repo eh.ReadRepo) *Repo + func NewRepo(factory func(ns string) (eh.ReadWriteRepo, error)) *Repo + func (r *Repo) Close() error + func (r *Repo) Find(ctx context.Context, id uuid.UUID) (eh.Entity, error) + func (r *Repo) FindAll(ctx context.Context) ([]eh.Entity, error) + func (r *Repo) InnerRepo(ctx context.Context) eh.ReadRepo + func (r *Repo) Remove(ctx context.Context, id uuid.UUID) error + func (r *Repo) Save(ctx context.Context, entity eh.Entity) error
Go to main page