eventstore

package module

Go to main page

Versions in this module

v0

v0.6.0

Dec 24, 2020

Changes in this version

+ type MiddlewareIterator struct

+ func NewMiddlewareIterator(ctx context.Context, iterator DomainEventIterator, ...) MiddlewareIterator

+ func (m MiddlewareIterator) Close()

+ func (m MiddlewareIterator) Current() (*DomainEvent, error)

+ func (m MiddlewareIterator) Error() error

+ func (m MiddlewareIterator) IsEmpty() (bool, error)

+ func (m MiddlewareIterator) Next() bool

+ func (m MiddlewareIterator) Rewind()

+ func (m MiddlewareIterator) ToList() ([]DomainEvent, error)

v0.5.0

Jul 5, 2020

v0.4.1

Jun 14, 2020

v0.4.0

Jun 13, 2020

v0.3.5

Jun 13, 2020

v0.3.4

Jun 13, 2020

v0.3.3

Jun 13, 2020

v0.3.2

Jun 13, 2020

v0.3.1

Jun 11, 2020

v0.3.0

Jun 10, 2020

Changes in this version

+ type DomainEventAction = string

+ const Appended

+ const Loaded

+ const PreAppend

type DomainEventIterator

+ IsEmpty func() (bool, error)

+ SetMiddleware func(middleware []DomainEventMiddleware)

+ type DomainEventMiddleware = func(ctx context.Context, event DomainEvent) (DomainEvent, error)

type EventStore

+ func (es *EventStore) AppendMiddleware(action DomainEventAction, middleware DomainEventMiddleware)

v0.2.1

Jun 9, 2020

Changes in this version

type BaseAggregate

+ func (a BaseAggregate) Version() int

v0.2.0

Jun 9, 2020

Changes in this version

+ type DomainEventIterator interface

+ Close func()

+ Current func() (*DomainEvent, error)

+ Error func() error

+ Next func() bool

+ Rewind func()

+ ToList func() ([]DomainEvent, error)

v0.1.3

Jun 9, 2020

Changes in this version

+ type DomainEvent struct

+ func NewDomainEvent(aggregateID uuid.UUID, payload interface{}, metadata map[string]interface{}, ...) DomainEvent

+ func (e DomainEvent) AggregateID() uuid.UUID

+ func (e DomainEvent) AggregateType() string

+ func (e DomainEvent) CreatedAt() time.Time

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

+ func (e DomainEvent) Name() string

+ func (e DomainEvent) Number() int

+ func (e DomainEvent) Payload() interface{}

+ func (e DomainEvent) SingleMetadata(key string) (interface{}, bool)

+ func (e DomainEvent) UUID() uuid.UUID

+ func (e DomainEvent) Version() int

+ func (e DomainEvent) WithAddedMetadata(name string, value interface{}) DomainEvent

+ func (e DomainEvent) WithAggregateType(aType string) DomainEvent

+ func (e DomainEvent) WithNumber(number int) DomainEvent

+ func (e DomainEvent) WithUUID(uuid uuid.UUID) DomainEvent

+ func (e DomainEvent) WithVersion(v int) DomainEvent

v0.1.2

Jun 8, 2020

Changes in this version

+ func CopyMap(m map[string]interface{}) map[string]interface

+ func FindStatusInSlice(slice []Status, val Status) (int, bool)

+ func ProjectorAlreadyInitialized() string

+ func ProjectorFromWasAlreadyCalled() string

+ func ProjectorNoHandler() string

+ func ProjectorStateNotInitialised() string

+ type Aggregate interface

+ AggregateID func() uuid.UUID

+ FromHistory func(events []PersistEvent)

+ PopEvents func() []PersistEvent

+ type BaseAggregate struct

+ func NewAggregate(source interface{}) BaseAggregate

+ func (a *BaseAggregate) Apply(event PersistEvent)

+ func (a *BaseAggregate) CallEventHandler(event interface{})

+ func (a *BaseAggregate) FromHistory(events []PersistEvent)

+ func (a *BaseAggregate) PopEvents() []PersistEvent

+ func (a *BaseAggregate) RecordThat(event interface{}, metadata map[string]interface{})

+ func (a BaseAggregate) AggregateID() uuid.UUID

+ type BaseEventStore struct

+ func (es BaseEventStore) AppendTo(ctx context.Context, streamName string, events []PersistEvent) error

+ func (es BaseEventStore) CreateStream(ctx context.Context, streamName string) error

+ func (es BaseEventStore) DeleteStream(ctx context.Context, streamName string) error

+ func (es BaseEventStore) FetchAllStreamNames(ctx context.Context) ([]string, error)

+ func (es BaseEventStore) HasStream(ctx context.Context, streamName string) (bool, error)

+ func (es BaseEventStore) Install(ctx context.Context) error

+ func (es BaseEventStore) Load(ctx context.Context, streamName string, fromNumber, count int, ...) ([]PersistEvent, error)

+ func (es BaseEventStore) MergeAndLoad(ctx context.Context, count int, streams ...LoadStreamParameter) ([]PersistEvent, error)

