Versions in this module Expand all Collapse all v0 v0.0.1 Apr 16, 2026 Changes in this version + func EventTypeOf(e any) (string, error) + func FromESEvent(pe store.PersistedEvent) (any, error) + func FromESEvents[T any](events []store.PersistedEvent) ([]T, error) + func FromUserDeletedV1(pe store.PersistedEvent) (v1.UserDeleted, error) + func FromUserEmailChangedV1(pe store.PersistedEvent) (v1.UserEmailChanged, error) + func FromUserRegisteredV1(pe store.PersistedEvent) (v1.UserRegistered, error) + func FromUserRegisteredV2(pe store.PersistedEvent) (v2.UserRegistered, error) + func ToESEvents[T any](aggregateType string, aggregateID string, events []T, opts ...Option) ([]store.Event, error) + func ToUserDeletedV1(aggregateType string, aggregateID string, e v1.UserDeleted, opts ...Option) (store.Event, error) + func ToUserEmailChangedV1(aggregateType string, aggregateID string, e v1.UserEmailChanged, ...) (store.Event, error) + func ToUserRegisteredV1(aggregateType string, aggregateID string, e v1.UserRegistered, opts ...Option) (store.Event, error) + func ToUserRegisteredV2(aggregateType string, aggregateID string, e v2.UserRegistered, opts ...Option) (store.Event, error) + type Option func(*eventOptions) + func WithCausationID(id string) Option + func WithCorrelationID(id string) Option + func WithMetadata(metadata []byte) Option + func WithTraceID(id string) Option
Go to main page