OnlyOneIsNil returns true if only one of the Objects is nil else it will return false.

PreparePod adds scheduler-backend-specific configuration to the given Pod object prior to its creation (schedulerName, annotations, etc.).

ResolveTemplateSpec resolves a ResourceSharingSpec to its ResourceClaimTemplateSpec. Resolution order: internal PCS-level resourceClaimTemplates first

ScalePCSG scales a PodCliqueScalingGroup to the specified replica count.

Sync creates or patches PCS-level ResourceClaims (AllReplicas + PerReplica) and cleans up stale RCs from previous scale-in operations.

Sync creates or patches PCLQ-level ResourceClaims (AllReplicas + PerReplica) and cleans up stale PerReplica RCs from previous scale-in operations. The

SynchronizeTopology synchronizes scheduler-specific topology resources at operator startup. Lists all existing ClusterTopologyBinding resources and en

VerifyPodsArePendingWithUnschedulableEvents verifies that pods are pending with Unschedulable events.

WaitForPodCountAndPhases waits for pods to reach specific total count and phase counts.

WithPodSpec sets a custom PodSpec for the PodCliqueTemplateSpec.

WithPollInterval sets the milestone polling interval.

buildHierarchyViolationMsg generates an error message when a parent constraint is narrower than a child constraint.

createValidPCSWithCliqueAnnotations creates a fully valid PCS with clique-level annotations for testing spec-level validation.

deletePodAndWaitForTermination deletes a pod and waits until it is fully terminated.

getEvents returns a copy of all recorded events

getPodCliqueSelectorLabels returns labels for selecting all PodCliques of a PodCliqueSet.

Helper function to get pods by clique name pattern.

Helper function to check if an env var exists in a slice

hasHierarchyViolation reports whether the parent domain is narrower than the child domain, which violates the constraint hierarchy. Returns false when

newPCLQ returns a PCLQ object with the standard labels expected by the component.

Test helper functions

resolvePodViaEndpoints returns the name of the first ready pod backing the given service, using the Endpoints API (returns only Ready pods from Subset

Run a shell command, streaming output unless *capture* is True.

Convert various value types to boolean.

verifyPodState waits for the expected pod count and verifies RC references in pod specs.

Build creates a test client.Client with the configured reactions to errors.

CheckTopologyDrift compares the scheduler-specific topology resource named by ref.TopologyReference against the ClusterTopologyBinding's levels. Retur

ClusterTopologyBindings returns a ClusterTopologyBindingInformer.

ComputeHash computes a hash given one or more corev1.PodTemplateSpec.

CreateClusterTopology creates a ClusterTopologyBinding CR with the given name and levels.

FilterPodsByLabel filters pods by a specific label key-value pair.

FindPCSGConfig finds the matching PodCliqueScalingGroupConfig for a given PCSG from the PCS template.

GetCreateExpectations is a convenience method which gives a slice of resource UIDs for which creation has not yet been synced in the informer cache.

GetDeleteExpectations is a convenience method which gives a slice of resource UIDs for which deletion has not yet been synced in the informer cache.

GetPodGangSelectorLabels creates the label selector to list all the PodGangs for a PodCliqueSet.

Init provides a hook to initialize/setup one-time scheduler resources, called at the startup of grove operator.

InjectResourceClaimRefs appends ResourceClaim references to a PodSpec for entries that match the given scope and filter. It adds both the pod-level cl

Matches matches the errorType to the passed field.ErrorList

NewExpectationsStore creates a new expectations store.

NewHandler creates a new handler for the auhtorizer webhook.

PodCliqueScalingGroups returns a PodCliqueScalingGroupInformer.

PodCliqueSets returns a PodCliqueSetInformer.

PodCliques returns a PodCliqueInformer.

PodGangs returns a PodGangInformer.

QueryPrefix returns the Pyroscope metric selector prefix for this profile type. Single source of truth — switch-based, not a mutable package-level map

RecordErrorForObjectsMatchingLabels records an error for a specific client.Client method and object keys matching the given labels for a given GVK.

ReferencedDomains returns the unique required and preferred domains referenced by the constraint.

RegisterWithManager registers the backend controller with the manager

RegisterWithManager registers the webhook with the manager.

RemoveAndPatchFinalizer uses merge-patch strategy to patch the given object thereby resulting in removal of the given finalizer.

ResourceClaimLabels returns the standard Grove labels for a ResourceClaim owned by a PCS.

SyncPodGang synchronizes (creates/updates) scheduler-specific resources for a PodGang reacting to a creation or update of a PodGang resource.

UncordonNode marks a node as schedulable.

V1alpha1 provides access to shared informers for resources in V1alpha1.

WaitForKAITopology polls until the KAI Topology exists with the expected level keys and owner reference.

WaitForPCSCondition polls until the PodCliqueSet has a condition matching the expected type, status, and reason.

WaitForPodConditions polls until the expected pod state is reached.

addEnvironmentVariables adds Grove-specific environment variables to all containers and init-containers.

buildFakeClient creates a fake client with apiextensionsv1 scheme registered.

createTestCDs creates a slice of test ComputeDomains with proper labels and finalizers.

createTestClient creates a test client with testScheme that supports ComputeDomain operations.

createTestClusterTopology creates a ClusterTopologyBinding with the given name and topology levels.

createTopologyPackConstraint creates a TopologyPackConstraint based on the sync context and provided parameters for a resource. PackConstraints are de

Safely traverse the DEPENDENCIES dict by key path. Args: *keys: Sequence of dictionary keys to traverse. default: Value to return

extractIndexFromHostname extracts the numeric index from a pod hostname.

extractUsedIndices extracts and validates indices from existing pods.

findAvailableIndices finds the next count available indices starting from 0.

getFirstPodForClique returns the name of the first pod belonging to the specified clique.

---------------------------------- Helper methods ----------------------------------

makePCSWithTopology creates a minimal PCS with an optional topology constraint.

mapBackendTopologyToCT returns a MapFunc that maps a backend topology resource event to the ClusterTopologyBinding that should be reconciled. For aut

pcsgScaleOutRCNames: sga 1→3. Total: 14 RCs.

Common condition builders

Run a command and log a warning if it fails (instead of raising).

scalePCS scales a PCS to the specified number of replicas

setSchedulerTopologyDriftCondition sets the SchedulerTopologyDrift condition on the ClusterTopologyBinding based on the aggregated scheduler topology

============================================================================ RollingRecreate strategy utilities ======================================

validateQueueExistsAndIsOpen verifies that the resolved Volcano queue exists in the cluster and that its status is Open before admitting the workload.

verifyComputeDomainContent verifies that a ComputeDomain exists with correct metadata and spec.

verifyPodCliqueStartupOrder combines pod fetching, filtering, count verification, and startup order verification.

AddEnvVarsToContainers adds the given environment variables to the Pod containers.