maintenance

type Attributor interface {
	RootOwner(ctx context.Context) (func(root []byte) pack.Attribution, error)
	RecordSetSizes(ctx context.Context, report *pack.CollectReport) error
}

type Collected interface {
	LastCollected() (time.Time, error)
}

type Measurer interface {
	MeasureSets(ctx context.Context) ([]index.SetInfo, error)
}

type Presence interface {
	BuildPendingPresence(ctx context.Context) (int, error)
}

type Ran struct {
	Swept             bool
	Retired, Presence int
	// Compacted is nil when no compaction ran; alongside a failed one it
	// counts what that finished.
	Compacted *pack.CompactReport
	// Measured is how many sets had their sizes measured.
	Measured int
	// Collected is nil when no collection was due.
	Collected *pack.CollectReport
	// Reindexed are the tables whose indexes the run's churn rebuilt.
	Reindexed []index.Reindexed
}

type Reindexer interface {
	ReindexChurned(ctx context.Context) ([]index.Reindexed, error)
}

type Repairer interface {
	Repair(ctx context.Context) (*pack.RepairReport, error)
}

type Runner struct {
	Store      Store
	Collector  pack.Collector
	Attributor Attributor
	Retirer    backup.Retirer
	Presence   Presence
	Measurer   Measurer
	Reindexer  Reindexer
	Schedule   Schedule
	// OnCollect sees every garbage collection report; nil ignores them.
	OnCollect func(*pack.CollectReport)
	// Logger is where failures go; nil means slog.Default.
	Logger *slog.Logger
	// Now is the clock; nil means time.Now.
	Now func() time.Time
}

type Schedule struct {
	Sweep   time.Duration
	Compact time.Duration
	Collect time.Duration
	Retire  time.Duration
	// Presence also measures the sets whose commits changed.
	Presence time.Duration
}

type Scrubber interface {
	Scrub(ctx context.Context) (*pack.ScrubReport, error)
}

type SetLister interface {
	ListSets(ctx context.Context) ([]index.SetInfo, error)
}

type Store interface {
	Sweep(now time.Time)
	Compact(ctx context.Context) (*pack.CompactReport, error)
}