MCPcopy Create free account

hub / github.com/calfonso/rusternetes / functions

Functions6,481 in github.com/calfonso/rusternetes

⨍ Functions 6,481◇ Types & classes 991
↓ 7 callersFunctionmake_pod
(name: &str, namespace: &str, hostname: Option<&str>, subdomain: Option<&str>)
crates/kubelet/tests/hosts_file_test.rs:33
↓ 7 callersFunctionmake_test_client
()
crates/kubectl/src/commands/cp.rs:221
↓ 7 callersMethodmetadata_mut
(&mut self)
crates/api-server/src/handlers/finalizers.rs:182
↓ 7 callersFunctionparse_resource_group
Parse "resource.group/subresource" into (resource_with_sub, api_group)
crates/kubectl/src/commands/create.rs:1287
↓ 7 callersFunctionprint_event_row
(event: &Value, all_namespaces: bool)
crates/kubectl/src/commands/events.rs:317
↓ 7 callersFunctionprotocolColor
(protocol?: string)
console/src/views/TopologyView.tsx:106
↓ 7 callersMethodregister_filter_plugin
Register a Filter plugin
crates/scheduler/src/framework.rs:357
↓ 7 callersFunctionresolve_sort_key
Resolve a JSONPath expression to a sortable value from a serde_json::Value
crates/kubectl/src/commands/get.rs:192
↓ 7 callersMethodrun_validating_webhooks_with_dryrun
( &self, operation: &Operation, gvk: &GroupVersionKind, gvr: &GroupVersionReso
crates/api-server/src/admission_webhook.rs:556
↓ 7 callersFunctionseed_pod
Seed a Pod into memory storage and return its registry key. The seeded shape carries TWO containers — `c1` and `c2` — so that strategic-merge vs RFC 7
crates/api-server/tests/decoder_content_type_test.rs:149
↓ 7 callersFunctionsetup
()
crates/controller-manager/tests/daemonset_revision_match_test.rs:20
↓ 7 callersFunctionsetup
()
crates/controller-manager/tests/deployment_scaling_test.rs:19
↓ 7 callersFunctionsetup_cni_environment
Helper function to create a temporary directory with mock CNI plugin
crates/kubelet/tests/cni_integration_test.rs:9
↓ 7 callersFunctionsetup_test
()
crates/controller-manager/tests/pv_binder_test.rs:13
↓ 7 callersFunctionsetup_test
()
crates/controller-manager/tests/cronjob_controller_test.rs:13
↓ 7 callersFunctionsetup_test
()
crates/controller-manager/tests/statefulset_controller_test.rs:13
↓ 7 callersFunctionsetup_test_storage
()
tests/tests/networking_conformance_test.rs:12
↓ 7 callersMethodshutdown
Signal shutdown. After this, `get()` returns `None` once the queue is drained.
crates/storage/src/workqueue.rs:289
↓ 7 callersFunctionspawn_webhook_server
Spin up a tiny axum HTTP server that returns the canned AdmissionReview response for every POST. Returns the base URL so the webhook config can point
crates/api-server/src/admission_webhook.rs:3446
↓ 7 callersFunctiontry_brace_scan_or_type_meta
Try brace-scanning to find embedded JSON in a protobuf body, validating the result with serde_json. If no valid JSON is found, fall back to extracting
crates/api-server/src/middleware.rs:1172
↓ 7 callersMethodupdate_condition
( &self, apiservice_name: &str, status: &str, reason: &str, message: &
crates/controller-manager/src/controllers/apiservice.rs:395
↓ 7 callersMethodwith_default_network
Set the default network to use
crates/kubelet/src/cni/runtime.rs:62
↓ 7 callersMethodwith_force
Enable force mode
crates/common/src/server_side_apply.rs:65
↓ 6 callersFunctionapiBase
Get the base URL for API calls. In production this is same-origin.
console/src/engine/query.ts:7
↓ 6 callersFunctionbind_listener
Bind a TCP listener according to the config. Exposed for testing.
crates/kubectl/src/commands/proxy.rs:44
↓ 6 callersFunctionbroadcast_to_stream
Convert a broadcast receiver into a WatchStream compatible with existing handlers.
crates/api-server/src/watch_cache.rs:220
↓ 6 callersFunctionbuild_cluster_role
( name: &str, verbs: &[String], resources: &[String], resource_names: &[String], non_resou
crates/kubectl/src/commands/create.rs:363
↓ 6 callersMethodbuild_nat_rules
( &self, services: &[rusternetes_common::resources::Service], endpointslice_map: &std:
crates/kube-proxy/src/iptables.rs:1358
↓ 6 callersFunctionbuild_router
(state: Arc<ApiServerState>, console_dir: Option<&Path>)
crates/api-server/src/router.rs:663
↓ 6 callersFunctioncheck_resource_quota
Check ResourceQuota before creating a pod in a namespace. Returns Ok(()) if quota allows, Err with quota exceeded message otherwise.
crates/controller-manager/src/controllers/mod.rs:38
↓ 6 callersFunctioncontent_for_resource
(resource_name: &str)
crates/api-server/src/openapi.rs:797
↓ 6 callersFunctioncreate_basic_service_spec
()
crates/api-server/tests/service_test.rs:16
↓ 6 callersFunctioncreate_minimal_pod
(name: &str, namespace: &str)
crates/api-server/tests/admission_test.rs:20
↓ 6 callersFunctioncreate_running_pod
Test helper to create a running pod
crates/kubelet/tests/ephemeral_containers_test.rs:7
↓ 6 callersFunctioncreate_test_deployment_with_pods
( _storage: &Arc<MemoryStorage>, name: &str, namespace: &str, replicas: i32, )
crates/controller-manager/tests/vpa_controller_test.rs:12
↓ 6 callersFunctiondelete_single_resource
Core single-resource delete with full options support.
crates/kubectl/src/commands/delete.rs:502
↓ 6 callersFunctionencode_protobuf
Encode a Kubernetes API object to protobuf format This function: 1. Serializes the object to JSON (since we don't have generated protobuf schemas) 2.
crates/common/src/protobuf.rs:94
↓ 6 callersFunctionextract_sysctls
Extract the sysctls map from a pod the same way create_pod does (lines 874-882)
crates/kubelet/src/runtime.rs:9524
↓ 6 callersMethodflush
(&self)
crates/common/src/audit.rs:208
↓ 6 callersMethodget
(&self, key: &str)
crates/storage/src/memory.rs:115
↓ 6 callersFunctionget_aggregated_resources_for_group
Build aggregated discovery resource entries for a given API group. Returns a list of resource objects in the apidiscovery.k8s.io/v2 format. In v2, sub
crates/api-server/src/handlers/discovery.rs:766
↓ 6 callersMethodget_current_context
Get the current context
crates/kubectl/src/kubeconfig.rs:138
↓ 6 callersMethodget_pod_ip
Get the pod IP address from the first running container
crates/kubelet/src/runtime.rs:7373
↓ 6 callersFunctionhandleResponse
(res: Response)
console/src/engine/query.ts:29
↓ 6 callersFunctionheaders
Build headers for API requests.
console/src/engine/query.ts:12
↓ 6 callersMethodinitialize
Initialize the controller by scanning existing services
crates/controller-manager/src/controllers/service.rs:111
↓ 6 callersFunctionk8s_label_value
Generate a Kubernetes label / annotation value (relaxed printable ASCII, no embedded quotes/newlines so serde_json::Value comparisons are stable).
crates/common/tests/fuzz_roundtrip_jsonproto_test.rs:70
↓ 6 callersFunctionmake_daemonset
(name: &str, namespace: &str, uid: &str)
crates/controller-manager/src/controllers/cascade_tests.rs:127
↓ 6 callersFunctionmake_node
(name: &str)
crates/scheduler/src/scheduler.rs:1449
↓ 6 callersFunctionmake_node
(name: &str)
crates/controller-manager/src/controllers/cascade_tests.rs:102
↓ 6 callersFunctionmake_pod
( name: &str, namespace: &str, labels: HashMap<String, String>, running: bool,
crates/api-server/src/handlers/pod_subresources.rs:1353
↓ 6 callersFunctionmake_pod
(name: &str, restart_policy: &str, init: Vec<Container>, app: Vec<Container>)
crates/kubelet/tests/kubelet_lifecycle_test.rs:49
↓ 6 callersFunctionmake_pod_with_sysctls
Helper: build a pod with optional sysctls in its security context
crates/kubelet/src/runtime.rs:9454
↓ 6 callersFunctionmake_rc
( name: &str, ns: &str, replicas: i32, selector: HashMap<String, String>,
crates/controller-manager/src/controllers/replicationcontroller.rs:771
↓ 6 callersFunctionmake_statefulset
(name: &str, namespace: &str, replicas: i32, image: &str)
crates/controller-manager/src/controllers/statefulset.rs:1364
↓ 6 callersFunctionmake_validating_config
(name: &str, url: &str, rule: Rwo)
crates/api-server/src/admission_webhook.rs:3523
↓ 6 callersFunctionmaybe_increment_generation
Increment generation if spec has changed (by comparing old vs new JSON, ignoring metadata and status). This should be called during resource updates
crates/api-server/src/handlers/lifecycle.rs:21
↓ 6 callersFunctionobject_meta_namespaced
Strategy for `ObjectMeta` with namespace.
crates/common/tests/fuzz_roundtrip_jsonproto_test.rs:110
↓ 6 callersMethodon_upgrade
Upgrade the connection and call the callback
crates/api-server/src/spdy_upgrade.rs:35
↓ 6 callersFunctionparse_annotations
(annotations: &[String])
crates/kubectl/src/commands/annotate.rs:76
↓ 6 callersFunctionparse_index_ranges
Parse index ranges like "0,1,3-5" into a set of integers {0, 1, 3, 4, 5}
crates/controller-manager/src/controllers/job.rs:1414
↓ 6 callersFunctionparse_labels
(labels: &[String])
crates/kubectl/src/commands/label.rs:76
↓ 6 callersFunctionparse_resource_slash
Parse resource_type for slash syntax (e.g. "pod/nginx") and return (type, optional_name)
crates/kubectl/src/commands/get.rs:177
↓ 6 callersFunctionprint_pods
(pods: &[Pod], no_headers: bool, show_labels: bool)
crates/kubectl/src/commands/get.rs:1252
↓ 6 callersMethodreconcile
(&self, daemonset: &mut DaemonSet)
crates/controller-manager/src/controllers/daemonset.rs:290
↓ 6 callersMethodreconcile_service
Reconcile EndpointSlices for a single Service
crates/controller-manager/src/controllers/endpointslice.rs:617
↓ 6 callersMethodremove_finalizer
Remove a specific finalizer from a resource in storage
crates/controller-manager/src/controllers/garbage_collector.rs:515
↓ 6 callersFunctionscan_balanced_braces
Scan for a balanced JSON object starting from data[0] which must be `{`. Returns the balanced slice as a Vec, or None if unbalanced.
crates/api-server/src/middleware.rs:1140
↓ 6 callersFunctionset_last_applied_annotation
Inject the `last-applied-configuration` annotation into a JSON Value representing the resource being applied. The annotation stores the original* inp
crates/kubectl/src/commands/apply.rs:306
↓ 6 callersFunctionsetup_test
()
crates/controller-manager/tests/deployment_controller_test.rs:14
↓ 6 callersFunctionskip_length
(der: &[u8], pos: usize)
crates/api-server/src/handlers/health.rs:402
↓ 6 callersMethodstart_pod
Start all containers for a pod
crates/kubelet/src/runtime.rs:525
↓ 6 callersFunctionstrip_last_applied
Return a copy of the value with the last-applied annotation removed (used to build the annotation value without recursion).
crates/kubectl/src/commands/apply.rs:334
↓ 6 callersMethodupdate_node_conditions
Update node conditions based on eviction signals
crates/kubelet/src/eviction.rs:310
↓ 6 callersMethodupdate_pod_with_retry
Write a pod update with one-attempt retry on resource-version Conflict and tracing for all other errors. Avoids silently dropping storage failures fro
crates/scheduler/src/scheduler.rs:43
↓ 6 callersFunctionvalidate_max_resources
( resources: &ResourceRequirements, max: &HashMap<String, String>, container_name: &str, )
crates/api-server/src/admission.rs:745
↓ 6 callersFunctionwatch_cluster_scoped_json
Watch cluster-scoped resources using serde_json::Value (for DRA types without HasMetadata)
crates/api-server/src/handlers/watch.rs:2227
↓ 6 callersFunctionwrap_json_in_protobuf
(json: &[u8])
crates/api-server/src/middleware.rs:410
↓ 6 callersMethodwrite_error
Write error message
crates/api-server/src/spdy.rs:205
↓ 5 callersFunctionbuild_delete_fallback_json
Construct a fallback DELETE event JSON when typed deserialization fails. When etcd's prev_kv is absent (compaction) or the stored JSON doesn't match
crates/api-server/src/handlers/watch.rs:1243
↓ 5 callersFunctionbuild_deployment_for_tests
Build a Deployment with the given image + replicas + (maxSurge, maxUnavailable) and optional `paused` flag. Reduces boilerplate in the proportional /
crates/controller-manager/src/controllers/deployment.rs:2614
↓ 5 callersFunctionbuild_hpa_v1
( hpa_name: &str, namespace: &str, api_version: &str, kind: &str, name: &str, min: Opt
crates/kubectl/src/commands/autoscale.rs:169
↓ 5 callersFunctionbuild_role
( name: &str, namespace: &str, verbs: &[String], resources: &[String], resource_names: &[S
crates/kubectl/src/commands/create.rs:747
↓ 5 callersFunctionbuild_secret_docker_registry
( name: &str, namespace: &str, server: &str, username: Option<&str>, password: Option<&str
crates/kubectl/src/commands/create.rs:855
↓ 5 callersFunctionbuild_subjects
( users: &[String], groups: &[String], service_accounts: &[String], )
crates/kubectl/src/commands/create.rs:1248
↓ 5 callersMethodcache_value
Cache a value with TTL
crates/api-server/src/prometheus_client.rs:330
↓ 5 callersMethodcall_validating_webhook
( &self, webhook: &ValidatingWebhook, request: &AdmissionReviewRequest, )
crates/api-server/src/admission_webhook.rs:65
↓ 5 callersFunctioncompute_pdb_disruptions_allowed
Compute disruptions_allowed for a PDB by counting matching healthy pods
crates/api-server/src/handlers/pod_subresources.rs:1322
↓ 5 callersFunctioncompute_rolling_update_counts
Compute the max surge and max unavailable counts for a rolling update. Returns (max_surge, max_unavailable).
crates/controller-manager/src/controllers/deployment.rs:26
↓ 5 callersMethodcreate_snapshot_content
( &self, vsc: &VolumeSnapshotClass, vs: &VolumeSnapshot, content_name: &str,
crates/controller-manager/src/controllers/volume_snapshot.rs:271
↓ 5 callersFunctioncreate_tar_from_file
(path: &str)
crates/kubectl/src/commands/cp.rs:440
↓ 5 callersFunctioncreate_test_job
(name: &str, namespace: &str, ttl_seconds: i32)
crates/controller-manager/src/controllers/ttl_controller.rs:327
↓ 5 callersFunctioncreate_test_pvc
( storage: &MemoryStorage, name: &str, namespace: &str, storage_class: Option<String>, cap
crates/controller-manager/tests/pv_binder_test.rs:72
↓ 5 callersFunctioncreate_test_state
These tests require etcd because ApiServerState uses StorageBackend.
crates/api-server/src/dynamic_routes.rs:225
↓ 5 callersMethoddecode
(data: &[u8])
crates/kubectl/src/websocket.rs:54
↓ 5 callersMethoddecode_message
Decode a protobuf message to JSON using the schema for the given message type. Returns None if the message type is not in the registry.
crates/api-server/src/protobuf.rs:2638
↓ 5 callersFunctiondecode_protobuf
Decode a Kubernetes API object from protobuf format This function: 1. Verifies the magic number prefix 2. Decodes the Unknown wrapper 3. Deserializes
crates/common/src/protobuf.rs:132
↓ 5 callersMethodevaluate_to_value
Evaluate a CEL expression and return the raw Value (for VAP variables)
crates/common/src/cel.rs:107
↓ 5 callersFunctionextract_scale
Extract scale information from a resource object
crates/api-server/src/handlers/scale.rs:268
↓ 5 callersMethodfinalize_namespace
Finalize a namespace by deleting all resources within it
crates/controller-manager/src/controllers/namespace.rs:291
← previousnext →301–400 of 6,481, ranked by callers