Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

eventstore

package module

Go to main page

Versions in this module

v1

v1.2.1

Dec 28, 2020

v1.1.1

Dec 27, 2020

v1.1.0

Dec 27, 2020

v1.0.0

Dec 25, 2020

Changes in this version

+ func ProjectorNoHandler() string

type Status

+ const StatusDeleting

+ const StatusDeletingIinclEmittedEevents

+ const StatusResetting

v0

v0.6.3

Dec 29, 2020

v0.6.2

Dec 29, 2020

v0.6.1

Dec 29, 2020

v0.6.0

Dec 28, 2020

Changes in this version

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

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

+ type Aggregate interface

+ AggregateID func() uuid.UUID

+ FromHistory func(events DomainEventIterator) error

+ PopEvents func() []DomainEvent

+ type BaseAggregate struct

+ func NewAggregate(source interface{}) BaseAggregate

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

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

+ func (a *BaseAggregate) FromHistory(events DomainEventIterator) error

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

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

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

+ func (a BaseAggregate) Version() int

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

+ type DomainEventAction = string

+ const Appended

+ const Loaded

+ const PreAppend

+ type DomainEventIterator interface

+ Close func()

+ Current func() (*DomainEvent, error)

+ Error func() error

+ IsEmpty func() (bool, error)

+ Next func() bool

+ Rewind func()

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

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

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

+ type EventStore struct

+ func NewEventStore(strategy PersistenceStrategy) *EventStore

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

+ func (es *EventStore) AppendTo(ctx context.Context, streamName string, events []DomainEvent) error

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

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

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

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

+ func (es *EventStore) Install(ctx context.Context) error

+ func (es *EventStore) Load(ctx context.Context, streamName string, fromNumber, count int, ...) (DomainEventIterator, error)

+ func (es *EventStore) MergeAndLoad(ctx context.Context, count int, streams ...LoadStreamParameter) (DomainEventIterator, error)

+ type FieldType string

+ const MessagePropertyField

+ const MetadataField

+ type HandlersCache map[reflect.Type]func(source interface{}, event interface{}, metadata map[string]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 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)

+ type PersistenceStrategy interface

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

+ AppendTo func(ctx context.Context, streamName string, events []DomainEvent) 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, ...) (DomainEventIterator, error)

+ MergeAndLoad func(ctx context.Context, count int, streams ...LoadStreamParameter) (DomainEventIterator, 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 DomainEvent) 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 DomainEvent) error

+ func (q *Projector) Name() string

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

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

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

+ func (q *Projector) Status() Status

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

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

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

+ type ProjectorAlreadyInitialized struct

+ func (e ProjectorAlreadyInitialized) Error() string

+ type ProjectorFromWasAlreadyCalled struct

+ func (e ProjectorFromWasAlreadyCalled) Error() string

+ type ProjectorHandlerAlreadyDefined struct

+ func (e ProjectorHandlerAlreadyDefined) Error() string

+ type ProjectorHasNoHandler struct

+ func (e ProjectorHasNoHandler) Error() string

+ type ProjectorHasNoInitCallback struct

+ func (e ProjectorHasNoInitCallback) Error() string

+ type ProjectorStateNotInitialised struct

+ func (e ProjectorStateNotInitialised) Error() string

+ type Query struct

+ 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() error

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

+ func (q *Query) Stop()

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

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

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

+ func (q Query) Status() 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) 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) (DomainEventIterator, error)

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

+ type Status string

+ const StatusIdle

+ 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