eventhorizon

package module

Go to main page

Versions in this module

v0

v0.15.6

Jun 13, 2022

Changes in this version

+ const AggregateStoreOpLoad

+ const AggregateStoreOpSave

+ const EventStoreOpClear

+ const EventStoreOpLoad

+ const EventStoreOpRename

+ const EventStoreOpReplace

+ const EventStoreOpSave

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

+ 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 RegisteredCommands() map[CommandType]func() Command

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

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

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