backup

type Handler ¶

type Handler struct {
	Svc *instance.Service
}

Handler runs "backup" jobs by delegating to instance.Service.Backup.

func (h *Handler) Run(ctx context.Context, job store.Job, jc *jobs.JobContext) error

type LocalDir ¶

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

LocalDir is the OSS BlobStore: blobs are plain files under a root directory, written via temp-file + rename so a partial write is never visible as a complete blob.

A process crash mid-write can leave a .tmp-* file behind. Because the temp file lives inside the blob's key-prefix directory, a DeleteAll call on that prefix (e.g. to clean up a failed backup) reclaims it automatically.

func NewLocalDir(root string) (*LocalDir, error)

func (l *LocalDir) DeleteAll(_ context.Context, prefix string) error

func (l *LocalDir) Get(_ context.Context, key string) (io.ReadCloser, error)

func (l *LocalDir) Put(_ context.Context, key string) (instance.BlobWriter, error)

type Reconciler ¶

type Reconciler struct {
	Svc *instance.Service
}

Reconciler recovers "backup" jobs interrupted by a daemon restart: the backup row is failed (unless the work actually completed), partial blobs are deleted, and the instance is restarted.

func (r *Reconciler) Reconcile(ctx context.Context, job store.Job, jc *jobs.JobContext) (store.JobState, string, bool, error)

type RestoreHandler ¶

type RestoreHandler struct {
	Svc *instance.Service
}

RestoreHandler runs "restore" jobs by delegating to instance.Service.Restore.

restore has no reconciler on purpose: an interrupted restore is resolved by boot recovery failing the job, and the operator re-running the restore — which is idempotent from the blob (it re-does teardown + import + verify).

func (h *RestoreHandler) Run(ctx context.Context, job store.Job, jc *jobs.JobContext) error