Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/NVIDIA/nvcf
/ functions
Functions
25,340 in github.com/NVIDIA/nvcf
⨍
Functions
25,340
◇
Types & classes
4,535
↳
Endpoints
14
↓ 17 callers
Function
mutateCertificates
mutateCertificates adds init containers and volumes for certificate management This matches the kyverno-cert-mount.yaml logic: 1. a-toolbox: copies bu
src/compute-plane-services/nvcf-unbound/cmd/webhook/mutate_certificates.go:39
↓ 17 callers
Function
newTestClient
(httpClient *http.Client)
src/clis/nvcf-cli/internal/client/clusters_test.go:34
↓ 17 callers
Function
newTestController
(secretNames []string, objects ...runtime.Object)
src/compute-plane-services/nvca/pkg/operator/mirror/controller_test.go:38
↓ 17 callers
Function
newTestServer
(objects ...runtime.Object)
src/compute-plane-services/nvsnap/internal/server/server_test.go:37
↓ 17 callers
Method
observe_sse_chunk
(&mut self, raw_data: &str, output_token_delta: Option<u64>)
src/libraries/rust/stargate/crates/pylon-lib/src/request_quality_monitor/recorder.rs:75
↓ 17 callers
Function
parse_args
(extra: &[&str])
src/libraries/rust/stargate/crates/stargate/src/main.rs:476
↓ 17 callers
Function
spansByName
(spans tracetest.SpanStubs, name string)
src/invocation-plane-services/vanity-gateway/gateway/shadow_tracing_test.go:46
↓ 17 callers
Method
spawn_critical
(&self, name: &'static str, task: F)
src/libraries/rust/stargate/crates/stargate-runtime/src/critical.rs:97
↓ 17 callers
Method
tunnel_connections
(&self)
src/libraries/rust/stargate/crates/stargate/src/routing_state/registration.rs:128
↓ 16 callers
Method
Auth
Auth is used to return the client for credential-backend API calls.
src/compute-plane-services/ess-agent/api/auth.go:35
↓ 16 callers
Method
Close
()
src/invocation-plane-services/grpc-proxy/proxy/worker/connections.go:126
↓ 16 callers
Method
Consul
Consul returns the Consul client for this set.
src/compute-plane-services/ess-agent/dependency/client_set.go:511
↓ 16 callers
Method
DecodeJSON
DecodeJSON decodes the 'Value' present in StorageEntry.
src/compute-plane-services/ess-agent/sdk/logical/storage.go:56
↓ 16 callers
Function
DefaultHTTPClientV2
DefaultHTTPClientV2 returns an HTTP client with sane defaults that shares a singleton HTTP client. Multiple instances returned by this function will s
src/libraries/go/lib/pkg/nvkit/clients/http_client.go:284
↓ 16 callers
Function
EnsureNetworkPoliciesFunctionNamespace
( ctx context.Context, namespace string, nps map[string]string, ffFetcher featureflag.Fetcher, k8sClient
src/compute-plane-services/nvca/internal/util/k8sutil/netpol.go:81
↓ 16 callers
Method
HasPath
HasPath returns if the prefix for the path exists regardless if it is a path (ending with /) or a prefix for a leaf node
src/compute-plane-services/ess-agent/sdk/helper/pathmanager/pathmanager.go:121
↓ 16 callers
Function
NewStreamDirector
(functionInvoker FunctionInvoker)
src/invocation-plane-services/grpc-proxy/proxy/director.go:78
↓ 16 callers
Method
RemainingValue
()
src/invocation-plane-services/llm-api-gateway/ratelimit/ratelimit_result.go:49
↓ 16 callers
Function
SelectRenderer
SelectRenderer picks an EventSink based on opts and ambient state. The matrix is documented in SRD/SDD §6.4.4 and implemented row-by-row below in prio
src/clis/nvcf-cli/internal/selfhosted/progress/select.go:113
↓ 16 callers
Function
StringPresent
StringPresent returns a boolean indicating if the pointer is nil, or if the pointer is pointing to the zero value..
src/compute-plane-services/ess-agent/config/convert.go:241
↓ 16 callers
Method
SyncQueues
(ctx context.Context)
src/compute-plane-services/nvca/pkg/nvca/queue_manager.go:256
↓ 16 callers
Method
UpdateRestoreStatus
UpdateRestoreStatus updates the status of a restore.
src/compute-plane-services/nvsnap/internal/db/restore.go:41
↓ 16 callers
Method
all
()
src/compute-plane-services/ess-agent/sdk/helper/authmetadata/auth_metadata.go:66
↓ 16 callers
Method
command
(&self)
src/libraries/rust/stargate/crates/stargate-bench/src/k8s/kubectl.rs:99
↓ 16 callers
Function
defaultITRequest
()
src/compute-plane-services/worker-utils/worker/integration_test.go:192
↓ 16 callers
Method
demoUpdateState
--- Helpers --- demoUpdateState atomically mutates demo state and broadcasts via WebSocket. Also persists to the DB catalog for crash recovery.
src/compute-plane-services/nvsnap/internal/server/demo.go:1082
↓ 16 callers
Method
encode
(out io.Writer, objs []runtime.Object)
src/control-plane-services/helm-reval/reval/serialize.go:204
↓ 16 callers
Method
excludes_cluster
(&self, cluster_id: &str)
src/libraries/rust/stargate/crates/stargate/src/load_balancer/request.rs:38
↓ 16 callers
Function
generate_self_signed_cert
Generates a self-signed certificate and private key in PEM format. The certificate has SANs for `localhost` and `stargate`.
src/libraries/rust/stargate/crates/stargate-tls/src/lib.rs:29
↓ 16 callers
Function
getRequestsNamespace
(nb *nvidiaiov1.NVCFBackend)
src/compute-plane-services/nvca/pkg/operator/reconcile/nvcaagent_reconcile.go:217
↓ 16 callers
Function
labelSelectorMatches
labelSelectorMatches evaluates a LabelSelector against a set of labels. A nil selector never matches. An empty selector (no matchLabels, no matchExpre
src/compute-plane-services/nvca/internal/clustervalidator/netpol.go:516
↓ 16 callers
Method
metadata
(self)
src/libraries/rust/stargate/crates/stargate-bench/src/microbench/lb.rs:164
↓ 16 callers
Function
metrics_text
(registry: Arc<prometheus::Registry>)
src/libraries/rust/stargate/crates/stargate/tests/suite/proxy_contract.rs:55
↓ 16 callers
Function
newClientForMock
newClientForMock builds a real nvct.Client wired to the ephemeral mock.
src/libraries/go/worker/nvct/coverage_test.go:145
↓ 16 callers
Function
newNVCTTestClient
newNVCTTestClient wires a Client to point exclusively at an httptest server for the NVCT base URL while leaving the NVCF base URL pointed somewhere in
src/clis/nvcf-cli/internal/client/tasks_test.go:33
↓ 16 callers
Function
nvsnap_zmq_sock_from_ptr
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:897
↓ 16 callers
Function
parse_sse_events
(body: &str)
src/libraries/rust/stargate/crates/stargate/tests/common/sse.rs:24
↓ 16 callers
Function
resetComputePlaneFlags
(t *testing.T)
src/clis/nvcf-cli/cmd/self_hosted_compute_plane_test.go:35
↓ 16 callers
Method
resolve
Returns a cached token, minting a fresh one when none is cached or it is near expiry. The lock is held across the refresh so callers coalesce onto one
src/libraries/rust/stargate/crates/stargate-auth/src/client_credentials.rs:76
↓ 16 callers
Method
sendProgressUpdate
(ctx context.Context, progress Progress)
src/compute-plane-services/worker-task/internal/progress/progress.go:153
↓ 16 callers
Function
send_json_proxy_request
( send: &mut stargate_protocol::SendStream, path: &str, model: &str, request_id: &str, bod
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:1094
↓ 16 callers
Method
setGPUs
(gpus []types.BackendGPU)
src/compute-plane-services/nvca/pkg/nvca/gpumonitor_test.go:62
↓ 16 callers
Function
setupTestServer
(_ *testing.T, handler http.HandlerFunc)
src/libraries/go/lib/pkg/fnds/client/client_test.go:46
↓ 16 callers
Method
shutdown
(self)
src/libraries/rust/stargate/crates/stargate/tests/suite/quic_forwarding.rs:85
↓ 16 callers
Function
sortedKeys
(set map[string]struct{})
tools/collect-dependencies/common.go:150
↓ 16 callers
Function
start_lifecycle_topology
( transport: TransportMode, stargates: StargateTopology, )
src/libraries/rust/stargate/crates/stargate/tests/suite/lifecycle.rs:1651
↓ 16 callers
Method
styleMuted
()
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1908
↓ 16 callers
Function
testCatalog
()
tools/docs-version-sync/main_test.go:757
↓ 16 callers
Function
traceError
(span trace.Span, err error)
src/libraries/go/worker/proxy/proxy.go:385
↓ 16 callers
Function
validateConfig
(cfg *NetworkCheckConfig)
src/compute-plane-services/nvca/internal/clustervalidator/config.go:135
↓ 16 callers
Function
wait_until
( label: &str, timeout: Duration, poll_interval: Duration, mut poll: F, )
src/libraries/rust/stargate/crates/stargate/tests/common/mod.rs:192
↓ 15 callers
Method
AllInstancesTerminatedAndReported
AllInstancesTerminatedAndReported returns if all NVCF worker instances for backend are terminated and reported to ICMS
src/compute-plane-services/nvca/pkg/nvca/computebackend.go:54
↓ 15 callers
Method
Close
()
src/invocation-plane-services/grpc-proxy/proxy/director.go:159
↓ 15 callers
Function
Fatalf
(format string, args ...interface{})
src/compute-plane-services/ess-agent/dependency/dependency_test.go:455
↓ 15 callers
Method
Get
(ctx context.Context, key string)
src/compute-plane-services/ess-agent/sdk/physical/cache.go:176
↓ 15 callers
Method
Key
Key returns a boolean indicating whether the given key exists in the map.
src/compute-plane-services/ess-agent/template/scratch.go:21
↓ 15 callers
Function
NewHTTPMiddleware
HTTPMiddleware builds a http middleware that: - Adds contexted request logger with {method,path,ip} into request.Context - Collects <latencyMetricsN
src/libraries/go/lib/pkg/core/httpservice.go:346
↓ 15 callers
Function
NewWorkerConnection
(requestId uuid.UUID, functionId, functionVersionId string, onActive, onInactive func())
src/invocation-plane-services/grpc-proxy/proxy/worker/worker.go:38
↓ 15 callers
Method
Put
(in ChartCacheInput, r io.ReadSeeker, size int64)
src/compute-plane-services/nvca/internal/miniservice/chartcache/chartcache.go:44
↓ 15 callers
Method
RecordModelCacheResult
RecordModelCacheResult records a model cache operation result. result should be "success" or "failure". failureReason should be empty string for succe
src/compute-plane-services/nvca/internal/metrics/metrics.go:1010
↓ 15 callers
Method
RegisterRoutes
(group *echo.Group)
src/invocation-plane-services/llm-api-gateway/api/chat_handler.go:53
↓ 15 callers
Method
SetClusterValidatorSummary
SetClusterValidatorSummary atomically updates every cluster-validator metric from a single run's summary. The protocol: 1. Compute the new label tuple
src/compute-plane-services/nvca/internal/metrics/metrics.go:1234
↓ 15 callers
Method
Stop
Stop halts the execution of this runner and its subprocesses.
src/compute-plane-services/ess-agent/manager/runner.go:520
↓ 15 callers
Method
abort
(self)
src/libraries/rust/stargate/crates/pylon-lib/src/registration/calibration.rs:105
↓ 15 callers
Function
buildChiMux
buildChiMux constructs the router from an already-validated GatewayConfig. Callers must ensure mappings have been validated (SetupConfigWithConfigPath
src/invocation-plane-services/vanity-gateway/gateway/h2.go:60
↓ 15 callers
Method
close
(self)
src/libraries/rust/stargate/crates/stargate/src/control_plane/registration.rs:354
↓ 15 callers
Function
egressAllowsTraffic
egressAllowsTraffic returns true when pods in srcNS (matching srcSelector) are permitted to send traffic to the destination namespace on port/proto.
src/compute-plane-services/nvca/internal/clustervalidator/netpol.go:309
↓ 15 callers
Function
file_sdk_database_dbplugin_v5_proto_database_proto_rawDescGZIP
()
src/compute-plane-services/ess-agent/sdk/database/dbplugin/v5/proto/database.pb.go:997
↓ 15 callers
Function
getClientConnFromProxy
(ctx context.Context, work *pb.WorkerInvokeFunctionRequest, h3 *h3ConnectionCache)
src/libraries/go/worker/proxy/proxy.go:349
↓ 15 callers
Function
getConfigValue
getConfigValue reads configuration value with proper priority order: 1. Environment variable (highest priority - explicit user override) 2. Config fil
src/clis/nvcf-cli/internal/client/client.go:401
↓ 15 callers
Function
getFileOwnership
(path string)
src/compute-plane-services/ess-agent/renderer/file_ownership.go:19
↓ 15 callers
Function
isErrHTTPAuthIssue
(err error)
src/control-plane-services/helm-reval/reval/helm_template.go:610
↓ 15 callers
Function
make_stargate_runtime_with_lb
( id: &str, lb_config_path: Option<String>, )
src/libraries/rust/stargate/crates/stargate/tests/common/mod.rs:806
↓ 15 callers
Function
mergeMaps
(m1, m2 map[string]string)
src/compute-plane-services/nvca/pkg/nvca/backendk8scache.go:2610
↓ 15 callers
Method
newAgentConfig
(ctx context.Context, nb *nvidiaiov1.NVCFBackend)
src/compute-plane-services/nvca/pkg/operator/reconcile/nvcaagent_reconcile.go:2217
↓ 15 callers
Function
newConfigMapClient
newConfigMapClient is an internal helper that constructs a ConfigMapClient with the default mappers plus optional ones provided by the caller.
src/compute-plane-services/nvca/pkg/operator/reconcile/clustermgmt/configmapclient.go:53
↓ 15 callers
Function
nvsnap_zmq_maybe_replay_after_restore
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:1489
↓ 15 callers
Method
on_upstream_response_headers
( &mut self, _response_headers: &HeaderMap, status: u16, )
src/libraries/rust/stargate/crates/pylon-lib/src/request_observer.rs:206
↓ 15 callers
Function
passingToolSpec
passingToolSpec returns a BinarySpec that always reports the given version as passing.
src/clis/nvcf-cli/internal/selfhosted/preflight_test.go:379
↓ 15 callers
Function
printSummary
printSummary outputs the final validation results and returns an error if the cluster is not ready.
src/compute-plane-services/nvca/internal/clustervalidator/validator.go:195
↓ 15 callers
Function
rateLimitSubjectKey
(rateLimitKey string, projectID string, routingKey string)
src/invocation-plane-services/llm-api-gateway/api/auth_middleware.go:140
↓ 15 callers
Method
recv_body
(&mut self)
src/libraries/rust/stargate/crates/stargate/src/tunnel/body.rs:97
↓ 15 callers
Method
register_inference_server
( &self, request: Request<tonic::Streaming<InferenceServerRegistration>>, )
src/libraries/rust/stargate/crates/stargate/src/control_plane.rs:263
↓ 15 callers
Function
register_int_counter_vec
( registry: &Registry, opts: Opts, labels: &[&str], )
src/libraries/rust/stargate/crates/pylon-lib/src/stats/metrics.rs:908
↓ 15 callers
Method
request_policy_mut
(&mut self)
src/libraries/rust/stargate/crates/stargate/src/load_balancer/config.rs:257
↓ 15 callers
Function
resolveICMSURL
resolveICMSURL picks the ICMS endpoint for cluster register, in priority order: 1. --icms-url flag (explicit user override). 2. NVCF_ICMS_URL env var.
src/clis/nvcf-cli/cmd/self_hosted.go:147
↓ 15 callers
Method
reverse_tunnel
(self)
src/libraries/rust/stargate/crates/stargate/tests/suite/lifecycle.rs:59
↓ 15 callers
Function
routed_backend
( cluster_id: &str, inference_server_id: &str, output_tps: f64, last_mean_input_tps: f64,
src/libraries/rust/stargate/crates/stargate/src/routing_state/tests.rs:110
↓ 15 callers
Method
run
(ctx context.Context)
src/compute-plane-services/nvca/pkg/webhook/cmd.go:202
↓ 15 callers
Function
setupLogger
()
src/libraries/go/worker/proxy/proxy_test.go:184
↓ 15 callers
Method
signal
(s os.Signal)
src/compute-plane-services/ess-agent/child/child.go:384
↓ 15 callers
Method
state
(&self)
src/libraries/rust/stargate/crates/stargate/src/runtime.rs:348
↓ 15 callers
Method
stop
(&mut self)
src/libraries/rust/stargate/crates/stargate/tests/suite/model_routing.rs:230
↓ 15 callers
Function
stringValue
(value *string)
src/clis/nvcf-cli/cmd/function_llm_model_test.go:543
↓ 15 callers
Function
target_with_model
(model_id: &str)
src/libraries/rust/stargate/crates/stargate/src/load_balancer/tests.rs:31
↓ 15 callers
Function
validQueue
validQueue builds a Queue with all resources set to the expected healthy defaults.
src/compute-plane-services/nvca/pkg/nvca/enforce/kaischeduler/kaischeduler_test.go:258
↓ 15 callers
Function
wait_for_model_stats
( runtime_state: &PylonRuntimeState, model_id: &str, context: &str, predicate:
src/libraries/rust/stargate/crates/pylon-lib/src/stats/collector.rs:670
↓ 14 callers
Method
Authenticate
(ctx context.Context, req *types.Request)
src/control-plane-services/nats-auth-callout/internal/plugins/nkey/nkey.go:98
↓ 14 callers
Method
Default
(_ context.Context, obj runtime.Object)
src/compute-plane-services/nvca/pkg/webhook/enforcement_webhook.go:63
↓ 14 callers
Method
Fetch
Fetch queries the Vault API
src/compute-plane-services/ess-agent/dependency/vault_read.go:97
← previous
next →
601–700 of 25,340, ranked by callers