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

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