version

Documentation

Index

• type EventStoreReader
• type MinVersionFunc
• type Repo
  • func IntoRepo(ctx context.Context, repo eh.ReadRepo) *Repo
  • func NewRepo(repo eh.ReadWriteRepo, eventStore EventStoreReader) *Repo
  • func (r *Repo) Find(ctx context.Context, id uuid.UUID) (eh.Entity, error)
  • func (r *Repo) InnerRepo(_ context.Context) eh.ReadRepo

Types

type EventStoreReader

type EventStoreReader interface {
	// LoadFrom loads all events from version for the aggregate id from the store.
	LoadFrom(ctx context.Context, id uuid.UUID, version int) ([]eh.Event, error)
}

type MinVersionFunc

type MinVersionFunc = func(ctx context.Context, uuid2 uuid.UUID) (int, bool)

type Repo

type Repo struct {
	eh.ReadWriteRepo
	// contains filtered or unexported fields
}

Repo is a middleware that adds version checking to a read repository.

func IntoRepo

func IntoRepo(ctx context.Context, repo eh.ReadRepo) *Repo

IntoRepo tries to convert an eh.ReadRepo into a Repo by recursively looking at inner repos. Returns nil if none was found.

func NewRepo

func NewRepo(repo eh.ReadWriteRepo, eventStore EventStoreReader) *Repo

NewRepo creates a new Repo. Uses the supplied event store to find the min version number of a given stream/aggregate

func (*Repo) Find

func (r *Repo) Find(ctx context.Context, id uuid.UUID) (eh.Entity, error)

Find implements the Find method of the eventhorizon.ReadModel interface. If the context contains a min version set by WithMinVersion it will only return an item if its version is at least min version. If a timeout or deadline is set on the context it will repeatedly try to get the item until either the version matches or the deadline is reached.

func (*Repo) InnerRepo

func (r *Repo) InnerRepo(_ context.Context) eh.ReadRepo

InnerRepo implements the InnerRepo method of the eventhorizon.ReadRepo interface.