projection

Documentation

Index

• func NewDiskSnapshotStore(basePath string) *diskSnapshotStore
• type AggregateTypeStats
  • func NewAggregateTypeStats() *AggregateTypeStats
  • func (a *AggregateTypeStats) Accept(record *rangedb.Record)
  • func (a *AggregateTypeStats) LatestGlobalSequenceNumber() uint64
  • func (a *AggregateTypeStats) LoadFromSnapshot(r io.Reader) error
  • func (a *AggregateTypeStats) SaveSnapshot(w io.Writer) error
  • func (a *AggregateTypeStats) SnapshotName() string
  • func (a *AggregateTypeStats) SortedAggregateTypes() []string
  • func (a *AggregateTypeStats) TotalEvents() uint64
  • func (a *AggregateTypeStats) TotalEventsByAggregateType(aggregateType string) uint64
• type SnapshotProjection
• type SnapshotStore

Functions

func NewDiskSnapshotStore

func NewDiskSnapshotStore(basePath string) *diskSnapshotStore

Types

type AggregateTypeStats

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

func NewAggregateTypeStats

func NewAggregateTypeStats() *AggregateTypeStats

func (*AggregateTypeStats) Accept

func (a *AggregateTypeStats) Accept(record *rangedb.Record)

func (*AggregateTypeStats) LatestGlobalSequenceNumber

func (a *AggregateTypeStats) LatestGlobalSequenceNumber() uint64

func (*AggregateTypeStats) LoadFromSnapshot

func (a *AggregateTypeStats) LoadFromSnapshot(r io.Reader) error

func (*AggregateTypeStats) SaveSnapshot

func (a *AggregateTypeStats) SaveSnapshot(w io.Writer) error

func (*AggregateTypeStats) SnapshotName

func (a *AggregateTypeStats) SnapshotName() string

func (*AggregateTypeStats) SortedAggregateTypes

func (a *AggregateTypeStats) SortedAggregateTypes() []string

func (*AggregateTypeStats) TotalEvents

func (a *AggregateTypeStats) TotalEvents() uint64

func (*AggregateTypeStats) TotalEventsByAggregateType

func (a *AggregateTypeStats) TotalEventsByAggregateType(aggregateType string) uint64

type SnapshotProjection

type SnapshotProjection interface {
	SnapshotName() string
	SaveSnapshot(w io.Writer) error
	LoadFromSnapshot(r io.Reader) error
}

type SnapshotStore

type SnapshotStore interface {
	Load(projection SnapshotProjection) error
	Save(projection SnapshotProjection) error
}