Versions in this module Expand all Collapse all v0 v0.6.0 Oct 30, 2026 Changes in this version + type ArtifactStore interface + Delete func(ctx context.Context, prefix string) error + Get func(ctx context.Context, key string) (io.ReadCloser, error) + Preflight func(ctx context.Context, requiredBytes int64) error + Put func(ctx context.Context, key string, r io.Reader) (PutResult, error) + Stat func(ctx context.Context, key string) (int64, string, error) + type BackupRepository interface + AddArtifact func(ctx context.Context, a *domain.Artifact) error + CreateRestore func(ctx context.Context, run *domain.RestoreRun) error + CreateRun func(ctx context.Context, run *domain.BackupRun) error + DeleteArtifacts func(ctx context.Context, backupRunID string) error + GetRestore func(ctx context.Context, id string) (*domain.RestoreRun, error) + GetRun func(ctx context.Context, id string) (*domain.BackupRun, error) + ListArtifacts func(ctx context.Context, backupRunID string) ([]*domain.Artifact, error) + ListRuns func(ctx context.Context, orgID string, limit int) ([]*domain.BackupRun, error) + ListRunsBySet func(ctx context.Context, setID string) ([]*domain.BackupRun, error) + ListSummaries func(ctx context.Context, orgID string) ([]domain.RunSummary, error) + UpdateRestore func(ctx context.Context, run *domain.RestoreRun) error + UpdateRun func(ctx context.Context, run *domain.BackupRun) error + type ConnectionResetter interface + Reset func() + type DBDumper interface + Dump func(ctx context.Context, target DBTarget, out io.Writer) (DumpResult, error) + Restore func(ctx context.Context, target DBTarget, in io.Reader) error + SchemaState func(ctx context.Context, target DBTarget) (domain.SchemaState, error) + ServerVersion func(ctx context.Context, target DBTarget) (string, error) + type DBTarget struct + Component domain.Component + Database string + Host string + Password string + Port int + PreserveTables []string + User string + type DumpResult struct + BytesWritten int64 + ClientVersion string + type GatewayAliasRepinner interface + RepinGatewayAliases func(ctx context.Context, stackID, namespace string, kubeconfig []byte) (gatewayIP string, updated []string, err error) + type HelmReleaseLister interface + ListHelmReleases func(ctx context.Context, namespace string) ([]domain.HelmReleaseSpec, error) + type KVExportResult struct + Bytes int64 + PathCount int + type KVExporter interface + Export func(ctx context.Context, stackID string, out io.Writer) (KVExportResult, error) + Import func(ctx context.Context, stackID string, in io.Reader) error + PathExists func(ctx context.Context, stackID, path string) (bool, error) + type NamespaceEnsurer interface + EnsureNamespace func(ctx context.Context, namespace, restoredFromBackupID string) error + type Notifier interface + NotifyBackupResult func(ctx context.Context, run *domain.BackupRun) error + type OrganizationChecker interface + OrganizationExists func(ctx context.Context, orgID string) (bool, error) + type PutResult struct + Bytes int64 + ChecksumSHA256 string + Location string + type ResourceDumper interface + Apply func(ctx context.Context, namespace string, in io.Reader) error + Dump func(ctx context.Context, namespace string, out io.Writer) (int64, error) + type Sealer interface + KeyID func() string + Seal func(ctx context.Context, plaintext io.Reader, out io.Writer) error + Unseal func(ctx context.Context, ciphertext io.Reader, out io.Writer) error + type SharedComponentsEnsurer interface + EnsureSharedComponents func(ctx context.Context, kubeconfig []byte, namespace string) (steps []string, warnings []string, err error) + type SharedResourceDumper interface + ApplyShared func(ctx context.Context, in io.Reader) error + ApplySharedSecrets func(ctx context.Context, in io.Reader) error + DumpShared func(ctx context.Context, out io.Writer) (int64, error) + type StackLister interface + ListCompletedStacks func(ctx context.Context, orgID string) ([]domain.StackRef, error) + type TokenSourceLister interface + ListPaths func(ctx context.Context, orgID string) ([]TokenSourceRef, error) + type TokenSourceRef struct + ID string + Path string + type VolumeArchiver interface + Archive func(ctx context.Context, namespace, pvc string, out io.Writer) (int64, error) + EnsurePVC func(ctx context.Context, namespace string, spec domain.VolumeSpec, ...) error + ListPVCs func(ctx context.Context, namespace string) ([]domain.VolumeSpec, error) + Restore func(ctx context.Context, namespace, pvc string, in io.Reader) error + type WorkloadScaler interface + List func(ctx context.Context, namespace string) ([]domain.Workload, error) + Scale func(ctx context.Context, w domain.QuiesceTarget, replicas int32) error + WaitStopped func(ctx context.Context, namespace string, targets []domain.QuiesceTarget) error