memory

Documentation

Index

• type DomainEventIterator
  • func NewDomainEventIterator(ctx context.Context, events []eventstore.DomainEvent) *DomainEventIterator
  • func (it *DomainEventIterator) Close()
  • func (it *DomainEventIterator) Current() (*eventstore.DomainEvent, error)
  • func (it *DomainEventIterator) Error() error
  • func (it *DomainEventIterator) IsEmpty() (bool, error)
  • func (it *DomainEventIterator) Next() bool
  • func (it *DomainEventIterator) Rewind()
  • func (it *DomainEventIterator) ToList() ([]eventstore.DomainEvent, error)
• type PersistenceStrategy
  • func NewPersistenceStrategy() *PersistenceStrategy
  • func (ps *PersistenceStrategy) AddStreamToStreamsTable(_ context.Context, streamName string) error
  • func (ps *PersistenceStrategy) AppendTo(ctx context.Context, streamName string, events []eventstore.DomainEvent) error
  • func (ps *PersistenceStrategy) CreateEventStreamsTable(_ context.Context) error
  • func (ps *PersistenceStrategy) CreateProjectionsTable(_ context.Context) error
  • func (ps *PersistenceStrategy) CreateSchema(_ context.Context, _ string) error
  • func (ps *PersistenceStrategy) DeleteStream(ctx context.Context, streamName string) error
  • func (ps *PersistenceStrategy) DropSchema(_ context.Context, _ string) error
  • func (ps *PersistenceStrategy) FetchAllStreamNames(_ context.Context) ([]string, error)
  • func (ps *PersistenceStrategy) HasStream(_ context.Context, streamName string) (bool, error)
  • func (ps *PersistenceStrategy) Load(ctx context.Context, streamName string, fromNumber, count int, ...) (eventstore.DomainEventIterator, error)
  • func (ps *PersistenceStrategy) MergeAndLoad(ctx context.Context, count int, streams ...eventstore.LoadStreamParameter) (eventstore.DomainEventIterator, error)
  • func (ps *PersistenceStrategy) RemoveStreamFromStreamsTable(_ context.Context, streamName string) error
• type ProjectionManager
  • func NewProjectionManager() *ProjectionManager
  • func (pm ProjectionManager) CreateProjection(_ context.Context, projectionName string, state interface{}, ...) error
  • func (pm ProjectionManager) DeleteProjection(_ context.Context, projectionName string) error
  • func (pm ProjectionManager) FetchProjectionStatus(_ context.Context, projectionName string) (eventstore.Status, error)
  • func (pm ProjectionManager) LoadProjection(_ context.Context, projectionName string) (map[string]int, interface{}, error)
  • func (pm ProjectionManager) PersistProjection(_ context.Context, projectionName string, state interface{}, ...) error
  • func (pm ProjectionManager) ProjectionExists(_ context.Context, projectionName string) (bool, error)
  • func (pm ProjectionManager) ResetProjection(_ context.Context, projectionName string, state interface{}) error
  • func (pm ProjectionManager) UpdateProjectionStatus(_ context.Context, projectionName string, status eventstore.Status) error

Types

type DomainEventIterator

type DomainEventIterator struct {
	// contains filtered or unexported fields
}

func NewDomainEventIterator

func NewDomainEventIterator(ctx context.Context, events []eventstore.DomainEvent) *DomainEventIterator

func (*DomainEventIterator) Close

func (it *DomainEventIterator) Close()

func (*DomainEventIterator) Current

func (it *DomainEventIterator) Current() (*eventstore.DomainEvent, error)

func (*DomainEventIterator) Error

func (it *DomainEventIterator) Error() error

func (*DomainEventIterator) IsEmpty

func (it *DomainEventIterator) IsEmpty() (bool, error)

func (*DomainEventIterator) Next

func (it *DomainEventIterator) Next() bool

func (*DomainEventIterator) Rewind

func (it *DomainEventIterator) Rewind()

func (*DomainEventIterator) ToList

func (it *DomainEventIterator) ToList() ([]eventstore.DomainEvent, error)

type PersistenceStrategy

type PersistenceStrategy struct {
	// contains filtered or unexported fields
}

func NewPersistenceStrategy

func NewPersistenceStrategy() *PersistenceStrategy

func (*PersistenceStrategy) AddStreamToStreamsTable

func (ps *PersistenceStrategy) AddStreamToStreamsTable(_ context.Context, streamName string) error

func (*PersistenceStrategy) AppendTo

func (ps *PersistenceStrategy) AppendTo(ctx context.Context, streamName string, events []eventstore.DomainEvent) error

func (*PersistenceStrategy) CreateEventStreamsTable

func (ps *PersistenceStrategy) CreateEventStreamsTable(_ context.Context) error

func (*PersistenceStrategy) CreateProjectionsTable

func (ps *PersistenceStrategy) CreateProjectionsTable(_ context.Context) error

func (*PersistenceStrategy) CreateSchema

func (ps *PersistenceStrategy) CreateSchema(_ context.Context, _ string) error

func (*PersistenceStrategy) DeleteStream

func (ps *PersistenceStrategy) DeleteStream(ctx context.Context, streamName string) error

func (*PersistenceStrategy) DropSchema

func (ps *PersistenceStrategy) DropSchema(_ context.Context, _ string) error

func (*PersistenceStrategy) FetchAllStreamNames

func (ps *PersistenceStrategy) FetchAllStreamNames(_ context.Context) ([]string, error)

func (*PersistenceStrategy) HasStream

func (ps *PersistenceStrategy) HasStream(_ context.Context, streamName string) (bool, error)

func (*PersistenceStrategy) Load

func (ps *PersistenceStrategy) Load(ctx context.Context, streamName string, fromNumber, count int, matcher eventstore.MetadataMatcher) (eventstore.DomainEventIterator, error)

func (*PersistenceStrategy) MergeAndLoad

func (ps *PersistenceStrategy) MergeAndLoad(ctx context.Context, count int, streams ...eventstore.LoadStreamParameter) (eventstore.DomainEventIterator, error)

func (*PersistenceStrategy) RemoveStreamFromStreamsTable

func (ps *PersistenceStrategy) RemoveStreamFromStreamsTable(_ context.Context, streamName string) error

type ProjectionManager

type ProjectionManager struct {
	// contains filtered or unexported fields
}

func NewProjectionManager

func NewProjectionManager() *ProjectionManager

func (ProjectionManager) CreateProjection

func (pm ProjectionManager) CreateProjection(_ context.Context, projectionName string, state interface{}, status eventstore.Status) error

func (ProjectionManager) DeleteProjection

func (pm ProjectionManager) DeleteProjection(_ context.Context, projectionName string) error

func (ProjectionManager) FetchProjectionStatus

func (pm ProjectionManager) FetchProjectionStatus(_ context.Context, projectionName string) (eventstore.Status, error)

func (ProjectionManager) LoadProjection

func (pm ProjectionManager) LoadProjection(_ context.Context, projectionName string) (map[string]int, interface{}, error)

func (ProjectionManager) PersistProjection

func (pm ProjectionManager) PersistProjection(_ context.Context, projectionName string, state interface{}, streamPositions map[string]int) error

func (ProjectionManager) ProjectionExists

func (pm ProjectionManager) ProjectionExists(_ context.Context, projectionName string) (bool, error)

func (ProjectionManager) ResetProjection

func (pm ProjectionManager) ResetProjection(_ context.Context, projectionName string, state interface{}) error

func (ProjectionManager) UpdateProjectionStatus

func (pm ProjectionManager) UpdateProjectionStatus(_ context.Context, projectionName string, status eventstore.Status) error