eventhandler

package
v0.3.6-dev40 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEventStoreRefreshMiddleware

func NewEventStoreRefreshMiddleware(esClient apiEs.EventStoreClient, refreshInterval time.Duration) es.EventHandlerMiddleware

NewEventStoreRefreshMiddleware creates an EventHandler which automates periodic querying of the EventStore to keep up-to-date.

func NewEventStoreReplayMiddleware

func NewEventStoreReplayMiddleware(esClient apiEs.EventStoreClient) es.EventHandlerMiddleware

NewEventStoreReplayMiddleware creates an EventHandler which automates querying the EventStore in case of gaps in AggregateVersion found in other EventHandlers later in the chain of EventHandlers.

func NewLoggingEventHandler

func NewLoggingEventHandler() *loggingEventHandler

NewLoggingEventHandler creates an EventHandler which automates storing Events in the EventStore when a Logging has emitted any.

func NewProjectingEventHandler

func NewProjectingEventHandler(projector es.Projector, repository es.Repository) es.EventHandler

NewProjectingEventHandler creates an EventHandler which applies incoming events on a Projector and updates the Repository accordingly.

func NewReactorEventHandler

func NewReactorEventHandler(esClient apiEs.EventStoreClient, reactor es.Reactor) *reactorEventHandler

NewReactorEventHandler creates an EventHandler which automates storing Events in the EventStore when a Reactor has emitted any.

Types

type ProjectionOutdatedError

type ProjectionOutdatedError struct {
	ProjectionVersion uint64
}

func (*ProjectionOutdatedError) Error

func (e *ProjectionOutdatedError) Error() string

Jump to

Keyboard shortcuts

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