controllers

type AutoscalerToPDBReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Filter filter
}

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

type DeploymentToPDBReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
	Filter   filter
}

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

type EvictionAutoScalerReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
	Filter   filter
	// ZeroSurgeOverride lets the controller surge a workload whose maxSurge
	// resolves to 0 — an explicit maxSurge: 0 (common under safe-deployment
	// guidance) or a Recreate strategy — which otherwise cannot surge and
	// would degrade. Note: an unset RollingUpdate strategy is NOT treated as
	// zero — Kubernetes defaults it to 25% at admission time, and GetMaxSurge
	// returns that default. When non-nil, its value is applied as the drain surge for such
	// workloads: an int-or-percentage resolved against minReplicas, mirroring
	// Kubernetes' own maxSurge semantics — e.g. "25%" (rounded up) or an absolute
	// "10". The actual surge stays demand-driven (minReplicas + displaced) and is
	// capped at this amount, so larger drains proceed in waves. It is a fleet-wide,
	// install-time knob (the ZERO_SURGE_OVERRIDE controller env var); nil (the
	// default) preserves today's degrade-on-zero behavior, so Cosmic — not
	// individual workload owners — decides whether it applies.
	ZeroSurgeOverride *intstr.IntOrString
	// PDBFloorMutationEnabled is the master switch for the PDB-floor pinning feature.
	// It ships OFF (dormant) and is wired from the ENABLE_PDB_FLOOR_MUTATION controller
	// env var at startup (main.go). Held as a per-reconciler field (not a package var)
	// so config is declared at construction and tests set it per instance.
	PDBFloorMutationEnabled bool
}

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

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

type NodeReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

type PDBToEvictionAutoScalerReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
	Filter   filter
}

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

type SurgeApplier interface {
	// ApplySurge sets the minimum replica count to surgeReplicas.
	// Callers may invoke this multiple times; implementations must be idempotent.
	ApplySurge(ctx context.Context, surgeReplicas int32) error
	// RevertSurge restores the original minimum replica count.
	RevertSurge(ctx context.Context, originalMinReplicas int32) error
	// IsSurgeActive returns true if a surge is currently in progress on the target.
	// Used during generation tracking to distinguish our own scaling from external changes.
	IsSurgeActive() bool
	// RecordedSurge returns the replica count recorded by the last ApplySurge (from the
	// evictionSurgeReplicas annotation) and whether it is present. Used by the
	// bail-on-replica-change guard to detect an external replica edit mid-surge.
	RecordedSurge() (int32, bool)
	// RecordedBaseline returns the pre-surge baseline recorded by ApplySurge (from the
	// original-min-replicas annotation) and whether it is present. Used to recover the
	// true baseline for an EvictionAutoScaler that lost its Status.MinReplicas (e.g. a
	// freshly recreated CR that started at 0 while a surge was already active).
	RecordedBaseline() (int32, bool)
	// Name returns a human-readable name for logging
	Name() string
}

type Surger interface {
	//GetGeneration() int64
	GetReplicas() int32
	// ReadyReplicas returns the number of currently Ready pods (status.readyReplicas), used to
	// measure how much of a requested surge has actually materialized (pods scheduled once the
	// Cluster Autoscaler brings up nodes), as opposed to the desired spec.replicas.
	ReadyReplicas() int32
	SetReplicas(int32)
	GetMaxSurge() intstr.IntOrString
	Obj() client.Object
	//Update(ctx context.Context, obj Object, opts ...UpdateOption) error
	AddAnnotation(string, string)
	RemoveAnnotation(string)
}