maintenance

type BatchFunc func(context.Context, time.Time) (rows int64, more bool, err error)

type Config struct {
	LeaseDuration        time.Duration
	RenewInterval        time.Duration
	RetryInterval        time.Duration
	ContinuationInterval time.Duration
	PassTimeout          time.Duration
	MaxBatches           int
}

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

type Job struct {
	Name     string
	Interval time.Duration
	RunBatch BatchFunc
}

type LeaseStore interface {
	TryAcquireMaintenanceLease(context.Context, string, uuid.UUID, time.Duration) (store.MaintenanceLease, bool, error)
	RenewMaintenanceLease(context.Context, store.MaintenanceLease, time.Duration) (store.MaintenanceLease, bool, error)
	ReleaseMaintenanceLease(context.Context, store.MaintenanceLease) (bool, error)
	RunMaintenanceBatch(context.Context, store.MaintenanceLease, func(context.Context) (int64, bool, error)) (int64, bool, bool, error)
}

type Metrics interface {
	ObserveMaintenanceLease(outcome string)
	SetMaintenanceLeader(leader bool)
	ObserveMaintenanceRun(job, outcome string, duration time.Duration, rows int64)
}