eventhorizon

package module

Go to main page

Versions in this module

v0

v0.20.1

Oct 14, 2024

v0.20.0

Jul 12, 2024

Changes in this version

+ const EventStoreOpRemove

type EventStoreMaintenance

+ Remove func(ctx context.Context, aggregateID uuid.UUID) error

v0.19.1

Jun 7, 2024

v0.19.0

May 20, 2024

Changes in this version

type EventStoreMaintenance

+ Clear func(ctx context.Context) error

v0.18.1-prefix.1

May 16, 2024

v0.18.0

May 15, 2024

Changes in this version

+ const AggregateStoreOpLoad

+ const AggregateStoreOpSave

+ const EventStoreOpClear

+ const EventStoreOpLoad

+ const EventStoreOpLoadSnapshot

+ const EventStoreOpRename

+ const EventStoreOpReplace

+ const EventStoreOpSave

+ const EventStoreOpSaveSnapshot

+ const RepoOpClear

+ const RepoOpFind

+ const RepoOpFindAll

+ const RepoOpFindQuery

+ const RepoOpRemove

+ const RepoOpSave

+ var ErrEventConflictFromOtherSave = errors.New("event conflict from other save")

+ var ErrEventNotFound = errors.New("event not found")

+ var ErrHandlerAlreadyAdded = errors.New("handler already added")

+ var ErrMismatchedEventAggregateIDs = errors.New("mismatched event aggregate IDs")

+ var ErrMismatchedEventAggregateTypes = errors.New("mismatched event aggregate types")

+ var ErrMissingAggregateID = errors.New("missing aggregate ID")

+ var ErrMissingCommand = errors.New("missing command")

+ var ErrMissingEvent = errors.New("missing event")

+ var ErrMissingEvents = errors.New("missing events")

+ var ErrMissingHandler = errors.New("missing handler")

+ var ErrMissingMatcher = errors.New("missing matcher")

+ var ErrSnapshotDataNotRegistered = errors.New("snapshot data not registered")

+ func AggregateIDFromContext(ctx context.Context) (uuid.UUID, bool)

+ func CompareEventSlices(evts1, evts2 []Event, opts ...CompareOption) bool

+ func CompareEvents(e1, e2 Event, options ...CompareOption) error

+ func CopyContext(from, to context.Context) context.Context

+ func NewContextWithAggregateID(ctx context.Context, aggregateID uuid.UUID) context.Context

+ func NewContextWithAggregateType(ctx context.Context, aggregateType AggregateType) context.Context

+ func NewContextWithCommandType(ctx context.Context, commandType CommandType) context.Context

+ func RegisterSnapshotData(aggregateType AggregateType, factory func(id uuid.UUID) SnapshotData)

+ func RegisteredCommands() map[CommandType]func() Command

+ func UnregisterAggregate(aggregateType AggregateType)

+ type AggregateError struct

+ Err error

+ func (e *AggregateError) Cause() error

+ func (e *AggregateError) Error() string

+ func (e *AggregateError) Unwrap() error

+ type AggregateStoreError struct

+ AggregateID uuid.UUID

+ AggregateType AggregateType

+ Err error

+ Op AggregateStoreOperation

+ func (e *AggregateStoreError) Cause() error

+ func (e *AggregateStoreError) Error() string

+ func (e *AggregateStoreError) Unwrap() error

+ type AggregateStoreOperation string

type AggregateType

+ func AggregateTypeFromContext(ctx context.Context) (AggregateType, bool)

+ func (at AggregateType) String() string

+ type BasicMongoDB struct

+ func NewMongoDB(uri string, dbName string) (*BasicMongoDB, error)

+ func NewMongoDBWithClient(client *mongo.Client, dbName string) *BasicMongoDB

+ func (db *BasicMongoDB) Close() error

+ func (db *BasicMongoDB) CollectionDrop(ctx context.Context, collectionName string) error

+ func (db *BasicMongoDB) CollectionExec(ctx context.Context, collectionName string, ...) error

+ func (db *BasicMongoDB) CollectionExecWithTransaction(ctx context.Context, collectionName string, ...) error

