memory

package
v3.2.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 3, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrNoEventData = errors.New("Cannot scan, no event data")

Functions

func NewMemoryEventStore

func NewMemoryEventStore() cqrs.EventStore

func NewSnapshotStore

func NewSnapshotStore() cqrs.SnapshotStore

Types

type EventStore

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

func (*EventStore) LoadStream

func (s *EventStore) LoadStream(aggregateName string, aggregateId uuid.UUID, version int) (cqrs.EventStream, error)

func (*EventStore) WriteEvent

func (s *EventStore) WriteEvent(aggregateName string, events ...cqrs.Event) error

type EventStream

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

func (*EventStream) AggregateId

func (s *EventStream) AggregateId() uuid.UUID

func (*EventStream) Error

func (s *EventStream) Error() error

func (*EventStream) EventName

func (s *EventStream) EventName() string

func (*EventStream) Next

func (s *EventStream) Next() bool

func (*EventStream) OccurredAt

func (s *EventStream) OccurredAt() time.Time

func (*EventStream) Scan

func (s *EventStream) Scan(event cqrs.Event) error

func (*EventStream) Version

func (s *EventStream) Version() int

Jump to

Keyboard shortcuts

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