+ type Client interface

+ Conn func() interface{}

+ Delete func(ctx context.Context, collection string) error

+ Exists func(ctx context.Context, collection string) (bool, error)

+ Insert func(ctx context.Context, collection string, values map[string]interface{}) error

+ Remove func(ctx context.Context, collection string, identifiers map[string]interface{}) error

+ Reset func(ctx context.Context, collection string) error

+ Update func(ctx context.Context, collection string, values map[string]interface{}, ...) error

+ type Event struct

+ func NewEvent(aggregateID uuid.UUID, payload interface{}, metadata map[string]interface{}, ...) Event

+ func (e Event) AggregateID() uuid.UUID

+ func (e Event) AggregateType() string

+ func (e Event) CreatedAt() time.Time

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

+ func (e Event) Name() string

+ func (e Event) Number() int

+ func (e Event) Payload() interface{}

+ func (e Event) SingleMetadata(key string) (interface{}, bool)

+ func (e Event) UUID() uuid.UUID

+ func (e Event) Version() int

+ func (e Event) WithAddedMetadata(name string, value interface{}) PersistEvent

+ func (e Event) WithAggregateType(aType string) PersistEvent

+ func (e Event) WithNumber(number int) PersistEvent

+ func (e Event) WithUUID(uuid uuid.UUID) PersistEvent

+ func (e Event) WithVersion(v int) PersistEvent

+ type EventHandler = func(state interface{}, event PersistEvent) interface

+ type EventStore interface

+ AppendTo func(ctx context.Context, streamName string, events []PersistEvent) error

+ CreateStream func(ctx context.Context, streamName string) error

+ DeleteStream func(ctx context.Context, streamName string) error

+ FetchAllStreamNames func(ctx context.Context) ([]string, error)

+ HasStream func(ctx context.Context, streamName string) (bool, error)

+ Install func(context.Context) error

+ Load func(ctx context.Context, streamName string, fromNumber, count int, ...) ([]PersistEvent, error)

+ MergeAndLoad func(ctx context.Context, count int, streams ...LoadStreamParameter) ([]PersistEvent, error)

+ func NewEventStore(strategy PersistenceStrategy) EventStore

+ type FieldType string

+ const MessagePropertyField

+ const MetadataField

+ type HandlersCache map[reflect.Type]func(source interface{}, event interface{})

+ type LoadStreamParameter struct

+ FromNumber int

+ Matcher MetadataMatcher

+ StreamName string

+ type MetadataMatch struct

+ Field string

+ FieldType FieldType

+ Operation MetadataOperator

+ Value interface{}

+ type MetadataMatcher = []MetadataMatch

+ type MetadataOperator string

+ const EqualsOperator

+ const GreaterThanEqualsOperator

+ const GreaterThanOperator

+ const InOperator

+ const LowerThanEuqalsOperator

+ const LowerThanOperator

+ const NotEqualsOperator

+ const NotInOperator

+ const RegexOperator

+ type PersistEvent interface

+ AggregateID func() uuid.UUID

+ AggregateType func() string

+ CreatedAt func() time.Time

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

+ Name func() string

+ Number func() int

+ Payload func() interface{}

+ SingleMetadata func(key string) (interface{}, bool)

+ UUID func() uuid.UUID

+ Version func() int

+ WithAddedMetadata func(name string, value interface{}) PersistEvent

+ WithAggregateType func(aType string) PersistEvent

+ WithNumber func(no int) PersistEvent

+ WithUUID func(eventID uuid.UUID) PersistEvent

+ WithVersion func(v int) PersistEvent

+ type PersistenceStrategy interface

+ AddStreamToStreamsTable func(ctx context.Context, streamName string) error

+ AppendTo func(ctx context.Context, streamName string, events []PersistEvent) error

+ CreateEventStreamsTable func(context.Context) error

+ CreateProjectionsTable func(context.Context) error

+ CreateSchema func(ctx context.Context, streamName string) error

+ DeleteStream func(ctx context.Context, streamName string) error

+ DropSchema func(ctx context.Context, streamName string) error

+ FetchAllStreamNames func(ctx context.Context) ([]string, error)

+ HasStream func(ctx context.Context, streamName string) (bool, error)

+ Load func(ctx context.Context, streamName string, fromNumber int, count int, ...) ([]PersistEvent, error)

+ MergeAndLoad func(ctx context.Context, count int, streams ...LoadStreamParameter) ([]PersistEvent, error)

+ RemoveStreamFromStreamsTable func(ctx context.Context, streamName string) error

+ type ProjectionManager interface

+ CreateProjection func(ctx context.Context, projectionName string, state interface{}, status Status) error

+ DeleteProjection func(ctx context.Context, projectionName string) error

+ FetchProjectionStatus func(ctx context.Context, projectionName string) (Status, error)

+ LoadProjection func(ctx context.Context, projectionName string) (map[string]int, interface{}, error)

+ PersistProjection func(ctx context.Context, projectionName string, state interface{}, ...) error