+ func (db *BasicMongoDB) CollectionWatchChangeStream(ctx context.Context, collectionName string, pipeline interface{}, ...) error

+ func (db *BasicMongoDB) DatabaseExec(ctx context.Context, fn func(context.Context, *mongo.Database) error) error

+ func (db *BasicMongoDB) DatabaseExecWithTransaction(ctx context.Context, fn func(mongo.SessionContext, *mongo.Database) error) error

+ func (db *BasicMongoDB) Errors() <-chan error

+ func (db *BasicMongoDB) Ping(ctx context.Context, rp *readpref.ReadPref) error

+ type CommandCodec interface

+ MarshalCommand func(context.Context, Command) ([]byte, error)

+ UnmarshalCommand func(context.Context, []byte) (Command, context.Context, error)

+ type CommandIDer interface

+ CommandID func() uuid.UUID

type CommandType

+ func CommandTypeFromContext(ctx context.Context) (CommandType, bool)

+ func (ct CommandType) String() string

+ type CompareConfig struct

+ type CompareOption func(*CompareConfig)

+ func IgnorePositionMetadata() CompareOption

+ func IgnoreTimestamp() CompareOption

+ func IgnoreVersion() CompareOption

type Event

+ Metadata func() map[string]interface{}

type EventBus

+ Close func() error

+ Errors func() <-chan error

+ type EventBusError struct

+ Ctx context.Context

+ Err error

+ Event Event

+ func (e *EventBusError) Cause() error

+ func (e *EventBusError) Error() string

+ func (e *EventBusError) Unwrap() error

+ type EventCodec interface

+ MarshalEvent func(context.Context, Event) ([]byte, error)

+ UnmarshalEvent func(context.Context, []byte) (Event, context.Context, error)

type EventHandler

+ HandlerType func() EventHandlerType

+ type EventHandlerChain interface

+ InnerHandler func() EventHandler

+ type EventHandlerError struct

+ Err error

+ Event Event

+ func (e *EventHandlerError) Cause() error

+ func (e *EventHandlerError) Error() string

+ func (e *EventHandlerError) Unwrap() error

type EventHandlerFunc

+ func (f EventHandlerFunc) HandlerType() EventHandlerType

+ type EventHandlerType string

+ func (ht EventHandlerType) String() string

type EventMatcher

+ Match func(Event) bool

+ type EventOption func(Event)

+ func ForAggregate(aggregateType AggregateType, aggregateID uuid.UUID, version int) EventOption

+ func FromCommand(cmd Command) EventOption

+ func WithGlobalPosition(position int) EventOption

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

+ type EventSource interface

+ ClearUncommittedEvents func()

+ UncommittedEvents func() []Event

type EventStore

+ Close func() error

+ LoadFrom func(ctx context.Context, id uuid.UUID, version int) ([]Event, error)

type EventStoreError

+ AggregateID uuid.UUID

+ AggregateType AggregateType

+ AggregateVersion int

+ Events []Event

+ Op EventStoreOperation

+ func (e *EventStoreError) Cause() error

+ func (e *EventStoreError) Unwrap() error

+ type EventStoreMaintenance interface

+ RenameEvent func(ctx context.Context, from, to EventType) error

+ Replace func(context.Context, Event) error

+ type EventStoreOperation string

type EventType

+ func (et EventType) String() string

+ type IsZeroer interface

+ IsZero func() bool

+ type MatchAggregates []AggregateType

+ func (types MatchAggregates) Match(e Event) bool

+ type MatchAll []EventMatcher

+ func (matchers MatchAll) Match(e Event) bool

type MatchAny

+ func (matchers MatchAny) Match(e Event) bool

+ type MatchEvents []EventType

+ func (types MatchEvents) Match(e Event) bool

+ type MongoDB interface

+ Close func() error

+ CollectionDrop func(ctx context.Context, collectionName string) error

+ CollectionExec func(ctx context.Context, collectionName string, ...) error

+ CollectionExecWithTransaction func(ctx context.Context, collectionName string, ...) error

