es

package module

Go to main page

Versions in this module

v0

v0.3.1

Jul 24, 2025

v0.3.0

Jul 17, 2025

v0.2.2

May 4, 2025

Changes in this version

type Aggregate

+ TrackChanges func(aggregate AggregateRoot[K], events ...EventPayload) error

v0.2.1

May 4, 2025

Changes in this version

type EventStore

+ func (s *EventStore[K]) WithRepository(repository EventRepository[K]) *EventStore[K]

type SnapshotStore

+ func (s *SnapshotStore[K]) WithEventStore(eventStore *EventStore[K]) *SnapshotStore[K]

+ func (s *SnapshotStore[K]) WithRepository(repository SnapshotRepository[K]) *SnapshotStore[K]

v0.2.0

May 4, 2025

Changes in this version

+ func RegisterEvent[K comparable, T EventPayload](eventStore *EventStore[K], event T)

+ func RegisterSnapshot[K comparable, T SnapshotPayload](snapshotStore *SnapshotStore[K], snapshot T)

+ type ErrUnregisteredEvent string

+ func (e ErrUnregisteredEvent) Error() string

+ type ErrUnregisteredSnapshot string

+ func (e ErrUnregisteredSnapshot) Error() string

+ type EventPayload interface

+ Kind func() string

+ type EventStore struct

+ func (s *EventStore[K]) Load(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

+ func (s *EventStore[K]) Save(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

+ type SnapshotPayload interface

+ Kind func() string

+ type SnapshotStore struct

+ func (s *SnapshotStore[K]) Load(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

+ func (s *SnapshotStore[K]) Save(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

v0.1.0

Apr 17, 2025

Changes in this version

+ type Aggregate interface

+ AggregateID func() K

+ AggregateVersion func() int

+ Changes func() []any

+ SetID func(K)

+ SetVersion func(int)

+ TrackChange func(aggregate AggregateRoot[K], event any) error

+ func NewAggregate[K comparable](id AggregateID[K]) Aggregate[K]

+ type AggregateID interface

+ Get func() K

+ IsSet func() bool

+ New func() K

+ Set func(K)

+ type AggregateRoot interface

+ AggregateType func() string

+ ApplyChange func(event any) error

+ type AggregateStore interface

+ Load func(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

+ Save func(ctx context.Context, aggregate AggregateRoot[K], hooks ...Hook[K]) error

+ func NewEventStore[K comparable](registry envelope.Registry, repository EventRepository[K]) AggregateStore[K]

+ func NewSnapshotStore[K comparable](registry envelope.Registry, eventStore AggregateStore[K], ...) AggregateStore[K]

+ type ErrAggregateVersionConflict struct

+ AggregateID any

+ AggregateType string

+ AggregateVersion int

+ func (e ErrAggregateVersionConflict) Error() string

+ type ErrUnknownAggregateChangeType struct

+ AggregateType string

+ Change any

+ func (e ErrUnknownAggregateChangeType) Error() string

+ type ErrUnknownAggregateSnapshotType struct

+ AggregateType string

+ Snapshot any

+ func (e ErrUnknownAggregateSnapshotType) Error() string

+ type Event struct

+ AggregateID K

+ AggregateType string

+ AggregateVersion int

+ EventData []byte

+ EventType string

+ OccurredAt time.Time

+ type EventLoadHooks interface

+ EventsPostLoad func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ EventsPreLoad func(ctx context.Context, aggregate AggregateRoot[K]) error

+ type EventRepository interface

+ Load func(ctx context.Context, aggregate AggregateRoot[K], hooks EventLoadHooks[K]) ([]Event[K], error)

+ Save func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K], ...) error

+ type EventSaveHooks interface

+ EventsPostSave func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ EventsPreSave func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ type EventsPostLoad func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ type EventsPostSave func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ type EventsPreLoad func(ctx context.Context, aggregate AggregateRoot[K]) error

+ type EventsPreSave func(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ type Hook interface

+ func EventsPostLoadHook[K comparable](fn EventsPostLoad[K]) Hook[K]

+ func EventsPostSaveHook[K comparable](fn EventsPostSave[K]) Hook[K]

+ func EventsPreLoadHook[K comparable](fn EventsPreLoad[K]) Hook[K]

+ func EventsPreSaveHook[K comparable](fn EventsPreSave[K]) Hook[K]

+ func SnapshotPostLoadHook[K comparable](fn SnapshotPostLoad[K]) Hook[K]

+ func SnapshotPostSaveHook[K comparable](fn SnapshotPostSave[K]) Hook[K]

+ func SnapshotPreLoadHook[K comparable](fn SnapshotPreLoad[K]) Hook[K]

+ func SnapshotPreSaveHook[K comparable](fn SnapshotPreSave[K]) Hook[K]

+ type Hooks []Hook[K]

+ func (h Hooks[K]) EventsPostLoad(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ func (h Hooks[K]) EventsPostSave(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ func (h Hooks[K]) EventsPreLoad(ctx context.Context, aggregate AggregateRoot[K]) error

+ func (h Hooks[K]) EventsPreSave(ctx context.Context, aggregate AggregateRoot[K], events []Event[K]) error

+ func (h Hooks[K]) SnapshotPostLoad(ctx context.Context, aggregate AggregateRoot[K], snapshot *Snapshot[K]) error

+ func (h Hooks[K]) SnapshotPostSave(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ func (h Hooks[K]) SnapshotPreLoad(ctx context.Context, aggregate AggregateRoot[K]) error

+ func (h Hooks[K]) SnapshotPreSave(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ type Snapshot struct

+ AggregateID K

+ AggregateType string

+ AggregateVersion int

+ CreatedAt time.Time

+ SnapshotData []byte

+ SnapshotType string

+ type SnapshotAggregate interface

+ ApplySnapshot func(snapshot any) error

+ CreateSnapshot func() any

+ type SnapshotLoadHooks interface

+ SnapshotPostLoad func(ctx context.Context, aggregate AggregateRoot[K], snapshot *Snapshot[K]) error

+ SnapshotPreLoad func(ctx context.Context, aggregate AggregateRoot[K]) error

+ type SnapshotPostLoad func(ctx context.Context, aggregate AggregateRoot[K], snapshot *Snapshot[K]) error

+ type SnapshotPostSave func(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ type SnapshotPreLoad func(ctx context.Context, aggregate AggregateRoot[K]) error

+ type SnapshotPreSave func(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ type SnapshotRepository interface

+ Load func(ctx context.Context, aggregate AggregateRoot[K], hooks SnapshotLoadHooks[K]) (*Snapshot[K], error)

+ Save func(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K], ...) error

+ type SnapshotSaveHooks interface

+ SnapshotPostSave func(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ SnapshotPreSave func(ctx context.Context, aggregate AggregateRoot[K], snapshot Snapshot[K]) error

+ type SnapshotStrategy interface

+ ShouldSnapshot func(aggregate AggregateRoot[K]) bool

+ func NewFrequencySnapshotStrategy[K comparable](frequency int) SnapshotStrategy[K]

+ func NewParticularChangesSnapshotStrategy[K comparable](changes []any) SnapshotStrategy[K]

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL