Functions — github.com/calfonso/rusternetes

hub / github.com/calfonso/rusternetes / functions

Functions6,481 in github.com/calfonso/rusternetes

⨍ Functions 6,481◇ Types & classes 991

↓ 5 callersFunctionfixup_init_container_ready

Apply the K8s init container ready fixup rule. K8s prober_manager.go:377: for non-restartable init containers, if terminated with exit_code=0, set rea

crates/kubelet/tests/kubelet_lifecycle_test.rs:158

↓ 5 callersFunctionformat_duration

(duration: chrono::Duration)

crates/kubectl/src/commands/describe.rs:39

↓ 5 callersFunctionformat_labels

Format labels as a comma-separated string for --show-labels output

crates/kubectl/src/commands/get.rs:231

↓ 5 callersMethodgather

Get metrics in Prometheus text format

crates/common/src/observability.rs:323

↓ 5 callersMethodget

(&self, path: &str)

crates/kubectl/tests/mock_client_example.rs:25

↓ 5 callersMethodget_cached

Get a cached value if it exists and is not expired

crates/api-server/src/prometheus_client.rs:316

↓ 5 callersMethodget_container_resource_value

Get a container resource value for DownwardAPI Returns the resource value formatted according to the divisor. For memory: returns bytes (or bytes/div

crates/kubelet/src/runtime.rs:7592

↓ 5 callersFunctionget_event_time

(event: &Value)

crates/kubectl/src/commands/events.rs:275

↓ 5 callersMethodget_pod_field_value

Get a pod field value for DownwardAPI

crates/kubelet/src/runtime.rs:7490

↓ 5 callersMethodget_pod_priority_sync

Get the priority value for a pod (synchronous version using pre-loaded PriorityClasses) If pod.spec.priority is set, use it directly Otherwise, look u

crates/scheduler/src/scheduler.rs:1196

↓ 5 callersMethodget_ws_url

Convert HTTP(S) base URL to WebSocket URL for streaming endpoints

crates/kubectl/src/client.rs:306

↓ 5 callersMethodis_leader

Check if this instance is the leader

crates/common/src/leader_election.rs:84

↓ 5 callersFunctionk8sPatch

( apiPath: string, patch: unknown, contentType = "application/strategic-merge-patch+json", )

console/src/engine/query.ts:103

↓ 5 callersMethodlb_name

Generate load balancer name from service

crates/cloud-providers/src/aws.rs:83

↓ 5 callersMethodlock_allocated

Lock the allocated-IP set, recovering from poison rather than panicking. A panic in another thread shouldn't lock out all future ClusterIP allocation.

crates/api-server/src/ip_allocator.rs:19

↓ 5 callersFunctionmake_endpointslice_map

( namespace: &str, service: &str, endpoints: &[(&str, Option<&str>, u16)], )

crates/kube-proxy/src/iptables.rs:1913

↓ 5 callersFunctionmake_job

(name: &str, namespace: &str, uid: &str)

crates/controller-manager/src/controllers/cascade_tests.rs:171

↓ 5 callersFunctionmake_labels

(pairs: &[(&str, &str)])

crates/controller-manager/src/controllers/replicaset.rs:734

↓ 5 callersFunctionmake_limit_range

( default_cpu: Option<&str>, default_request_cpu: Option<&str>, min_cpu: Option<&str>,

crates/api-server/src/admission.rs:1351

↓ 5 callersFunctionmake_pod

(name: &str, namespace: &str, phase: Phase, job_name: &str, job_uid: &str)

crates/controller-manager/src/controllers/job.rs:1550

↓ 5 callersFunctionmake_service

( name: &str, namespace: &str, cluster_ip: &str, service_type: ServiceType,

crates/kube-proxy/src/iptables.rs:1873

↓ 5 callersFunctionmake_succeeded_pod

()

crates/kubelet/tests/status_idempotency_test.rs:19

↓ 5 callersMethodmatches

Check if a resource matches this label selector

crates/common/src/label_selector.rs:302

↓ 5 callersFunctionmod_revision_to_resource_version

Convert etcd mod_revision to resourceVersion string

crates/storage/src/concurrency.rs:36

↓ 5 callersMethodnormalize

Normalize the Secret by converting stringData to data (base64 encoded) This matches Kubernetes behavior where stringData is a write-only convenience f

crates/common/src/resources/config_and_secret.rs:228

↓ 5 callersFunctionparse_condition

(condition: &str)

crates/kubectl/src/commands/wait.rs:164

↓ 5 callersFunctionparse_cpu_quantity

Parse a Kubernetes CPU quantity string (e.g., "500m", "1", "0.5") into millicores.

crates/kubelet/src/runtime.rs:8109

↓ 5 callersFunctionpods_rule

()

crates/api-server/src/admission_webhook.rs:3473

↓ 5 callersFunctionprint_deployments

(deployments: &[Deployment], no_headers: bool, show_labels: bool)

crates/kubectl/src/commands/get.rs:1337

↓ 5 callersFunctionprint_services

(services: &[Service], no_headers: bool, show_labels: bool)

crates/kubectl/src/commands/get.rs:1286

↓ 5 callersMethodreconcile_all

(&self)

crates/controller-manager/src/controllers/endpoints.rs:214

↓ 5 callersMethodreconcile_all

(&self)

crates/controller-manager/src/controllers/replicaset.rs:208

↓ 5 callersMethodregister_score_plugin

crates/scheduler/src/framework.rs:372

↓ 5 callersFunctionresolve_aggregator_target_with_storage

Storage-only flavour of [`resolve_aggregator_target`] — exposed for integration tests that want to exercise the resolver without spinning up the whole

crates/api-server/src/handlers/generic.rs:269

↓ 5 callersFunctionresolve_probe_port

Resolve a probe port (which K8s spec'd as IntOrString) against a Container's declared ports. Integer values pass through; string values are looked up

crates/common/src/resources/pod.rs:1591

↓ 5 callersFunctionresolve_webhook_timeout

Resolve a webhook's `timeoutSeconds` to a [`Duration`], honoring K8s v1.35 bounds. `None` → 10s default. Values < 1 → 1s. Values > 30 → 30s.

crates/api-server/src/admission_webhook.rs:34

↓ 5 callersFunctionrun

Run the kubelet component. This is the main entry point for embedding the kubelet in the all-in-one binary. Starts the kubelet sync loop and metrics

crates/kubelet/src/lib.rs:47

↓ 5 callersMethodrun

(self: &Arc<Self>)

crates/kubelet/src/kubelet.rs:116

↓ 5 callersFunctionseed_apiservice

( storage: &MemoryStorage, name: &str, group: &str, version: &str, spec_overrides: Value,

crates/api-server/tests/aggregator_test.rs:42

↓ 5 callersFunctionset_default_storage_class

DefaultStorageClass admission controller - sets default storage class for PVCs This is a built-in admission controller that: 1. If a PVC doesn't speci

crates/api-server/src/admission.rs:898

↓ 5 callersFunctionset_initial_generation

Set generation to 1 on newly created resources. This should be called during resource creation, after all mutations but before storing the resource.

crates/api-server/src/handlers/lifecycle.rs:13

↓ 5 callersFunctionsetup_emptydir_dir

Set up an EmptyDir volume directory with mode 0o777, matching upstream Kubernetes (pkg/volume/emptydir/empty_dir.go setupDir). The chmod is idempoten

crates/kubelet/src/runtime.rs:171

↓ 5 callersFunctionsetup_test

()

crates/controller-manager/tests/volume_snapshot_controller_test.rs:12

↓ 5 callersFunctionsetup_test_storage

()

tests/tests/storage_lifecycle_test.rs:16

↓ 5 callersFunctionsetup_test_storage

()

tests/tests/controller_verification_test.rs:15

↓ 5 callersFunctionsetup_test_storage

()

tests/tests/kubernetes_compatibility_test.rs:13

↓ 5 callersFunctionsimulate_init_container_failure

Helper: build a pod with a failing init container and an app container, then simulate what the kubelet does when start_pod returns an error due to ini

crates/kubelet/src/runtime.rs:10341

↓ 5 callersFunctionskip_whitespace

Skip whitespace characters

crates/api-server/src/handlers/validation.rs:168

↓ 5 callersMethodstop_pod_for

Stop all containers for a pod, executing preStop lifecycle hooks first. This is the preferred method when the Pod spec is available, as it allows pre

crates/kubelet/src/runtime.rs:6949

↓ 5 callersFunctiontest_user

(username: &str, groups: &[&str], extras: &[(&str, &[&str])])

crates/api-server/tests/aggregator_test.rs:27

↓ 5 callersFunctionupdate

( State(state): State<Arc<ApiServerState>>, Extension(auth_ctx): Extension<AuthContext>, Path((nam

crates/api-server/src/handlers/job.rs:116

↓ 5 callersMethodupdate_deployment_status

( &self, deployment: &Deployment, )

crates/controller-manager/src/controllers/deployment.rs:1607

↓ 5 callersFunctionvalidate_custom_resource

Validate a custom resource against its CRD schema

crates/api-server/src/handlers/custom_resource.rs:1303

↓ 5 callersMethodvalue

Get the expected value

crates/common/src/field_selector.rs:154

↓ 5 callersMethodwith_annotations

(mut self, annotations: HashMap<String, String>)

crates/common/src/types.rs:111

↓ 5 callersMethodwith_api_server_metrics

(mut self)

crates/common/src/observability.rs:298

↓ 4 callersFunctionadd_standard_crd_properties

Add standard K8s properties (metadata, apiVersion, kind) to a CRD schema definition. K8s always adds these to CRD OpenAPI definitions. K8s ref: stagin

crates/api-server/src/handlers/openapi.rs:670

↓ 4 callersFunctionapply_json_patch

Apply JSON Patch (RFC 6902)

crates/api-server/src/patch.rs:148

↓ 4 callersFunctionbuild_active_rs

Build a ReplicaSet that matches a deployment's template, owned by the deployment, with the given replicas. By default the RS carries the `desired-repl

crates/controller-manager/tests/deployment_idempotency_test.rs:104

↓ 4 callersFunctionbuild_cluster_role_binding

( name: &str, clusterrole: &str, users: &[String], groups: &[String], service_accounts: &[

crates/kubectl/src/commands/create.rs:396

↓ 4 callersFunctionbuild_configmap

( name: &str, namespace: &str, from_literal: &[String], from_file: &[String], )

crates/kubectl/src/commands/create.rs:417

↓ 4 callersFunctionbuild_cronjob

( name: &str, namespace: &str, image: &str, schedule: &str, restart: &str, command: &[

crates/kubectl/src/commands/create.rs:449

↓ 4 callersFunctionbuild_deployment

Build a Deployment with the given replicas using a minimal RollingUpdate strategy (so the controller takes the rolling-update code path).

crates/controller-manager/tests/deployment_idempotency_test.rs:36

↓ 4 callersFunctionbuild_policy_rules

( verbs: &[String], resources: &[String], resource_names: &[String], non_resource_urls: &[Stri

crates/kubectl/src/commands/create.rs:1209

↓ 4 callersFunctionbuild_quota

(name: &str, namespace: &str, hard: Option<&str>)

crates/kubectl/src/commands/create.rs:1182

↓ 4 callersFunctionbuild_secret_generic

( name: &str, namespace: &str, from_literal: &[String], from_file: &[String], secret_type:

crates/kubectl/src/commands/create.rs:818

↓ 4 callersMethodbytes_to_memory_string

Convert bytes to human-readable memory string

crates/controller-manager/src/controllers/resource_quota.rs:756

↓ 4 callersMethodcalculate_desired_healthy

Calculate desired_healthy based on min_available or max_unavailable

crates/controller-manager/src/controllers/pod_disruption_budget.rs:210

↓ 4 callersMethodcalculate_usage

Calculate resource usage in a namespace, respecting quota scopes. Only counts resources that appear in `hard_keys` to avoid unnecessary work.

crates/controller-manager/src/controllers/resource_quota.rs:457

↓ 4 callersMethodcall_webhook_with_ca

Call a webhook with optional CA bundle for TLS verification. The request is bounded by a tokio task-level deadline matching the webhook's `spec.timeo

crates/api-server/src/admission_webhook.rs:167

↓ 4 callersFunctioncheck_node_affinity

Check node affinity requirements

crates/scheduler/src/advanced.rs:96

↓ 4 callersFunctioncheck_preemption

Check if preemption should occur and return pods to evict Returns (should_preempt, pods_to_evict)

crates/scheduler/src/advanced.rs:797

↓ 4 callersMethodcheck_probe

Execute a probe check

crates/kubelet/src/runtime.rs:6153

↓ 4 callersFunctioncheck_resource_quota

Check if pod creation would exceed ResourceQuota limits

crates/api-server/src/admission.rs:167

↓ 4 callersMethodcleanup_pod_volumes

Clean up volumes created for a pod Clean up volumes for a pod. Called by the TerminatedPod handler after all containers are stopped, and by the contai

crates/kubelet/src/runtime.rs:5065

↓ 4 callersFunctioncompile_regex_cached

(pattern: &str)

crates/common/src/schema_validation.rs:26

↓ 4 callersMethodcreate_pod_hosts_file

Create /etc/hosts file for a pod. Generates a hosts file with: - Standard localhost entries - The pod's own hostname → IP mapping (if IP is known) -

crates/kubelet/src/runtime.rs:1110

↓ 4 callersFunctioncreate_provider

Factory function to create a cloud provider based on the provider type

crates/cloud-providers/src/lib.rs:12

↓ 4 callersFunctioncreate_test_crd

(with_subresources: bool)

crates/api-server/src/dynamic_routes.rs:252

↓ 4 callersFunctioncreate_test_crd

()

crates/api-server/src/handlers/custom_resource.rs:1773

↓ 4 callersFunctioncreate_test_pv

(storage: &MemoryStorage, name: &str)

crates/controller-manager/tests/volume_snapshot_controller_test.rs:71

↓ 4 callersFunctioncreate_test_pvc

(name: &str, namespace: &str)

crates/api-server/tests/admission_test.rs:246

↓ 4 callersFunctioncreate_test_pvc

( storage: &MemoryStorage, name: &str, namespace: &str, pv_name: &str, )

crates/controller-manager/tests/volume_snapshot_controller_test.rs:16

↓ 4 callersFunctioncreate_test_state

()

crates/api-server/src/handlers/metrics.rs:394

↓ 4 callersFunctioncreate_test_storage_class

( storage: &Arc<MemoryStorage>, name: &str, allow_expansion: bool, )

crates/controller-manager/tests/volume_expansion_test.rs:20

↓ 4 callersMethoddecode

Decode a token from base64 string

crates/common/src/pagination.rs:52

↓ 4 callersMethoddecrypt

(&self, ciphertext: &[u8])

crates/common/src/encryption.rs:166

↓ 4 callersFunctiondelete

Delete an event

crates/api-server/src/handlers/event.rs:297

↓ 4 callersFunctiondelete_resource

(client: &ApiClient, value: &serde_yaml::Value)

crates/kubectl/src/commands/delete.rs:200

↓ 4 callersMethoddiscover_plugins

Discover all available CNI plugins

crates/kubelet/src/cni/plugin.rs:157

↓ 4 callersMethodencrypt

(&self, plaintext: &[u8])

crates/common/src/encryption.rs:143

↓ 4 callersMethodensure_chain

Ensure an iptables chain exists

crates/kube-proxy/src/iptables.rs:697

↓ 4 callersFunctionexecute

KubeRC is an alpha feature for user-level kubectl configuration. Equivalent to: kubectl kuberc KubeRC allows users to configure kubectl behavior via

crates/kubectl/src/commands/kuberc.rs:12

↓ 4 callersFunctionexecute

Explain Kubernetes resource documentation

crates/kubectl/src/commands/explain.rs:5

↓ 4 callersMethodexecute

( &self, command: CniCommand, container_id: &str, netns: &str, ifname:

crates/kubelet/src/cni/plugin.rs:32

↓ 4 callersFunctionexecute_enhanced

( client: &ApiClient, resource_type: &str, name: Option<&str>, namespace: &str, selector:

crates/kubectl/src/commands/describe.rs:6

↓ 4 callersFunctionexecute_enhanced

( client: &ApiClient, resource_type: &str, name: &str, namespace: &str, opts: &DeleteOptio

crates/kubectl/src/commands/delete.rs:559

↓ 4 callersFunctionexecute_enhanced

( client: &ApiClient, resource_type: &str, name: Option<&str>, namespace: Option<&str>, _a

crates/kubectl/src/commands/get.rs:313

↓ 4 callersFunctionexecute_image

Update container images in a resource. Usage: `kubectl set image deployment/nginx nginx=nginx:1.9.1`

crates/kubectl/src/commands/set.rs:151

↓ 4 callersFunctionexecute_inline

Execute inline resource creation (e.g., kubectl create namespace foo)

crates/kubectl/src/commands/create.rs:1386

← previous next →401–500 of 6,481, ranked by callers