Helper function to build resource keys

Check if storage is empty

Get the number of stored items

Helper function to build prefix for listing

Check if a request is a dry-run request Returns true if the dryRun query parameter is set to "All"

Apply both field and label selector filtering to a list of resources. Serializes each resource to JSON at most once (instead of twice when field and

Check if this is an empty selector

Handle deletion of a resource that may have finalizers. This function implements the Kubernetes finalizer protocol: 1. If the resource has finalizers

Ensure uid is populated (generate if empty). Also resolves generateName if name is empty.

Get the next key to process. Blocks until a key is available or the queue is shut down. Returns `None` on shutdown.

Ensure creation timestamp is set

Add a key to the queue. If the key is already queued or being processed, this is a no-op (deduplication).

Mark a key as done processing. Must be called after `get()`. If the key was re-added via `add()` while being processed, it will be re-queued — either

Clear the failure counter for a key. Called after successful reconciliation.

Normalize a resourceVersion value: treat empty string as None (= "start from current")

Parse a label selector string Format supports both equality-based and set-based selectors: - Equality: key=value, key==value, key!=value - Set-based:

Execute config commands for kubeconfig management

Copy files between local filesystem and containers

Get a list of resources, automatically unwrapping the Kubernetes List wrapper

Re-queue a key with exponential backoff. Called when reconciliation fails. Increments the failure counter and delays the re-queue.

Compute the API path for a given resource kind, apiVersion, namespace, and name. Returns the full path including the resource name (for PUT requests).

Create a success Status response

Add a JSON value as a variable (converts to CEL Value)

Create a test pod with specified requirements

Map resource type to Kind and apiVersion for TypeMeta injection.

Create a test node with specified labels and resources

Helper function to create a test service

Encode frame to bytes Format: [channel_id: 1 byte][data_length: 4 bytes, big-endian][data: N bytes]

Scan all resources and collect orphans

Runs the four-step roundtrip check for a single fixture and returns the decoded value so callers can perform additional field-level assertions.

Clear all data (useful for test cleanup)

Helper function to create a test lease with basic configuration

Read a varint from data starting at pos. Returns (value, new_pos).

Resolve an API path for a resource type and name.

Resolve the API path for a resource type/name.

Helper function to create a test cronjob

Helper function to create test Event

Helper function to create a test replicationcontroller

Helper function to create a test csidriver with basic configuration

Helper function to create a test priorityclass with basic configuration

Helper function to create a test persistent volume

Helper function to create a test persistent volume claim

Helper function to create a test serviceaccount

Helper function to create a test storage class

Check if a query param map indicates a watch request

Convert query parameters to WatchParams

Helper function to create a test csinode with basic configuration

Helper function to create a test networkpolicy with basic pod selector

Helper function to create a test poddisruptionbudget with minAvailable

Helper function to create a test runtimeclass with basic configuration

Helper function to create a test job

Helper function to create a test secret

Helper function to create a test volumesnapshot from a PVC

Helper function to create a test ingressclass with basic configuration

Helper function to create a test replicaset

Helper function to create a test statefulset