namespace

Jul 12, 2024

Changes in this version

type EventStore

+ func (s *EventStore) LoadSnapshot(ctx context.Context, id uuid.UUID) (*eh.Snapshot, error)

+ func (s *EventStore) Remove(ctx context.Context, id uuid.UUID) error

+ func (s *EventStore) SaveSnapshot(ctx context.Context, id uuid.UUID, snapshot eh.Snapshot) (err error)

May 20, 2024

Changes in this version

type EventStore

+ func (s *EventStore) Clear(ctx context.Context) error

+ func (s *EventStore) RenameEvent(ctx context.Context, from, to eh.EventType) error

+ func (s *EventStore) Replace(ctx context.Context, event eh.Event) error

May 15, 2024

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) LoadFrom(ctx context.Context, id uuid.UUID, version int) ([]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