eventsourcing

Sep 19, 2023

Changes in this version

+ type Registry struct

+ func NewRegistry() *Registry

+ func (a *Registry) ApplyChange(event Eventer) error

+ func (a *Registry) PopEvents() []Eventer

+ func (a *Registry) RegisterEvent(kind Kind, handler func(e Eventer))

Sep 18, 2023

Changes in this version

+ var ErrHandlerNotFound = errors.New("handler not found")

+ var ErrWrongHandlerInput = errors.New("handler input must be one of type eventsourcing.Eventer")

+ var ErrWrongHandlerOutput = errors.New("handler should not return anything")

+ func HandlerCall(a Aggregater[K], event Eventer) error

+ type DecoderMeta struct

+ AggregateID K

+ Kind Kind

+ type EventRegister interface

+ RegisterEvent func(kind Kind, handler func(e Eventer))

+ type Handler func(E)

type RootAggregate

+ func (a *RootAggregate[K]) HandleEvent(event Eventer) error

+ func (a *RootAggregate[K]) RegisterEvent(kind Kind, handler func(e Eventer))

Sep 16, 2023

Changes in this version

+ type Metadata map[string]string

type Snapshot

+ Metadata Metadata

Sep 6, 2023

Changes in this version

+ type ID interface

+ type IDPt interface

Sep 4, 2023

Changes in this version

type EventRecordDetail

+ ID eventid.EventID

type PersistOptions

+ Metadata map[string]interface{}

Jul 28, 2023

Changes in this version

+ type PersistOption func(*PersistOptions)

+ type PersistOptions struct

+ IdempotencyKey string

+ Labels map[string]interface{}

Jul 25, 2023

Changes in this version

type Event

+ Partition uint32

Jun 26, 2023

Changes in this version

type Event

+ Sequence uint64

Jun 24, 2023

Changes in this version

type EsOptions

+ SnapshotThreshold uint32

Dec 19, 2022

Changes in this version

+ var KindNoOpEvent = Kind("NoOp")

type Aggregater

+ HandleEvent func(Eventer) error

+ PopEvents func() []Eventer

type Event

+ AggregateKind Kind

+ Migrated bool

type EventRecord

+ AggregateKind Kind

type EventStore

+ func (es EventStore) Create(ctx context.Context, aggregate Aggregater, options ...SaveOption) (err error)

+ func (es EventStore) Retrieve(ctx context.Context, aggregateID string) (Aggregater, error)

+ func (es EventStore) Update(ctx context.Context, id string, do func(Aggregater) (Aggregater, error), ...) error

type EventStorer

+ Create func(ctx context.Context, aggregate Aggregater, options ...SaveOption) error

+ Retrieve func(ctx context.Context, aggregateID string) (Aggregater, error)

+ Update func(ctx context.Context, id string, do func(Aggregater) (Aggregater, error), ...) error

+ type Kind string

+ func (a Kind) String() string

+ type Kinder interface

+ GetKind func() Kind

+ type NoOpEvent struct

+ func (e NoOpEvent) GetKind() string

type RootAggregate

+ func (a RootAggregate) PopEvents() []Eventer

type SaveOption

+ func WithClock(clock util.Clocker) SaveOption

type Snapshot

+ AggregateKind Kind

Aug 12, 2021

Changes in this version

+ type AggregateFactory interface

+ NewAggregate func(typ AggregateType) (Aggregater, error)

type EsRepository

+ MigrateInPlaceCopyReplace func(ctx context.Context, revision int, snapshotThreshold uint32, ...) error

+ type EventFactory interface

+ NewEvent func(kind EventKind) (Typer, error)

type EventKind

+ const InvalidatedKind

+ type EventMigration struct

+ Body []byte

+ IdempotencyKey string

+ Kind EventKind

+ Metadata *encoding.Json

+ func DefaultEventMigration(e *Event) *EventMigration

type EventRecord

+ Metadata map[string]interface{}

type EventStore

+ func (es EventStore) MigrateInPlaceCopyReplace(ctx context.Context, revision int, snapshotThreshold uint32, ...) error

+ type MigrationHandler func(events []*Event) ([]*EventMigration, error)

Jun 6, 2021

Changes in this version

type EsOptions

+ func WithSnapshotThreshold(snapshotThreshold uint32) EsOptions

Jun 3, 2021

Changes in this version

+ const EmptyIdempotencyKey

Jun 2, 2021

Changes in this version

type Aggregater

+ GetUpdatedAt func() time.Time

+ SetUpdatedAt func(time.Time)

type EventStore

+ func (es EventStore) ApplyChangeFromHistory(agg Aggregater, e Event) error

type RootAggregate

+ func (a *RootAggregate) SetUpdatedAt(t time.Time)

+ func (a RootAggregate) GetUpdatedAt() time.Time

May 31, 2021

Changes in this version

+ type AggregateType string

+ func (a AggregateType) String() string

+ type EventKind string

+ func (e EventKind) String() string

Apr 29, 2021

Changes in this version

+ var ErrConcurrentModification = errors.New("concurrent modification")

+ var ErrUnknownAggregateID = errors.New("unknown aggregate ID")

+ type Aggregater interface

+ ApplyChangeFromHistory func(m EventMetadata, event Eventer)

