backup

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

type Deps struct {
	Store   store.Store
	Secrets SecretReader
	// Sources are what a Backup copies; KV loads and empties a KVStore; Purger empties a Bucket.
	Sources workload.Sources
	KV      KVLoader
	Purger  gc.BucketPurger
	// Hold nil is a platform never held, whose in-place Restore holds nothing.
	Hold Hold
	// StoreURL is the blob store's URL, blob.target or the file:// URL of blob.dir: a schedule on its provider is
	// Ready with reason SameProvider (Decision 6). "" compares with nothing.
	StoreURL string
	// Period re-checks a schedule at the latest after it, the namespace hold's release enqueuing nothing, and paces a
	// Backup waiting on the platform hold; 0 ⇒ controller.SupervisionPeriod.
	Period time.Duration
	Clock  clock.Clock
	Meter  metric.Meter
	Logger *slog.Logger
}

type Hold interface {
	hold.Gate
	hold.NamespaceGate
	HoldNamespace(ns v1.NamespaceName, m hold.Marker) error
	ReleaseNamespaceMarker(ns v1.NamespaceName, m hold.Marker) error
}

type KVLoader interface {
	LoadPrefix(ctx context.Context, prefix string, next func() (snapshot.Record, error)) error
	DropPrefix(prefix string) error
	List(ctx context.Context, prefix string) ([]string, error)
}

type Reconcilers struct {
	Schedules *ScheduleReconciler
	Backups   *BackupReconciler
	Restores  *RestoreReconciler
}

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

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

type SecretReader interface {
	ResolveEnv(ctx context.Context, id auth.Identity, ns v1.NamespaceName, names []string) (map[string]string, error)
}