eventhorizon

package module

Go to main page

Versions in this module

v1

v1.0.1

Sep 28, 2021

Changes in this version

+ var ErrCouldNotLoadEntity = errors.New("could not load entity")

+ var ErrCouldNotRemoveEntity = errors.New("could not remove entity")

+ var ErrCouldNotSaveEvents = errors.New("could not save events")

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

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

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

+ 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 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

+ type AggregateError struct

+ Err error

+ func (e AggregateError) Cause() error

+ func (e AggregateError) Error() string

+ func (e AggregateError) Unwrap() error

type AggregateType

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

+ func (at AggregateType) String() string

+ 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 CouldNotHandleEventError struct

+ Err error

+ Event Event

+ func (e CouldNotHandleEventError) Cause() error

+ func (e CouldNotHandleEventError) Error() string

+ func (e CouldNotHandleEventError) Unwrap() error

type Event

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

type EventBus

+ Errors func() <-chan EventBusError

+ Wait func()

+ 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 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 EventStoreError

+ 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 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 ReadRepo

+ InnerRepo func(context.Context) ReadRepo

type RepoError

+ func (e RepoError) Cause() error

+ func (e RepoError) Unwrap() error

v0

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