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)
• type UserSnapshotter
  • func NewUserSnapshotter(esClient esApi.EventStoreClient, projector es.Projector[*projections.User]) *UserSnapshotter
  • func (s *UserSnapshotter) CreateRoleBindingSnapshots(ctx context.Context, userId uuid.UUID, timestamp time.Time) []*projections.UserRoleBinding

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.

type UserSnapshotter

type UserSnapshotter struct {
	*Snapshotter[*projections.User]
}

UserSnapshotter implements basic snapshot creation for the user aggregate

func NewUserSnapshotter

func NewUserSnapshotter(esClient esApi.EventStoreClient, projector es.Projector[*projections.User]) *UserSnapshotter

func (*UserSnapshotter) CreateRoleBindingSnapshots

func (s *UserSnapshotter) CreateRoleBindingSnapshots(ctx context.Context, userId uuid.UUID, timestamp time.Time) []*projections.UserRoleBinding

CreateRoleBindingSnapshots returns a list of userRoleBinding snapshots for the user specified by its id This is a temporary implementation until snapshots are fully implemented, and it is not meant to be used extensively.