MCPcopy Create free account

hub / github.com/calfonso/rusternetes / functions

Functions6,481 in github.com/calfonso/rusternetes

↓ 10 callersFunctionmake_test_client
()
crates/kubectl/src/commands/describe.rs:754
↓ 10 callersFunctionmake_test_client
()
crates/kubectl/src/commands/set.rs:1176
↓ 10 callersFunctionparse_duration
(duration: &str)
crates/kubectl/src/commands/wait.rs:197
↓ 10 callersMethodvalidate_crd_spec
Validate CRD specification
crates/controller-manager/src/controllers/crd.rs:311
↓ 10 callersFunctionwants_table
Check if the request wants table format
crates/api-server/src/handlers/table.rs:279
↓ 9 callersMethodadd_column
Add a column definition
crates/api-server/src/handlers/table.rs:95
↓ 9 callersFunctionbuild_ingress
( name: &str, namespace: &str, ingress_class: Option<&str>, rules: &[String], default_back
crates/kubectl/src/commands/create.rs:489
↓ 9 callersFunctionbuild_token_request
( audiences: &[String], duration: Option<&str>, bound_object_kind: Option<&str>, bound_object_
crates/kubectl/src/commands/create.rs:945
↓ 9 callersMethodbuild_webhook_url
Build webhook URL from client config
crates/api-server/src/admission_webhook.rs:360
↓ 9 callersFunctioncheck_resource_version
Check resourceVersion for optimistic concurrency control. Returns Err(Conflict) if the provided resourceVersion doesn't match the stored one. If eith
crates/api-server/src/handlers/lifecycle.rs:46
↓ 9 callersFunctioncreate_test_daemonset
( name: &str, namespace: &str, node_selector: Option<HashMap<String, String>>, )
crates/controller-manager/tests/daemonset_controller_test.rs:51
↓ 9 callersFunctioncreate_test_deployment
(name: &str, namespace: &str, replicas: i32)
crates/controller-manager/tests/hpa_controller_test.rs:12
↓ 9 callersFunctioncreate_test_hpa
( name: &str, namespace: &str, target_name: &str, target_kind: &str, min_replicas: Option<
crates/controller-manager/tests/hpa_controller_test.rs:117
↓ 9 callersFunctioncreate_test_job
(name: &str, namespace: &str, ttl_seconds: i32, finished: bool)
crates/controller-manager/tests/ttl_controller_test.rs:22
↓ 9 callersMethoddecode
Decode frame from bytes Returns (frame, remaining_bytes) on success
crates/api-server/src/spdy.rs:97
↓ 9 callersFunctiondef_key
(group: &str, ver: &str, kind: &str)
crates/api-server/src/handlers/openapi.rs:1296
↓ 9 callersMethodencode
(&self)
crates/kubectl/src/websocket.rs:74
↓ 9 callersFunctiongeneric_table
Helper function to create a table for generic resources with just NAME and AGE
crates/api-server/src/handlers/table.rs:196
↓ 9 callersFunctionmake_container
(name: &str)
crates/kubelet/src/runtime.rs:8122
↓ 9 callersFunctionmake_host_port_pod
Helper: create a pod with a hostPort, scheduled on a node
crates/scheduler/src/advanced.rs:1476
↓ 9 callersFunctionmake_incoming_host_port_pod
Helper: create an unscheduled pod with a hostPort (incoming pod)
crates/scheduler/src/advanced.rs:1497
↓ 9 callersFunctionparse_copy_spec
(source: &str, dest: &str)
crates/kubectl/src/commands/cp.rs:338
↓ 9 callersFunctionparse_resource_arg
Parse "resource_type/name" format into (type, name).
crates/kubectl/src/commands/set.rs:137
↓ 9 callersFunctionparse_taint
Parse a taint string into a TaintSpec. Formats: key=value:Effect -> add taint key:Effect -> add taint (no value) key=value:Effect- -
crates/kubectl/src/commands/taint.rs:22
↓ 9 callersFunctionparse_target
(target: &str)
crates/kubectl/src/commands/debug.rs:49
↓ 9 callersFunctionpod_stub
(name: &str)
crates/api-server/tests/decoder_strict_fields_test.rs:124
↓ 9 callersFunctionread_stored
Read the JSON stored at `key`. Panics if the key is absent.
crates/api-server/tests/decoder_content_type_test.rs:124
↓ 9 callersMethodreconcile_all
(&self)
crates/controller-manager/src/controllers/replicationcontroller.rs:220
↓ 9 callersFunctionresolve_path
(value: &serde_json::Value, path: &str)
crates/kubectl/src/commands/get.rs:102
↓ 9 callersMethodsetup_network
Setup network for a container (ADD operation)
crates/kubelet/src/cni/runtime.rs:68
↓ 9 callersFunctionsetup_test
()
crates/controller-manager/tests/dynamic_provisioner_test.rs:12
↓ 9 callersFunctionsetup_test
()
crates/controller-manager/tests/ttl_controller_test.rs:16
↓ 8 callersMethodadd_finalizer
Add a finalizer to the object
crates/common/src/types.rs:164
↓ 8 callersFunctionapply_json_patch
Apply a single JSON patch operation to an object
crates/api-server/src/admission_webhook.rs:1653
↓ 8 callersFunctionapply_pod_spec_defaults
Apply K8s defaults to a PodSpec. Matches SetDefaults_PodSpec from pkg/apis/core/v1/defaults.go
crates/api-server/src/handlers/defaults.rs:19
↓ 8 callersFunctionbuild_job
( name: &str, namespace: &str, image: Option<&str>, from: Option<&str>, command: &[String]
crates/kubectl/src/commands/create.rs:635
↓ 8 callersFunctionbuild_service
( name: &str, namespace: &str, service_type: &str, tcp: &[String], _selector: Option<&str>
crates/kubectl/src/commands/create.rs:1100
↓ 8 callersFunctionbuild_service
Build a Service JSON object from the given parameters.
crates/kubectl/src/commands/expose.rs:103
↓ 8 callersMethodcheck_and_cleanup
(&self)
crates/controller-manager/src/controllers/ttl_controller.rs:150
↓ 8 callersMethodcheck_eviction_needed
Check if eviction is needed based on current node statistics
crates/kubelet/src/eviction.rs:146
↓ 8 callersFunctioncreate_parent_ref
(resource: &str, name: &str, namespace: Option<&str>)
crates/common/tests/ipaddress_test.rs:23
↓ 8 callersFunctioncreate_pod_with_sidecar
Test helper to create a pod with sidecar containers
crates/kubelet/tests/sidecar_containers_test.rs:7
↓ 8 callersFunctioncreate_test_daemonset
(name: &str, namespace: &str)
crates/controller-manager/tests/daemonset_controller_revision_test.rs:40
↓ 8 callersFunctioncreate_test_node
(name: &str)
crates/controller-manager/tests/daemonset_controller_revision_test.rs:18
↓ 8 callersFunctioncreate_test_role
Helper function to create test Role
crates/api-server/tests/rbac_handler_test.rs:15
↓ 8 callersFunctionempty_pod_spec
()
crates/api-server/tests/finalizers_test.rs:10
↓ 8 callersMethodensure_jump_rule
Ensure a jump rule exists
crates/kube-proxy/src/iptables.rs:717
↓ 8 callersFunctionextract_json_from_k8s_protobuf
Extract JSON from a Kubernetes protobuf envelope. K8s protobuf format: "k8s\0" + protobuf Unknown { raw: bytes, contentType: string } The `raw` field
crates/api-server/src/middleware.rs:454
↓ 8 callersFunctionextract_key
Extract the resource identity key from a WatchEvent's storage key. Storage keys follow `/registry/{resource_type}/{namespace}/{name}` for namespaced
crates/storage/src/workqueue.rs:32
↓ 8 callersFunctionformat_output
(result: &ApplyResult, options: &ApplyOptions)
crates/kubectl/src/commands/apply.rs:258
↓ 8 callersFunctionget_delete_api_path
(kind: &str, namespace: Option<&str>, name: &str)
crates/kubectl/src/commands/delete.rs:226
↓ 8 callersFunctionhandle_delete_with_finalizers_and_propagation
Handle deletion with propagation policy support. When propagation_policy is "Foreground", adds the "foregroundDeletion" finalizer so the garbage colle
crates/api-server/src/handlers/finalizers.rs:79
↓ 8 callersFunctionk8sDelete
( apiPath: string, opts?: { propagationPolicy?: "Orphan" | "Background" | "Foreground" }, )
console/src/engine/query.ts:117
↓ 8 callersFunctionmake_pod_ready
Make a pod look like it's Running and Ready
crates/controller-manager/src/controllers/statefulset.rs:1401
↓ 8 callersFunctionmake_test_client
()
crates/kubectl/src/commands/rollout.rs:582
↓ 8 callersFunctionparse_port_mapping
(port_spec: &str)
crates/kubectl/src/commands/port_forward.rs:32
↓ 8 callersFunctionparse_resource_spec
Parse a resource spec string like "cpu=200m,memory=512Mi" into a map.
crates/kubectl/src/commands/set.rs:759
↓ 8 callersFunctionpod_status_equal
Return true iff `a.status` and `b.status` are semantically equal. Compares via canonical JSON to ignore field ordering and `None` vs `Some(default)`
crates/kubelet/src/kubelet.rs:77
↓ 8 callersMethodquery_params
Build query parameters for the DELETE request.
crates/kubectl/src/commands/delete.rs:86
↓ 8 callersFunctionread_raw
Read the raw stored bytes for a key. Asserts the value is present.
crates/controller-manager/tests/garbage_collector_idempotency_test.rs:224
↓ 8 callersMethodresolve
Resolve force flag: when --force, grace_period becomes 0 and cascade becomes Background.
crates/kubectl/src/commands/delete.rs:78
↓ 8 callersMethodrun_iptables_logged
Run an iptables command with error logging instead of silently discarding errors
crates/kube-proxy/src/iptables.rs:859
↓ 8 callersMethodrun_mutating_webhooks
( &self, operation: &Operation, gvk: &GroupVersionKind, gvr: &GroupVersionReso
crates/api-server/src/admission_webhook.rs:958
↓ 8 callersMethodrun_mutating_webhooks_with_dryrun
( &self, operation: &Operation, gvk: &GroupVersionKind, gvr: &GroupVersionReso
crates/api-server/src/admission_webhook.rs:983
↓ 8 callersFunctionsetup_test
()
crates/api-server/tests/status_subresource_test.rs:8
↓ 8 callersFunctionsetup_test
()
crates/controller-manager/tests/pdb_controller_test.rs:22
↓ 8 callersFunctionsetup_test
()
crates/controller-manager/tests/daemonset_controller_test.rs:12
↓ 8 callersFunctionsetup_test
()
crates/controller-manager/tests/daemonset_controller_revision_test.rs:12
↓ 8 callersMethodstart_container
( &self, pod: &Pod, container: &Container, volume_paths: &HashMap<String, Stri
crates/kubelet/src/runtime.rs:3342
↓ 8 callersMethodsubscribe
Subscribe to watch events for a resource prefix. Returns a broadcast receiver that will receive all events for this prefix. If no etcd watch exists fo
crates/api-server/src/watch_cache.rs:63
↓ 8 callersMethodupdate_pod_status
( &self, pod: &Pod, phase: Phase, reason: Option<&str>, message: Optio
crates/kubelet/src/kubelet.rs:3938
↓ 7 callersFunctionapply_limit_range
( storage: &Arc<S>, namespace: &str, pod: &mut Pod, )
crates/api-server/src/admission.rs:443
↓ 7 callersFunctionapply_pod_template_defaults
Apply K8s defaults to a PodTemplateSpec (used by workload resources). This is called for DaemonSet, Deployment, StatefulSet, ReplicaSet, Job, CronJob.
crates/api-server/src/handlers/defaults.rs:110
↓ 7 callersFunctionapply_schema_defaults
Apply schema defaults from the CRD to a custom resource's spec. Walks the CRD's JSONSchemaProps and for each property with a `default` value, sets it
crates/api-server/src/handlers/custom_resource.rs:1111
↓ 7 callersFunctionapply_strategic_merge_patch
Apply Strategic Merge Patch (Kubernetes-specific) Implements strategic merge with directive markers: - `$patch`: Specifies merge strategy ("replace",
crates/api-server/src/patch.rs:323
↓ 7 callersFunctionbuild_pdb
( name: &str, namespace: &str, selector: &str, min_available: Option<&str>, max_unavailabl
crates/kubectl/src/commands/create.rs:709
↓ 7 callersFunctionbuild_role_binding
( name: &str, namespace: &str, clusterrole: Option<&str>, role: Option<&str>, users: &[Str
crates/kubectl/src/commands/create.rs:774
↓ 7 callersFunctioncreate_deployment
( name: &str, namespace: &str, replicas: i32, image: &str, strategy: Option<deployment::De
crates/controller-manager/tests/deployment_scaling_test.rs:50
↓ 7 callersFunctioncreate_pod_with_init_containers
Test helper to create a pod with init containers
crates/kubelet/tests/init_containers_test.rs:7
↓ 7 callersFunctioncreate_test_crd
()
crates/api-server/src/handlers/crd.rs:1055
↓ 7 callersFunctioncreate_test_cronjob
(name: &str, namespace: &str, schedule: &str)
crates/controller-manager/tests/cronjob_controller_test.rs:19
↓ 7 callersFunctioncreate_test_deployment
(name: &str, namespace: &str, replicas: i32)
crates/controller-manager/tests/deployment_controller_test.rs:45
↓ 7 callersFunctioncreate_test_pv
( storage: &MemoryStorage, name: &str, storage_class: Option<String>, capacity_gb: u32, )
crates/controller-manager/tests/pv_binder_test.rs:22
↓ 7 callersFunctioncreate_test_statefulset
(name: &str, namespace: &str, replicas: i32)
crates/controller-manager/tests/statefulset_controller_test.rs:34
↓ 7 callersFunctioncreate_test_vpa
( name: &str, namespace: &str, target_name: &str, target_kind: &str, update_mode: Option<&
crates/controller-manager/tests/vpa_controller_test.rs:163
↓ 7 callersFunctionencode_protobuf_varint
(buf: &mut Vec<u8>, mut value: u64)
crates/api-server/src/middleware.rs:438
↓ 7 callersFunctionevaluate_jsonpath
Evaluate a jsonpath expression against a JSON value. Supports basic dotted paths, array indexing, and filter expressions.
crates/kubectl/src/commands/get.rs:90
↓ 7 callersFunctionexecute
( client: &ApiClient, resource_type: &str, name: &str, namespace: Option<&str>, )
crates/kubectl/src/commands/describe.rs:56
↓ 7 callersFunctionexecute
Output shell completion code for the specified shell (bash, zsh, fish, or powershell). Equivalent to: kubectl completion bash kubectl completion zsh
crates/kubectl/src/commands/completion.rs:9
↓ 7 callersFunctionextract_ports
Extract container ports from a resource to auto-detect --port when not specified.
crates/kubectl/src/commands/expose.rs:82
↓ 7 callersFunctionformat_age
(timestamp: &str)
crates/kubectl/src/commands/events.rs:286
↓ 7 callersMethodformat_output
Format the output message for a deleted resource.
crates/kubectl/src/commands/delete.rs:117
↓ 7 callersMethodget
(&self, key: &str)
crates/storage/src/rhino.rs:149
↓ 7 callersFunctionget_list_api_path
(resource_type: &str, namespace: &str)
crates/kubectl/src/commands/delete.rs:349
↓ 7 callersFunctionget_pods
(storage: &Arc<MemoryStorage>, namespace: &str)
crates/controller-manager/src/controllers/cascade_tests.rs:243
↓ 7 callersFunctionget_resource_api_path
Get the API path for a single named resource, given CLI resource type aliases.
crates/kubectl/src/commands/delete.rs:416
↓ 7 callersFunctionget_resource_docs
()
crates/kubectl/src/commands/explain.rs:75
↓ 7 callersMethodis_being_deleted
Check if the object is being deleted (has deletion timestamp)
crates/common/src/types.rs:159
↓ 7 callersFunctionmake_daemonset
(name: &str, ns: &str)
crates/controller-manager/tests/daemonset_revision_match_test.rs:48
↓ 7 callersFunctionmake_node
(name: &str)
crates/controller-manager/tests/daemonset_revision_match_test.rs:26
← previousnext →201–300 of 6,481, ranked by callers