formatters

Documentation

Index

• type Snapshotter
  • func NewSnapshotter[T es.Projection](esClient esApi.EventStoreClient, projector es.Projector[T]) *Snapshotter[T]
  • func (s *Snapshotter[T]) CreateSnapshot(ctx context.Context, eventFilter *esApi.EventFilter) (T, error)

Types

type Snapshotter

type Snapshotter[T es.Projection] struct {
	// contains filtered or unexported fields
}

Snapshotter implements basic snapshot creation for audit formatters

func NewSnapshotter

func NewSnapshotter[T es.Projection](esClient esApi.EventStoreClient, projector es.Projector[T]) *Snapshotter[T]

func (*Snapshotter[T]) CreateSnapshot

func (s *Snapshotter[T]) CreateSnapshot(ctx context.Context, eventFilter *esApi.EventFilter) (T, error)

CreateSnapshot creates a snapshot based on an event-filter and the corresponding projector for the aggregate of which the id is used in the filter. This is a temporary implementation until snapshots are fully implemented, and it is not meant to be used extensively.