Versions in this module Expand all Collapse all v3 v3.9.9 Jun 3, 2022 Changes in this version + type Cache struct + func NewMutationCache() *Cache + func (c *Cache) Remove(mID types.ID) + func (c *Cache) TallyConflict() int + func (c *Cache) TallyStatus() map[MutatorIngestionStatus]int + func (c *Cache) Upsert(mID types.ID, ingestionStatus MutatorIngestionStatus, conflict bool) + type MutatorIngestionStatus string + const MutatorStatusActive + const MutatorStatusError + type StatsReporter interface + ReportMutatorIngestionRequest func(ms MutatorIngestionStatus, d time.Duration) error + ReportMutatorsInConflict func(n int) error + ReportMutatorsStatus func(ms MutatorIngestionStatus, n int) error + func NewStatsReporter() StatsReporter