MCPcopy Create free account

hub / github.com/calfonso/rusternetes / functions

Functions6,481 in github.com/calfonso/rusternetes

↓ 19 callersFunctionsetup_test
Setup test environment with in-memory storage
crates/scheduler/tests/scheduler_test.rs:13
↓ 18 callersFunctionbuild_query_string
(options: &ApplyOptions)
crates/kubectl/src/commands/apply.rs:188
↓ 18 callersFunctioncreate_test_configmap
Helper function to create a test configmap
crates/api-server/tests/configmap_handler_test.rs:12
↓ 18 callersFunctioncreate_test_node
Helper function to create a test node
crates/api-server/tests/node_handler_test.rs:12
↓ 18 callersMethodcurrent_revision
(&self)
crates/api-server/src/watch_cache.rs:186
↓ 18 callersMethodgenerate_token
Generate a JWT token for a service account
crates/common/src/auth.rs:179
↓ 18 callersFunctionmake_job
(name: &str, namespace: &str, completions: i32, parallelism: i32)
crates/controller-manager/src/controllers/job.rs:1509
↓ 17 callersFunctionbuildApiPath
( group: string, version: string, plural: string, namespace?: string, name?: string, )
console/src/engine/query.ts:135
↓ 17 callersFunctioncreate_test_capacity
Helper function to create a test CSIStorageCapacity with basic configuration
crates/api-server/tests/csistoragecapacity_test.rs:13
↓ 17 callersFunctioncreate_test_daemonset
Helper function to create a test daemonset
crates/api-server/tests/daemonset_handler_test.rs:16
↓ 17 callersFunctioncreate_test_volumeattachment
Helper function to create a test volumeattachment with persistent volume
crates/api-server/tests/volumeattachment_handler_test.rs:16
↓ 17 callersFunctionk8s_name
Generate a Kubernetes-valid DNS-1123 label (lowercase letters, digits, '-').
crates/common/tests/fuzz_roundtrip_jsonproto_test.rs:62
↓ 17 callersFunctionparse_memory_to_bytes
(memory: &str)
crates/api-server/src/admission.rs:851
↓ 17 callersMethodrun_validating_admission_policies_ext
Extended VAP evaluation with resource name and namespace for precise matching.
crates/api-server/src/admission_webhook.rs:1760
↓ 17 callersMethodrun_validating_webhooks
( &self, operation: &Operation, gvk: &GroupVersionKind, gvr: &GroupVersionReso
crates/api-server/src/admission_webhook.rs:529
↓ 17 callersFunctionvalidate_strict_fields
Validate the request body against the parsed resource per the `?fieldValidation=` directive. Behaviour by mode (matches upstream k8s 1.35): - `Strict
crates/api-server/src/handlers/validation.rs:429
↓ 17 callersMethodvalues
Get the values
crates/common/src/label_selector.rs:401
↓ 16 callersFunctionapply_patch
Apply a patch to a resource
crates/api-server/src/patch.rs:90
↓ 16 callersFunctioncreate_test_namespace
Helper function to create a test namespace
crates/api-server/tests/namespace_handler_test.rs:12
↓ 16 callersFunctioncreate_test_pod
(name: &str, namespace: &str, owner_uid: Option<&str>)
crates/controller-manager/tests/garbage_collector_test.rs:17
↓ 16 callersMethodencode
Encode the token to a base64 string
crates/common/src/pagination.rs:46
↓ 16 callersMethodget_init_container_statuses
Get detailed status of init containers by inspecting actual Docker container state.
crates/kubelet/src/runtime.rs:5231
↓ 16 callersFunctionget_resource_api_path
( resource_type: &str, namespace: &str, name: &str, )
crates/kubectl/src/commands/rollout.rs:418
↓ 16 callersFunctionmake_test_client
()
crates/kubectl/src/commands/delete.rs:1441
↓ 15 callersFunctioncreate_test_deployment
Helper function to create a test deployment
crates/api-server/tests/deployment_handler_test.rs:14
↓ 15 callersFunctioncreate_test_quota
Helper function to create a test resourcequota
crates/api-server/tests/resourcequota_handler_test.rs:13
↓ 15 callersMethodnamespace
Match resources by namespace
crates/common/src/field_selector.rs:250
↓ 15 callersFunctionparse_cpu_to_millicores
(cpu: &str)
crates/api-server/src/admission.rs:841
↓ 15 callersFunctionserve
Accept connections on the listener and proxy them to the API server.
crates/kubectl/src/commands/proxy.rs:54
↓ 15 callersFunctionspawn_router
()
crates/api-server/tests/decoder_strict_fields_test.rs:59
↓ 14 callersFunctionassert_status_contract
Assert the contract described in the file-level docs: - status is 400 or 422 - body parses as a Kubernetes `Status` failure object (`kind=Status`, `ap
crates/api-server/tests/decoder_malformed_json_test.rs:85
↓ 14 callersMethodclose
Close the connection
crates/api-server/src/spdy.rs:211
↓ 14 callersFunctioncreate_test_crd
(name: &str, group: &str, plural: &str)
crates/controller-manager/src/controllers/crd.rs:486
↓ 14 callersFunctioncreate_test_pod
Helper function to create a test pod
crates/api-server/tests/pod_handler_test.rs:11
↓ 14 callersFunctioncreate_test_pod
( name: &str, namespace: &str, labels: HashMap<String, String>, pod_ip: Option<String>, re
crates/controller-manager/tests/endpoints_controller_test.rs:56
↓ 14 callersFunctionget_resource_api_path
(kind: &str, namespace: &str, name: &str)
crates/kubectl/src/commands/diff.rs:116
↓ 14 callersFunctionparse_resource_quantity
Parse resource quantity (simplified) Handles K8s resource formats: CPU: "100m" (millicores), "0.5" or "1.5" (decimal cores), "2" (whole cores) Memory:
crates/scheduler/src/advanced.rs:747
↓ 14 callersFunctionpost_pod_raw
Send a raw byte body to the pod create endpoint and return `(status, body_bytes)`.
crates/api-server/tests/decoder_malformed_json_test.rs:63
↓ 14 callersFunctionsend_json
( router: Router, method: Method, uri: &str, body: &Value, )
crates/api-server/tests/decoder_strict_fields_test.rs:98
↓ 14 callersFunctionspawn_router
()
crates/api-server/tests/decoder_malformed_json_test.rs:56
↓ 13 callersFunctionbuild_swagger_spec_for_crds
Build a complete swagger v2 spec given a list of CRDs (as raw JSON). Centralising this in a pure function means the openapi/v2 endpoint always reflec
crates/api-server/src/handlers/openapi.rs:447
↓ 13 callersFunctioncreate_test_endpoints
( name: &str, namespace: &str, addresses: Vec<String>, ports: Vec<(String, u16)>, )
crates/controller-manager/tests/endpointslice_controller_test.rs:9
↓ 13 callersFunctioncreate_test_ingress
Helper function to create test Ingress
crates/api-server/tests/ingress_handler_test.rs:15
↓ 13 callersFunctionget_str
(obj: &'a serde_json::Map<String, serde_json::Value>, key: &str)
crates/api-server/src/gnostic.rs:51
↓ 13 callersFunctionlist
( State(state): State<Arc<ApiServerState>>, Extension(auth_ctx): Extension<AuthContext>, Path(name
crates/api-server/src/handlers/job.rs:216
↓ 13 callersFunctionmake_node
Helper: create a node with allocatable CPU and memory
crates/scheduler/src/advanced.rs:1302
↓ 13 callersFunctionsetup_test
()
crates/controller-manager/tests/garbage_collector_test.rs:11
↓ 13 callersFunctionsetup_test
()
crates/controller-manager/tests/csr_controller_test.rs:13
↓ 13 callersFunctionuseK8sWatch
( group: string, version: string, plural: string, namespace?: string, opts?: { enabled?: boolean },
console/src/hooks/useK8sWatch.ts:11
↓ 12 callersFunctionbuild_hosts_content
Build the /etc/hosts content string the same way create_pod_hosts_file does, so we can unit-test the logic without needing a live ContainerRuntime.
crates/kubelet/src/runtime.rs:8211
↓ 12 callersFunctioncrd_with_schema
( name: &str, group: &str, plural: &str, kind: &str, versions: Vec<(&s
crates/api-server/src/handlers/openapi.rs:1262
↓ 12 callersFunctioncreate_ephemeral_container
Create an ephemeral container for debugging
crates/kubelet/tests/ephemeral_containers_test.rs:122
↓ 12 callersFunctioncreate_servicecidr
(name: &str, cidrs: Vec<String>)
crates/common/tests/servicecidr_test.rs:14
↓ 12 callersFunctioncreate_test_csr
(name: &str, signer: &str, usages: Vec<KeyUsage>)
crates/controller-manager/tests/csr_controller_test.rs:19
↓ 12 callersFunctioncreate_test_hpa
Helper function to create test HorizontalPodAutoscaler
crates/api-server/tests/horizontalpodautoscaler_handler_test.rs:15
↓ 12 callersMethodevaluate
Evaluate a CEL expression with the given context # Arguments `expression` - The CEL expression to evaluate `context` - Variables to make available in
crates/common/src/cel.rs:36
↓ 12 callersFunctionextract_proxy_suffix
Extract the portion of `uri.path()` that follows the proxy marker for the given resource. The returned slice preserves a trailing slash so that we can
crates/api-server/src/handlers/proxy.rs:50
↓ 12 callersFunctionextract_selector
Extract selector labels from a resource JSON object. - For Pods: uses `.metadata.labels` - For Services: uses `.spec.selector` - For Deployments/Repl
crates/kubectl/src/commands/expose.rs:42
↓ 12 callersMethodget
(&self, key: &str)
crates/storage/src/etcd.rs:127
↓ 12 callersFunctionmake_pod
(name: &str, cpu_request: Option<&str>, cpu_limit: Option<&str>)
crates/api-server/src/admission.rs:1208
↓ 12 callersFunctionprocess_deletion
Process a deletion request
crates/common/src/deletion.rs:76
↓ 12 callersFunctionsnapshot
Snapshot a stored object as canonical JSON for byte-equality comparison.
crates/controller-manager/tests/deployment_idempotency_test.rs:309
↓ 12 callersFunctionspawn_router
()
crates/api-server/tests/decoder_content_type_test.rs:70
↓ 12 callersMethodvalidate_token
Validate and decode a JWT token
crates/common/src/auth.rs:190
↓ 11 callersFunctionadd_namespaced_resource
Add a namespaced resource to the paths
crates/api-server/src/openapi.rs:216
↓ 11 callersFunctionbuild_owned_rs
Build an owned ReplicaSet that mirrors the deployment's pod template (so `replicaset_matches_template` returns true when image matches), plus the pod-
crates/controller-manager/src/controllers/deployment.rs:2528
↓ 11 callersFunctioncreate_ipaddress
(name: &str, parent_ref: ParentReference)
crates/common/tests/ipaddress_test.rs:12
↓ 11 callersFunctioncreate_test_endpoints
Helper function to create test Endpoints
crates/api-server/tests/endpoints_handler_test.rs:12
↓ 11 callersFunctioncreate_test_endpointslice
Helper function to create test EndpointSlice
crates/api-server/tests/endpointslice_handler_test.rs:12
↓ 11 callersFunctioncreate_test_job
(name: &str, namespace: &str, completions: i32, parallelism: i32)
crates/controller-manager/tests/job_controller_test.rs:18
↓ 11 callersFunctioncreate_test_limitrange
Helper function to create test LimitRange
crates/api-server/tests/limitrange_handler_test.rs:12
↓ 11 callersFunctioncreate_test_manager
()
crates/api-server/src/admission_webhook.rs:2397
↓ 11 callersFunctioncreate_test_pod
( name: &str, namespace: &str, labels: HashMap<String, String>, is_healthy: bool, )
crates/controller-manager/tests/pdb_controller_test.rs:26
↓ 11 callersFunctioncreate_test_replicaset
(name: &str, namespace: &str, replicas: i32)
crates/controller-manager/tests/replicaset_controller_test.rs:11
↓ 11 callersMethodget_container_statuses
(&self, pod: &Pod)
crates/kubelet/src/runtime.rs:5735
↓ 11 callersFunctionget_resource_api_path
(resource_type: &str, namespace: &str, name: &str)
crates/kubectl/src/commands/edit.rs:94
↓ 11 callersFunctionmake_pod
(name: &str, namespace: &str, resource_version: Option<&str>)
crates/kubelet/src/kubelet.rs:4108
↓ 11 callersMethodmetadata
(&self)
crates/api-server/src/handlers/table.rs:290
↓ 11 callersFunctionpaginate
Paginate a list of items according to Kubernetes API conventions
crates/common/src/pagination.rs:86
↓ 11 callersFunctionsend_with_ct
Send an arbitrary-body request with an explicit `Content-Type` header (no normalization on the test side — the middleware is what we are exercising).
crates/api-server/tests/decoder_content_type_test.rs:79
↓ 11 callersFunctionserver_side_apply
Apply a resource using server-side apply semantics
crates/common/src/server_side_apply.rs:95
↓ 11 callersFunctionsetup_test
Setup test environment with in-memory storage
crates/api-server/tests/cluster_startup_test.rs:10
↓ 11 callersFunctionsetup_test
()
crates/controller-manager/tests/job_controller_test.rs:12
↓ 11 callersMethodupdate_replicaset_replicas
( &self, rs: &ReplicaSet, replicas: i32, )
crates/controller-manager/src/controllers/deployment.rs:1549
↓ 10 callersMethodadd_variable
Add a variable to the context
crates/common/src/cel.rs:194
↓ 10 callersMethodallocate
Allocate a new ClusterIP Returns None if all IPs are allocated
crates/api-server/src/ip_allocator.rs:51
↓ 10 callersFunctioncollect_files
Collect file paths from the supplied list, expanding directories.
crates/kubectl/src/commands/apply.rs:131
↓ 10 callersMethodcreate
(&self, key: &str, value: &T)
crates/storage/src/memory.rs:62
↓ 10 callersMethodcreate_event_if_new
Create an event if it doesn't already exist (deduplicate)
crates/controller-manager/src/controllers/events.rs:300
↓ 10 callersFunctioncreate_minimal_pod_spec
Helper to create minimal PodSpec (no Default impl)
crates/api-server/tests/watch_handler_test.rs:38
↓ 10 callersFunctioncreate_minimal_pod_status
Helper to create minimal PodStatus (no Default impl)
crates/api-server/tests/watch_handler_test.rs:109
↓ 10 callersFunctioncreate_owned_rs
( name: &str, namespace: &str, replicas: i32, deploy_name: &str, deploy_uid: &str, ima
crates/controller-manager/tests/deployment_scaling_test.rs:102
↓ 10 callersFunctioncreate_pod_with_qos
Test helper to create a pod with specific QoS class
crates/kubelet/tests/eviction_test.rs:18
↓ 10 callersFunctioncreate_test_node
(name: &str, labels: Option<HashMap<String, String>>)
crates/controller-manager/tests/daemonset_controller_test.rs:18
↓ 10 callersFunctioncreate_test_service
(name: &str, namespace: &str, selector: HashMap<String, String>)
crates/controller-manager/tests/endpoints_controller_test.rs:11
↓ 10 callersMethoddelete_body
Build the JSON body containing propagationPolicy for the DELETE request.
crates/kubectl/src/commands/delete.rs:101
↓ 10 callersFunctionencode
(s: &str)
crates/kubectl/src/commands/cp.rs:622
↓ 10 callersFunctionget_crd_for_resource
Helper to get CRD from storage
crates/api-server/src/handlers/custom_resource.rs:1100
↓ 10 callersFunctionmake_pod
(name: &str, namespace: &str, resources: Option<ResourceRequirements>)
crates/controller-manager/src/controllers/resource_quota.rs:852
↓ 10 callersFunctionmake_pod_with_containers
( name: &str, containers: Vec<rusternetes_common::resources::Container>, )
crates/api-server/src/handlers/pod.rs:1644
← previousnext →101–200 of 6,481, ranked by callers