+ CollectionWatchChangeStream func(ctx context.Context, collectionName string, pipeline interface{}, ...) error

+ DatabaseExec func(ctx context.Context, fn func(context.Context, *mongo.Database) error) error

+ DatabaseExecWithTransaction func(ctx context.Context, fn func(mongo.SessionContext, *mongo.Database) error) error

+ Errors func() <-chan error

+ Ping func(ctx context.Context, rp *readpref.ReadPref) error

+ type Outbox interface

+ AddHandler func(context.Context, EventMatcher, EventHandler) error

+ Close func() error

+ Errors func() <-chan error

+ Start func()

+ type OutboxError struct

+ Ctx context.Context

+ Err error

+ Event Event

+ func (e *OutboxError) Cause() error

+ func (e *OutboxError) Error() string

+ func (e *OutboxError) Unwrap() error

type ReadRepo

+ Close func() error

+ InnerRepo func(context.Context) ReadRepo

type RepoError

+ EntityID uuid.UUID

+ Op RepoOperation

+ func (e *RepoError) Cause() error

+ func (e *RepoError) Unwrap() error

+ type RepoOperation string

+ type Snapshot struct

+ AggregateType AggregateType

+ State interface{}

+ Timestamp time.Time

+ Version int

+ type SnapshotData interface

+ func CreateSnapshotData(AggregateID uuid.UUID, aggregateType AggregateType) (SnapshotData, error)

+ type SnapshotStore interface

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

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

+ type SnapshotStrategy interface

+ ShouldTakeSnapshot func(lastSnapshotVersion int, lastSnapshotTimestamp time.Time, event Event) bool

+ type Snapshotable interface

+ ApplySnapshot func(snapshot *Snapshot)

+ CreateSnapshot func() *Snapshot

v0.17.1-prefix.1

May 14, 2024

v0.2.0

Mar 21, 2018

v0.1.0

Mar 21, 2018

Changes in this version

+ const DefaultMinVersionDeadline

+ const DefaultNamespace

+ var ErrAggregateNotFound = errors.New("aggregate not found")

+ var ErrAggregateNotRegistered = errors.New("aggregate not registered")

+ var ErrCommandNotRegistered = errors.New("command not registered")

+ var ErrCouldNotSaveEntity = errors.New("could not save entity")

+ var ErrEntityHasNoVersion = errors.New("entity has no version")

+ var ErrEntityNotFound = errors.New("could not find entity")

+ var ErrEventDataNotRegistered = errors.New("event data not registered")

+ var ErrIncorrectEntityVersion = errors.New("incorrect entity version")

+ var ErrIncorrectEventVersion = errors.New("mismatching event version")

+ var ErrInvalidEvent = errors.New("invalid event")

+ var ErrMissingEntityID = errors.New("missing entity ID")

+ var ErrNoEventsToAppend = errors.New("no events to append")

+ func CheckCommand(cmd Command) error

+ func MarshalContext(ctx context.Context) map[string]interface

+ func MinVersionFromContext(ctx context.Context) (int, bool)

+ func NamespaceFromContext(ctx context.Context) string

+ func NewContextWithMinVersion(ctx context.Context, minVersion int) context.Context

+ func NewContextWithMinVersionWait(ctx context.Context, minVersion int) (c context.Context, cancel func())

+ func NewContextWithNamespace(ctx context.Context, namespace string) context.Context

+ func RegisterAggregate(factory func(UUID) Aggregate)

+ func RegisterCommand(factory func() Command)

+ func RegisterContextMarshaler(f ContextMarshalFunc)

+ func RegisterContextUnmarshaler(f ContextUnmarshalFunc)

+ func RegisterEventData(eventType EventType, factory func() EventData)

+ func UnmarshalContext(vals map[string]interface{}) context.Context

+ func UnregisterCommand(commandType CommandType)

+ func UnregisterEventData(eventType EventType)

+ type Aggregate interface

+ AggregateType func() AggregateType

+ func CreateAggregate(aggregateType AggregateType, id UUID) (Aggregate, error)

