k8sbackup

type Clients struct {
	Discovery discovery.DiscoveryInterface
	Dynamic   dynamic.Interface
	Core      kubernetes.Interface
}

type DBBackupOutcome struct {
	Result *temporal.BackupExecutionResult
	// State is the chain state to persist for the next run (nil when unchanged)
	State *dbspec.JobState
	// Precheck marks a configuration/environment failure a retry cannot fix
	Precheck bool
}

type DBBackupRequest struct {
	Namespace string
	// BackupID is the PBS group (used for the deterministic pod name)
	BackupID string
	RunID    string
	AgentID  string
	Timeout  time.Duration
	Worker   DBWorkerConfig
	Progress func(phase string)
}

type DBWorkerConfig struct {
	// Image is the engine's client-tools image (postgres:17, mariadb:11, mongo:7, …)
	Image string
	// AgentImage supplies the fallbck-k8s-agent binary through an init container
	AgentImage      string
	ImagePullPolicy string
	// Resources / SecurityContext are corev1 JSON blobs from the Helm chart (optional)
	ResourcesJSON       string
	SecurityContextJSON string
	// SpoolSizeLimit bounds the spool emptyDir (Kubernetes quantity; "" = unbounded)
	SpoolSizeLimit string
	// Env carries the worker credentials, session and previous state
	Env []corev1.EnvVar
}

type DumpStats struct {
	Counts       map[string]int
	Excluded     []string
	FailedGroups []string
	Namespaces   []string
	Warnings     []string
}

type VolumeBackupRequest struct {
	Plan              spec.VolumePlan
	RunID             string
	AgentID           string
	SnapshotTimeout   time.Duration
	VolumeTimeout     time.Duration
	AllowLiveFallback bool
	Worker            WorkerConfig
	Progress          func(phase string)
}

type WorkerConfig struct {
	Image string
	// ImagePullPolicy for worker pods (default IfNotPresent; ":latest" would otherwise
	// imply Always and break air-gapped/preloaded images)
	ImagePullPolicy string
	// Resources / SecurityContext are corev1 JSON blobs from the Helm chart (optional)
	ResourcesJSON       string
	SecurityContextJSON string
	// Env carries the worker credentials and session (built by the activity)
	Env []corev1.EnvVar
}