Versions in this module Expand all Collapse all v0 v0.6.0 Oct 30, 2026 Changes in this version + const DefaultHelperImage + type Adapters struct + Archiver *VolumeArchiver + Kubeconfig []byte + Namespaces *NamespaceEnsurer + Releases *HelmReleaseReader + Resources *ResourceDumper + Scaler *WorkloadScaler + func NewAdapters(kubeconfig []byte, helperImage string) (*Adapters, error) + type HelmReleaseReader struct + func NewHelmReleaseReader(client kubernetes.Interface) *HelmReleaseReader + func (r *HelmReleaseReader) ListHelmReleases(ctx context.Context, namespace string) ([]domain.HelmReleaseSpec, error) + type NamespaceEnsurer struct + func NewNamespaceEnsurer(client kubernetes.Interface) *NamespaceEnsurer + func (e *NamespaceEnsurer) EnsureNamespace(ctx context.Context, namespace, restoredFromBackupID string) error + type ResourceDumper struct + func NewResourceDumper(kubeconfig []byte) *ResourceDumper + func (d *ResourceDumper) Apply(ctx context.Context, namespace string, in io.Reader) error + func (d *ResourceDumper) ApplyShared(ctx context.Context, in io.Reader) error + func (d *ResourceDumper) ApplySharedSecrets(ctx context.Context, in io.Reader) error + func (d *ResourceDumper) Dump(ctx context.Context, namespace string, out io.Writer) (int64, error) + func (d *ResourceDumper) DumpShared(ctx context.Context, out io.Writer) (int64, error) + type VolumeArchiver struct + func NewVolumeArchiver(client kubernetes.Interface, cfg *rest.Config, image string) *VolumeArchiver + func (a *VolumeArchiver) Archive(ctx context.Context, namespace, pvc string, out io.Writer) (int64, error) + func (a *VolumeArchiver) EnsurePVC(ctx context.Context, namespace string, spec domain.VolumeSpec, ...) error + func (a *VolumeArchiver) ListPVCs(ctx context.Context, namespace string) ([]domain.VolumeSpec, error) + func (a *VolumeArchiver) Restore(ctx context.Context, namespace, pvc string, in io.Reader) error + type WorkloadScaler struct + func NewWorkloadScaler(client kubernetes.Interface) *WorkloadScaler + func (s *WorkloadScaler) List(ctx context.Context, namespace string) ([]domain.Workload, error) + func (s *WorkloadScaler) Scale(ctx context.Context, t domain.QuiesceTarget, replicas int32) error + func (s *WorkloadScaler) WaitStopped(ctx context.Context, namespace string, targets []domain.QuiesceTarget) error
Go to main page