+ ProjectionExists func(ctx context.Context, projectionName string) (bool, error)

+ ResetProjection func(ctx context.Context, projectionName string, state interface{}) error

+ UpdateProjectionStatus func(ctx context.Context, projectionName string, status Status) error

+ type ProjectionNotFound struct

+ Name string

+ func (e ProjectionNotFound) Error() string

+ type Projector struct

+ func NewProjector(name string, eventStore EventStore, manager ProjectionManager) Projector

+ func (q *Projector) Delete(ctx context.Context, deleteEmittedEvents bool) error

+ func (q *Projector) Emit(ctx context.Context, event PersistEvent) error

+ func (q *Projector) FromAll() *Projector

+ func (q *Projector) FromStream(streamName string, matcher MetadataMatcher) *Projector

+ func (q *Projector) FromStreams(streams ...StreamProjection) *Projector

+ func (q *Projector) Init(handler func() interface{}) *Projector

+ func (q *Projector) LinkTo(ctx context.Context, streamName string, event PersistEvent) error

+ func (q *Projector) Reset(ctx context.Context) error

+ func (q *Projector) Run(ctx context.Context, keepRunning bool) error

+ func (q *Projector) Stop(ctx context.Context) error

+ func (q *Projector) When(handlers map[string]EventHandler) *Projector

+ func (q *Projector) WhenAny(handler EventHandler) *Projector

+ func (q Projector) Name() string

+ func (q Projector) State() interface{}

+ func (q Projector) Status() Status

+ type Query struct

+ Status Status

+ func NewQuery(eventStore EventStore) Query

+ func (q *Query) FromAll() *Query

+ func (q *Query) FromStream(streamName string, matcher MetadataMatcher) *Query

+ func (q *Query) FromStreams(streams ...StreamProjection) *Query

+ func (q *Query) Init(handler func() interface{}) *Query

+ func (q *Query) Reset()

+ func (q *Query) Run(ctx context.Context) error

+ func (q *Query) Stop()

+ func (q *Query) When(handlers map[string]func(state interface{}, event PersistEvent) interface{}) *Query

+ func (q *Query) WhenAny(handler func(state interface{}, event PersistEvent) interface{}) *Query

+ func (q Query) State() interface{}

+ type ReadModel interface

+ Delete func(ctx context.Context) error

+ Init func(ctx context.Context) error

+ IsInitialized func(ctx context.Context) (bool, error)

+ Persist func(ctx context.Context) error

+ Reset func(ctx context.Context) error

+ Stack func(method string, args ...map[string]interface{})

+ type ReadModelProjector struct

+ ReadModel ReadModel

+ func NewReadModelProjector(name string, readModel ReadModel, eventStore EventStore, ...) ReadModelProjector

+ func (q *ReadModelProjector) Delete(ctx context.Context, deleteProjection bool) error

+ func (q *ReadModelProjector) FromAll() *ReadModelProjector

+ func (q *ReadModelProjector) FromStream(streamName string, matcher MetadataMatcher) *ReadModelProjector

+ func (q *ReadModelProjector) FromStreams(streams ...StreamProjection) *ReadModelProjector

+ func (q *ReadModelProjector) Init(handler func() interface{}) *ReadModelProjector

+ func (q *ReadModelProjector) Reset(ctx context.Context) error

+ func (q *ReadModelProjector) Run(ctx context.Context, keepRunning bool) error

+ func (q *ReadModelProjector) Stop(ctx context.Context) error

+ func (q *ReadModelProjector) When(handlers map[string]EventHandler) *ReadModelProjector

+ func (q *ReadModelProjector) WhenAny(handler EventHandler) *ReadModelProjector

+ func (q ReadModelProjector) Name() string

+ func (q ReadModelProjector) State() interface{}

+ func (q ReadModelProjector) Status() Status

+ type Repository struct

+ Stream string

+ func NewRepository(streamName string, eventStore EventStore) Repository

+ func (r Repository) GetAggregate(ctx context.Context, aggregateID uuid.UUID) ([]PersistEvent, error)

+ func (r Repository) SaveAggregate(ctx context.Context, aggregate Aggregate) error

+ type Status string

+ const StatusDeleting

+ const StatusDeletingIinclEmittedEevents

+ const StatusIdle

+ const StatusResetting

+ const StatusRunning

+ const StatusStopping

+ type StreamAlreadyExist struct

+ Stream string

+ func (e StreamAlreadyExist) Error() string

+ type StreamNotFound struct

+ Stream string

+ func (e StreamNotFound) Error() string

+ type StreamProjection struct

+ Matcher MetadataMatcher

+ StreamName string

+ type TypeCache map[string]reflect.Type

+ type TypeRegistry interface

+ GetHandlers func(interface{}) HandlersCache

+ GetTypeByName func(string) (reflect.Type, bool)

+ RegisterAggregate func(aggregate interface{}, events ...interface{})

+ RegisterEvents func(events ...interface{})

+ RegisterType func(interface{})

+ func NewTypeRegistry() TypeRegistry

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