+ type AggregateStore interface

+ Load func(context.Context, AggregateType, UUID) (Aggregate, error)

+ Save func(context.Context, Aggregate) error

+ type AggregateType string

+ type Command interface

+ AggregateID func() UUID

+ AggregateType func() AggregateType

+ CommandType func() CommandType

+ func CreateCommand(commandType CommandType) (Command, error)

+ type CommandFieldError struct

+ Field string

+ func (c CommandFieldError) Error() string

+ type CommandHandler interface

+ HandleCommand func(context.Context, Command) error

+ func UseCommandHandlerMiddleware(h CommandHandler, middleware ...CommandHandlerMiddleware) CommandHandler

+ type CommandHandlerFunc func(context.Context, Command) error

+ func (h CommandHandlerFunc) HandleCommand(ctx context.Context, cmd Command) error

+ type CommandHandlerMiddleware func(CommandHandler) CommandHandler

+ type CommandType string

+ type ContextMarshalFunc func(context.Context, map[string]interface{})

+ type ContextUnmarshalFunc func(context.Context, map[string]interface{}) context.Context

+ type Entity interface

+ EntityID func() UUID

+ type Event interface

+ AggregateID func() UUID

+ AggregateType func() AggregateType

+ Data func() EventData

+ EventType func() EventType

+ String func() string

+ Timestamp func() time.Time

+ Version func() int

+ func NewEvent(eventType EventType, data EventData, timestamp time.Time) Event

+ func NewEventForAggregate(eventType EventType, data EventData, timestamp time.Time, ...) Event

+ type EventBus interface

+ AddHandler func(EventMatcher, EventHandler)

+ PublishEvent func(context.Context, Event) error

+ type EventData interface

+ func CreateEventData(eventType EventType) (EventData, error)

+ type EventHandler interface

+ HandleEvent func(context.Context, Event) error

+ func UseEventHandlerMiddleware(h EventHandler, middleware ...EventHandlerMiddleware) EventHandler

+ type EventHandlerFunc func(context.Context, Event) error

+ func (h EventHandlerFunc) HandleEvent(ctx context.Context, e Event) error

+ type EventHandlerMiddleware func(EventHandler) EventHandler

+ type EventMatcher func(Event) bool

+ func MatchAggregate(t AggregateType) EventMatcher

+ func MatchAny() EventMatcher

+ func MatchAnyEventOf(types ...EventType) EventMatcher

+ func MatchAnyOf(matchers ...EventMatcher) EventMatcher

+ func MatchEvent(t EventType) EventMatcher

+ type EventObserver interface

+ Notify func(context.Context, Event)

+ type EventPublisher interface

+ AddObserver func(EventObserver)

+ type EventStore interface

+ Load func(context.Context, UUID) ([]Event, error)

+ Save func(ctx context.Context, events []Event, originalVersion int) error

+ type EventStoreError struct

+ BaseErr error

+ Err error

+ Namespace string

+ func (e EventStoreError) Error() string

+ type EventStoreMaintainer interface

+ RenameEvent func(ctx context.Context, from, to EventType) error

+ Replace func(context.Context, Event) error

+ type EventType string

+ type Iter interface

+ Close func() error

+ Next func() bool

+ Value func() interface{}

+ type ReadRepo interface

+ Find func(context.Context, UUID) (Entity, error)

+ FindAll func(context.Context) ([]Entity, error)

+ Parent func() ReadRepo

+ type ReadWriteRepo interface

+ type RepoError struct

+ BaseErr error

+ Err error

+ Namespace string

+ func (e RepoError) Error() string

+ type UUID string

+ func NewUUID() UUID

+ func ParseUUID(s string) (UUID, error)

+ func (id *UUID) UnmarshalJSON(data []byte) error

+ func (id UUID) MarshalJSON() ([]byte, error)

+ func (id UUID) String() string

+ type Versionable interface

+ AggregateVersion func() int

+ type WriteRepo interface

+ Remove func(context.Context, UUID) error

+ Save func(context.Context, Entity) error

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