Info logs an info message

Errorf logs a formatted error message

Run executes all defined phases in order and returns the complete result. metadata is embedded in the result for correlation with operator settings.

Build builds and returns the Pod.

Get returns the backend registered under name, or nil if not found. An empty name returns nil; use GetOrDefault for empty-falls-back-to-default behavi

Len returns the length of the DeletionSorter

WithScheme sets the scheme used by the delegating fake client.

WithObjects initializes the delegating fake client builder with objects.

WithReplicas sets the number of replicas for the PodClique. Default is set to 1.

Debugf logs a formatted debug message

Infof logs a formatted info message

List lists all PodCliques in the indexer. Objects returned here must be treated as read-only.

Error logs an error message

WithTimeout sets the polling timeout.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

WithOptions applies option functions to customize the PodClique.

Delete triggers the deletion of all resources that this Operator manages.

WithInterval sets the polling interval.

Has returns true if the set contains value. The Set type uses a sentinel struct{} value, so callers cannot use the comma-ok idiom directly; this metho

WithPodCliqueTemplateSpec sets the PodCliqueTemplateSpec for the PodCliqueSet. Consumers can use PodCliqueBuilder to create a PodCliqueTemplateSpec an

createTestPodCliqueSet creates a basic PodCliqueSet for testing.

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Server.

WithPodCliqueSetGenerationHash sets the CurrentGenerationHash in the PodCliqueSet status.

createPodWithHash creates a test pod with the specified template hash label

HasErrors returns true if there are errors from the reconcile step.

UncordonNodes uncordons multiple nodes.

createDummyPodCliqueTemplate creates a basic PodCliqueTemplateSpec for testing.

Register registers a components operator against the kind of components it operates on.

WithStatusSubresource registers types that have status subresources so that Status().Patch() works with the fake client.

WithMinAvailable sets the MinAvailable field for the PodCliqueScalingGroup.

GetLabelSelector returns the label selector for the current workload.

WaitForPods waits for the expected pod count to be ready.

WithRoleName sets the RoleName for the PodCliqueTemplateSpec.

DeployAndVerifyWorkload applies a workload YAML and waits for the expected pod count.

String returns a human-readable representation of the config

get returns the cached label selector, parsing it on first call.

GetAggregatedError returns all task errors joined into a single error.

ListPods lists pods matching the current workload's label selector.

Sync synchronizes all resources that this Operator manages. If a component does not exist then it will create it. If there are changes in the owning P

WaitUntil polls fetchFn at the configured interval and checks predicate. Unlike WaitFor, it discards the fetched value and only returns an error.

==================== Test Utilities ====================

Debug logs a debug message

WithCliqueStartupType sets the StartupType for the PodCliqueSet.

createPCSWithCliques creates a PCS with per-clique annotations.

AddPhase registers a phase definition for later execution.

PreferredDomain returns the preferred pack domain.

WithOwnerReference sets the owner reference for the PodClique from individual values.

WithScalingGroup adds a scaling group with the specified cliques.

VerifyPodGroupTopology verifies both top-level topology constraint and SubGroups structure.

createPCSWithGPU creates a PCS with GPU using the builder for tests in this package.

GetOperator gets a components operator that operates on the given kind.

RequiredDomain returns the required pack domain, falling back to legacy packDomain.

WaitFor polls fetchFn at the configured interval and checks predicate. Returns the final T on success, or zero T + error on timeout/fetch failure.

WaitForReadyPods waits for a specific number of pods to be ready.

WithTerminationDelay sets the TerminationDelay for the PodCliqueSet.

Result returns the result and error from the reconcile step.

ensureGroveTopology creates the shared "grove-topology" ClusterTopologyBinding if it does not already exist. TAS1-TAS16 all reference this topology; T

---------------------------- validate create of PodCliqueSet ----------------------------------------------- validate validates the PodCliqueSet objec

GetExistingResourceNames returns the names of all the existing resources that this Operator manages.

GetPodGroupOrFail retrieves a PodGroup for the specified PCS replica or fails the test.

WithRetryOnError causes fetch/condition errors to be retried instead of causing immediate failure. Errors are logged (if a logger is set) and polling

createValidPCSWithGPU creates a fully valid PCS with GPU and PCS-level annotations.

setupTest initializes an update strategy test with the given configuration. It handles: 1. Cluster preparation with required worker nodes 2. TestConte

Name is a unique name of the scheduler backend.

VerifyPodsInSameTopologyDomain verifies that all pods are in the same topology domain.

triggerPodCliqueUpdate triggers an update by adding/updating an environment variable in a PodClique. Uses tc.Workload.Name as the PCS name.

write writes a formatted string to the underlying writer, short-circuiting if a previous write already failed.

DeployWorkloadAndGetPods deploys workload, waits for pods to be ready, and returns the pod list

GetSummary returns a summary of successful, failed, and skipped tasks.

WithStandaloneClique adds a standalone clique (not part of any scaling group).

createPCSWithPCSGConfigAnnotations creates a PCS with a single PCSG config carrying the given annotations.

newTopologyConstraintsValidatorV2 creates a new topologyConstraintsValidator for the given PodCliqueSet.

emptyComputeDomain creates an empty ComputeDomain with only metadata set. We use unstructured.Unstructured instead of typed structs to avoid a compile

newPCSValidator creates a new PodCliqueSet validator for the given operation. schedulerConfig is the full scheduler configuration; the validator uses

stop stops the watcher and cleans up resources

FilterMatches checks whether the PCSG filter allows injection for the given names. When Filter is nil or no matchNames are provided, all children matc

NeedsRequeue returns true if the reconcile step needs to be requeued. This will happen if there is an error or if the result is marked to be requeued.

Warnf logs a formatted warning message

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

ListPodsAndAssertDistinctNodes lists pods and asserts they are on distinct nodes.

New creates a Waiter with default timeout and interval.

SetupAndCordonNodes retrieves worker nodes and cordons the specified number.

WaitForPodPhases waits for pods to reach specific running and pending counts.

WaitForRunningPods waits for a specific number of pods to be in Running phase.

WithUpdateStrategy sets the UpdateStrategy for the PodCliqueSet.