+ ClearEvents func()

+ GetEvents func() []Eventer

+ GetEventsCounter func() uint32

+ GetID func() string

+ GetVersion func() uint32

+ SetVersion func(uint32)

+ UpdatedAt func() time.Time

+ type Codec interface

+ type Decoder interface

+ Decode func(data []byte, v interface{}) error

+ type Encoder interface

+ Encode func(v interface{}) ([]byte, error)

+ type EsOptions func(*EventStore)

+ func WithCodec(codec Codec) EsOptions

+ func WithUpcaster(upcaster Upcaster) EsOptions

+ type EsRepository interface

+ Forget func(ctx context.Context, request ForgetRequest, ...) error

+ GetAggregateEvents func(ctx context.Context, aggregateID string, snapVersion int) ([]Event, error)

+ GetSnapshot func(ctx context.Context, aggregateID string) (Snapshot, error)

+ HasIdempotencyKey func(ctx context.Context, aggregateID, idempotencyKey string) (bool, error)

+ SaveEvent func(ctx context.Context, eRec EventRecord) (id string, version uint32, err error)

+ SaveSnapshot func(ctx context.Context, snapshot Snapshot) error

+ type Event struct

+ AggregateID string

+ AggregateIDHash uint32

+ AggregateType string

+ AggregateVersion uint32

+ Body encoding.Base64

+ CreatedAt time.Time

+ ID string

+ IdempotencyKey string

+ Kind string

+ Metadata map[string]interface{}

+ ResumeToken encoding.Base64

+ func (e Event) IsZero() bool

+ type EventHandler interface

+ HandleEvent func(event Eventer)

+ type EventMetadata struct

+ AggregateVersion uint32

+ CreatedAt time.Time

+ type EventRecord struct

+ AggregateID string

+ AggregateType string

+ CreatedAt time.Time

+ Details []EventRecordDetail

+ IdempotencyKey string

+ Labels map[string]interface{}

+ Version uint32

+ type EventRecordDetail struct

+ Body []byte

+ Kind string

+ type EventStore struct

+ func NewEventStore(repo EsRepository, snapshotThreshold uint32, factory Factory, ...) EventStore

+ func (es EventStore) Exec(ctx context.Context, id string, do func(Aggregater) (Aggregater, error), ...) error

+ func (es EventStore) Forget(ctx context.Context, request ForgetRequest, ...) error

+ func (es EventStore) GetByID(ctx context.Context, aggregateID string) (Aggregater, error)

+ func (es EventStore) HasIdempotencyKey(ctx context.Context, aggregateType, idempotencyKey string) (bool, error)

+ func (es EventStore) RehydrateAggregate(kind string, body []byte) (Typer, error)

+ func (es EventStore) RehydrateEvent(kind string, body []byte) (Typer, error)

+ func (es EventStore) Save(ctx context.Context, aggregate Aggregater, options ...SaveOption) (err error)

+ type EventStorer interface

+ Forget func(ctx context.Context, request ForgetRequest, ...) error

+ GetByID func(ctx context.Context, aggregateID string) (Aggregater, error)

+ HasIdempotencyKey func(ctx context.Context, aggregateID, idempotencyKey string) (bool, error)

+ Save func(ctx context.Context, aggregate Aggregater, options ...SaveOption) error

+ type Eventer interface

+ type Factory interface

+ New func(kind string) (Typer, error)

+ type ForgetRequest struct

+ AggregateID string

+ EventKind string

+ type JSONCodec struct

+ func (JSONCodec) Decode(data []byte, v interface{}) error

+ func (JSONCodec) Encode(v interface{}) ([]byte, error)

+ type Options struct

+ IdempotencyKey string

+ Labels map[string]interface{}

+ type RootAggregate struct

+ EventsCounter uint32

+ ID string

+ Version uint32

+ func NewRootAggregate(aggregate EventHandler) RootAggregate

+ func (a *RootAggregate) ApplyChange(event Eventer)

+ func (a *RootAggregate) ApplyChangeFromHistory(m EventMetadata, event Eventer)

+ func (a *RootAggregate) ClearEvents()

+ func (a *RootAggregate) SetVersion(version uint32)

+ func (a RootAggregate) GetEvents() []Eventer

+ func (a RootAggregate) GetEventsCounter() uint32

+ func (a RootAggregate) GetID() string

+ func (a RootAggregate) GetVersion() uint32

+ func (a RootAggregate) IsZero() bool

+ func (a RootAggregate) UpdatedAt() time.Time

+ type SaveOption func(*Options)

+ func WithIdempotencyKey(key string) SaveOption

+ func WithMetadata(metadata map[string]interface{}) SaveOption

+ type Snapshot struct

+ AggregateID string

+ AggregateType string

+ AggregateVersion uint32

+ Body []byte

+ CreatedAt time.Time

+ ID string

+ type Typer interface

+ GetType func() string

+ func RehydrateAggregate(factory Factory, decoder Decoder, upcaster Upcaster, kind string, body []byte) (Typer, error)

+ func RehydrateEvent(factory Factory, decoder Decoder, upcaster Upcaster, kind string, body []byte) (Typer, error)

+ type Upcaster interface

+ Upcast func(Typer) Typer