mongodb

Documentation

Index

• Variables
• type Options
• type SnapshotStore
  • func NewSnapshotStore(options Options) (*SnapshotStore, error)
  • func (s *SnapshotStore) Clear(ctx context.Context) error
  • func (s *SnapshotStore) Close()
  • func (s *SnapshotStore) Load(ctx context.Context, aggregateType eh.AggregateType, id string, version int) (eh.Aggregate, error)
  • func (s *SnapshotStore) Save(ctx context.Context, aggregate eh.Aggregate) error

Variables

var ErrCouldNotClearDB = errors.New("could not clear database")

ErrCouldNotClearDB is when the database could not be cleared.

var ErrCouldNotDialDB = errors.New("could not dial database")

ErrCouldNotDialDB is when the database could not be dialed.

var ErrCouldNotLoadSnapshot = errors.New("could not load snapshot")

ErrCouldNotLoadSnapshot is when an aggregate could not be loaded.

var ErrCouldNotMarshalSnapshot = errors.New("could not marshal snapshot")

ErrCouldNotMarshalSnapshot is when an event could not be marshaled into BSON.

var ErrCouldNotSaveSnapshot = errors.New("could not save snapshot")

ErrCouldNotSaveSnapshot is when an aggregate could not be saved.

var ErrCouldNotUnmarshalSnapshot = errors.New("could not unmarshal snapshot")

ErrCouldNotUnmarshalSnapshot is when an event could not be unmarshaled into a concrete type.

var ErrNoDBSession = errors.New("no database session")

ErrNoDBSession is when no database session is set.

Types

type Options

type Options struct {
	SSL            bool
	DBHost         string
	DBName         string
	DBUser         string
	DBPassword     string
	SingleSnapshot bool
}

type SnapshotStore

type SnapshotStore struct {
	SingleSnapshot bool
	// contains filtered or unexported fields
}

func NewSnapshotStore

func NewSnapshotStore(options Options) (*SnapshotStore, error)

NewSnapshotStore creates a new EventStore.

func (*SnapshotStore) Clear

func (s *SnapshotStore) Clear(ctx context.Context) error

func (*SnapshotStore) Close

func (s *SnapshotStore) Close()

func (*SnapshotStore) Load

func (s *SnapshotStore) Load(ctx context.Context, aggregateType eh.AggregateType, id string, version int) (eh.Aggregate, error)

func (*SnapshotStore) Save

func (s *SnapshotStore) Save(ctx context.Context, aggregate eh.Aggregate) error