Extract a field value from a JSON object using a path Supports nested fields like "status.phase" or "metadata.namespace"

Extract metadata from a resource

Extract the resource type from the request URI. For namespaced resources, the URI looks like: /api/v1/namespaces/{ns}/{resource}/{name}/status /apis/

Format CPU millicores to string

Format memory bytes to string

Forward a request to an aggregated APIService backend. Preserves the request's path and query string. Forwards `Accept`, `Content-Type`, and imperson

Generate the OpenAPI v3 specification for the Kubernetes API

Get detailed status of all containers in a pod Get statuses for ephemeral containers in a pod.

Get TTL seconds from Job spec

Check if this is an empty selector

Load all network configurations from the config directory

Helper: create an unscheduled pod (the incoming pod wanting resources)

Build a deterministic `ObjectMeta` from a name + optional labels. Avoids `ObjectMeta::new()` which calls `Uuid::new_v4()` + `Utc::now()`.

Build a minimal pod with explicit phase and (optionally) ownerReferences. Uses a stable UID so the stored JSON is deterministic across calls.

Check if a pod affinity term matches For affinity (is_affinity=true): returns true if matching pods exist on node's topology For anti-affinity (is_aff

Parse memory string to bytes (e.g., "1Gi" -> 1073741824, "512Mi" -> 536870912)

Parse resource quantity (helper method) Handles K8s resource formats: CPU: "100m" (millicores), "0.5" or "1.5" (decimal cores), "2" (whole cores) Memo

Calculate percentile of sorted data

Get the primary IP address (first IP in the list)

Read the last N lines of container logs (for FallbackToLogsOnError)

Reconcile a single service

Refresh `pod.status.init_container_statuses` in storage from the live Docker state. Called between init container actions so watches observe each tran

Derive the Kind and apiVersion from resource_type and api_group

Run one scheduling cycle — schedules all pending pods. Public for testing.

Select pods for eviction based on resource pressure

Check if a Job should be cleaned up

Sort a vector of serializable items by a JSONPath expression

Start a mock mutating webhook server whose label value reflects the call count. Used to verify reinvocation: the second invocation returns a different

Recursively strip default/empty values from a CRD JSON schema to match K8s Go's omitempty behavior. Go omitempty skips false booleans, empty strings,

Write data to a specific channel

Add operation - adds a value at the specified path

Check if the Accept header SPECIFICALLY requests aggregated discovery format. Only return aggregated format if the client explicitly prefers it (i.e.,

Allocate a ClusterIP from the service CIDR range

Allocate a random NodePort in the range 30000-32767

Allocate a NodePort from the available range

Apply JSON Merge Patch (RFC 7386) Rules: - If patch is not an object, replace original with patch - If patch is an object: - For each key in patch: -

Apply K8s defaults to a Probe. Matches SetDefaults_Probe from pkg/apis/core/v1/defaults.go

Convert historical events + a broadcast receiver into a WatchStream. Historical events are replayed first (in order), then live events follow.

Build routes for a CRD This creates the router configuration that should be registered when a CRD is created

Build PromQL query for a specific object

Build the set of HTTP headers the aggregator forwards on a proxied request. Returns a deterministic (sorted) list of `(name, value)` pairs: `X-Remote

Build webhook URL from client config

Calculate desired replica count based on metrics Implements the HPA algorithm: desiredReplicas = ceil[currentReplicas * (currentMetricValue / targetMe

Helper function to capitalize the first letter of a string

Check pod affinity requirements Returns (passes_hard_requirements, score)

Check pod anti-affinity requirements Returns (passes_hard_requirements, score_penalty)

Check if policy rules allow the requested action

Check if pod tolerates all node taints

Check topology spread constraints for a pod Returns (passes_hard_constraints, score_penalty)

Clear all probe states for a given pod (e.g., on restart or deletion).

Compute the desired healthy count from a PDB spec

Count pods that are Ready for a given ReplicaSet

Helper: create a CRD with a schema that has default values

Create SPDY upgrade response

Helper function to create test ClusterRole

Attempt to decode a K8s protobuf body into JSON. The K8s Unknown message wraps: field 1 = TypeMeta, field 2 = raw object (protobuf). We extract TypeMe