Functions — github.com/NVIDIA/nvcf

hub / github.com/NVIDIA/nvcf / functions

Functions25,340 in github.com/NVIDIA/nvcf

⨍ Functions 25,340◇ Types & classes 4,535↳ Endpoints 14

↓ 26 callersMethodScheme

()

src/compute-plane-services/nvca/internal/metrics/instrumented_crclient.go:96

↓ 26 callersMethodSetLevel

(args int, _ *struct{})

src/compute-plane-services/ess-agent/sdk/plugin/logger.go:74

↓ 26 callersFunctionapply_fallback_observation

( aggregator: &mut StatsAggregator, observation: &RequestObservation, )

src/libraries/rust/stargate/crates/pylon-lib/src/stats/collector.rs:438

↓ 26 callersMethodclear

(&mut self)

src/libraries/rust/stargate/crates/pylon-lib/src/registration/router_stream.rs:404

↓ 26 callersFunctioncommandRanThatContains

commandRanThatContains scans the captured fake runs for a substring match. Used for behavior-level wiring assertions only.

tests/bdd/godog_test.go:1064

↓ 26 callersFunctiongetConfigValueWithDefault

getConfigValueWithDefault reads configuration value with proper priority order: 1. Environment variable (via Viper's AutomaticEnv - highest priority)

src/clis/nvcf-cli/internal/client/client.go:415

↓ 26 callersMethodgetNextSequenceNumber

getNextSequenceNumber returns the next sequence number, wrapping at MaxInt

src/invocation-plane-services/llm-api-gateway/api/adapters/openairesponses/sse_writer.go:65

↓ 26 callersFunctionmockKubeClientsForIntegrationTests

()

src/compute-plane-services/nvca/pkg/operator/reconcile/backendk8scache_test.go:479

↓ 25 callersMethodDelete

Delete is used to permanently delete an entry

src/compute-plane-services/ess-agent/sdk/physical/physical.go:58

↓ 25 callersMethodGet

Get is used to fetch an entry

src/compute-plane-services/ess-agent/sdk/physical/physical.go:55

↓ 25 callersFunctionMeter

()

src/invocation-plane-services/llm-api-gateway/telemetry/metrics.go:61

↓ 25 callersMethodParse

(form *multipart.Form)

src/invocation-plane-services/llm-api-gateway/models/openai_audio.go:237

↓ 25 callersMethodPrePopulate

PrePopulate adds a GVK mapping for the given object type to the cache. Use this to pre-warm the cache with known types at initialization.

src/compute-plane-services/nvca/internal/miniservice/gvkcache.go:79

↓ 25 callersFunctionboolPtr

(b bool)

src/compute-plane-services/nvca/pkg/apis/nvcf/v1/nvcfbackend_types_test.go:279

↓ 25 callersMethodcancel

(&self)

src/libraries/rust/stargate/crates/stargate/src/routing_state/reservations.rs:42

↓ 25 callersFunctiongetAppLabels

()

src/compute-plane-services/nvca/pkg/operator/reconcile/reconcile_helpers.go:97

↓ 25 callersFunctionhandler

(w http.ResponseWriter, r *http.Request)

src/clis/nvcf-cli/scripts/admin-mock/main.go:144

↓ 25 callersFunctionprintWarning

(log *logrus.Entry, msg string)

src/compute-plane-services/nvca/internal/clustervalidator/output.go:77

↓ 25 callersFunctionrunning_coordinated_registration_in_cluster

( state: &StargateState, id: &str, cluster_id: &str, url: &str, routing_key: Option<&str>,

src/libraries/rust/stargate/crates/stargate/src/routing_state/tests.rs:74

↓ 25 callersMethodshutdown

(mut self)

src/libraries/rust/stargate/crates/stargate/src/control_plane/registration/health.rs:71

↓ 25 callersFunctionstartMockServer

startMockServer stands up the mock on 127.0.0.1:0 (ephemeral) and returns the http:// FQDN that CreateClient/createWorkerClient expect. The server is

src/libraries/go/worker/nvcf/coverage_test.go:98

↓ 25 callersFunctionwait_for_routing_on_all

(topology: &LifecycleTopology, model: &str, timeout: Duration)

src/libraries/rust/stargate/crates/stargate/tests/suite/lifecycle.rs:2187

↓ 24 callersMethodGetCluster

(ctx context.Context, clusterID string)

src/compute-plane-services/nvca/pkg/operator/reconcile/clustermgmt/reconciler.go:33

↓ 24 callersMethodLog

(args *LoggerArgs, _ *struct{})

src/compute-plane-services/ess-agent/sdk/plugin/logger.go:51

↓ 24 callersMethodSys

Sys is used to return the client for sys-related API calls.

src/compute-plane-services/ess-agent/api/sys.go:26

↓ 24 callersMethodValidate

()

src/invocation-plane-services/vanity-gateway/gateway_config/gateway_config.go:236

↓ 24 callersMethodabort

(&mut self)

src/libraries/rust/stargate/crates/stargate/src/tunnel/body/upload.rs:70

↓ 24 callersMethodabort

(&self)

src/libraries/rust/stargate/crates/stargate-runtime/src/owned_task.rs:92

↓ 24 callersMethodapplyICMSRequestStatusChange

(ctx context.Context, sr *nvcav2beta1new.ICMSRequest, modify func(context.Context, *nvcav2beta1new.ICMSReques

src/compute-plane-services/nvca/pkg/nvca/backendk8scache.go:1921

↓ 24 callersFunctionbase_config

( id: &str, grpc_addr: SocketAddr, http_addr: SocketAddr, )

src/libraries/rust/stargate/crates/stargate/tests/common/mod.rs:600

↓ 24 callersFunctioncheck

(ret, msg)

src/compute-plane-services/nvsnap/tests/cuda_va_preserve_stress.py:54

↓ 24 callersFunctionmustWriteRegular

mustWrite writes a regular file or fails the test.

src/compute-plane-services/nvsnap/internal/treecopy/copier_test.go:33

↓ 24 callersFunctionnccl_real_dlsym

src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/nccl_intercept.c:159

↓ 24 callersFunctionnewObjectMeta

(name, namespace string, labels map[string]string)

src/compute-plane-services/nvca/pkg/nodefeatures/dynamic_client_test.go:1370

↓ 24 callersFunctionnewTestClient

newTestClient spins up an httptest server with the supplied handler and returns an NgcClient pointed at it. The server is registered for cleanup. http

src/compute-plane-services/worker-task/pkg/ngc/ngc_test.go:57

↓ 24 callersFunctionnsSelector

(ns string)

src/compute-plane-services/nvca/internal/clustervalidator/netpol_test.go:65

↓ 24 callersFunctionparseRates

parseRates parses a comma-separated rate string (e.g. "5-S,300-H") into individual RateLimiterEntry instances, each with its own limiter. A single rat

src/invocation-plane-services/ratelimiter/rate_limiter.go:183

↓ 24 callersMethodwith_http_listener

(mut self, listener: std::net::TcpListener)

src/libraries/rust/stargate/crates/stargate/src/runtime.rs:176

↓ 23 callersMethodDecodeJSON

DecodeJSON will decode the response body to a JSON structure. This will consume the response body, but will not close it. Close must still be called.

src/compute-plane-services/ess-agent/api/response.go:45

↓ 23 callersMethodEvaluate

Evaluate implements Authorizer.

src/control-plane-services/helm-reval/pkg/authorizers/icms_introspect.go:140

↓ 23 callersMethodLoad

Load reads the state from disk

src/clis/nvcf-cli/internal/state/state.go:138

↓ 23 callersFunctionNewHTTPClientV2

NewHTTPClientV2 creates a new HTTP client with a dedicated underlying HTTP client. Each instance gets its own HTTP client for complete isolation and c

src/libraries/go/lib/pkg/nvkit/clients/http_client.go:333

↓ 23 callersFunctionNewTrafficShadower

(maxConcurrent int, timeout time.Duration)

src/invocation-plane-services/vanity-gateway/gateway/shadow.go:52

↓ 23 callersMethodPostICMSInstanceRequestStatusUpdates

(ctx context.Context)

src/compute-plane-services/nvca/pkg/nvca/agent.go:1881

↓ 23 callersMethodPublish

(ctx context.Context, msg *gcppubsub.Message)

src/invocation-plane-services/llm-api-gateway/pubsub/publisher.go:38

↓ 23 callersMethodSetNamespace

SetNamespace sets the namespace supplied either via the environment variable or via the command line.

src/compute-plane-services/ess-agent/api/client.go:944

↓ 23 callersMethodWithStaticGPUCapacity

(gpuCap uint64)

src/compute-plane-services/nvca/pkg/nvca/backendk8scache.go:363

↓ 23 callersFunctionbaseValidConfig

baseValidConfig is the minimal config that lets NewNVCFWorker succeed.

src/compute-plane-services/worker-utils/worker/newworker_test.go:50

↓ 23 callersFunctiondefault_policy

()

src/control-plane-services/function-autoscaler/crates/server/src/scaling/mod.rs:493

↓ 23 callersFunctionexecuteMaintenance

(t *testing.T, stdin string, args ...string)

src/clis/nvcf-cli/cmd/cluster_agent_maintenance_test.go:171

↓ 23 callersMethodgeneration

(&self)

src/libraries/rust/stargate/crates/stargate/src/routing_state/registration.rs:102

↓ 23 callersFunctiongetHelmPersistentStorageWebhook

(defaultStorageClassName string, internalPersistentStorageEnabled bool)

src/compute-plane-services/nvca/pkg/webhook/helm_persistent_storage_webhook.go:54

↓ 23 callersMethodheaders

()

src/invocation-plane-services/llm-api-gateway/api/ratelimit.go:318

↓ 23 callersFunctionmakeNamespace

(name string)

src/compute-plane-services/nvca/internal/clustervalidator/netpol_test.go:38

↓ 23 callersFunctionnewAC

(token string)

src/control-plane-services/helm-reval/pkg/authorizers/icms_introspect_test.go:66

↓ 23 callersFunctionnewBackend

(t *testing.T)

src/compute-plane-services/nvsnap/internal/webhook/mutate_test.go:47

↓ 23 callersFunctionnewFakeMaintainer

(dynObjs, k8sObjs []runtime.Object)

src/clis/nvcf-cli/internal/clusteragent/k8s_maintainer_test.go:47

↓ 23 callersFunctionnewTestBackend

(t *testing.T, opts ...func(*PerCapturePVCBackend))

src/compute-plane-services/nvsnap/internal/checkpointstore/percapture_pvc_test.go:101

↓ 23 callersFunctionnewTestLogger

(t *testing.T)

src/compute-plane-services/worker-utils/worker/newworker_test.go:42

↓ 23 callersFunctionnvsnap_zmq_is_enabled

src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:825

↓ 23 callersFunctionrecordK8sAPICall

(ctx context.Context, obj any, clientErr error, subResource ...string)

src/compute-plane-services/nvca/internal/metrics/instrumented_crclient.go:145

↓ 23 callersFunctionrecv_observation

( rx: &flume::Receiver<crate::RequestObservationEvent>, context: &'static str, )

src/libraries/rust/stargate/crates/pylon-lib/src/request_observer.rs:741

↓ 23 callersFunctionresult

(id: usize, backend: &str, ttft: u64, ttlt: u64)

src/libraries/rust/stargate/crates/stargate-bench/src/score.rs:916

↓ 23 callersFunctionsetup_mock_backend

()

src/libraries/rust/stargate/crates/stargate/src/tunnel/tests.rs:60

↓ 23 callersMethodupsert_backend

( &self, backend: Arc<RoutedInferenceServerSnapshot>, )

src/libraries/rust/stargate/crates/stargate/src/routing_state/clusters.rs:37

↓ 23 callersFunctionwithFakeMaintainer

(t *testing.T, f *fakeMaintainer)

src/clis/nvcf-cli/cmd/cluster_agent_maintenance_test.go:140

↓ 22 callersMethodClone

Clone creates a new client with the same configuration. Note that the same underlying http.Client is used; modifying the client from more than one gor

src/compute-plane-services/ess-agent/api/client.go:1153

↓ 22 callersMethodCopy

Copy walks src and replicates entries into dst. Returns total regular-file bytes + entry count copied (including dirs and symlinks in entry count, reg

src/compute-plane-services/nvsnap/internal/treecopy/copier.go:162

↓ 22 callersMethodDial

(network, addr string)

src/compute-plane-services/ess-agent/sdk/helper/ldaputil/ldap.go:33

↓ 22 callersFunctionFileMode

FileMode returns a pointer to the given os.FileMode.

src/compute-plane-services/ess-agent/config/convert.go:61

↓ 22 callersFunctionGetStateManagerForCurrentCommand

GetStateManagerForCurrentCommand returns the appropriate state manager for the current config context

src/clis/nvcf-cli/cmd/root.go:163

↓ 22 callersFunctionGetUseUUIDForRequestObjName

GetUseUUIDForRequestObjName returns whether request object names use UUID (true) or RequestID (false).

src/compute-plane-services/nvca/pkg/nvca/backendk8scache.go:113

↓ 22 callersFunctionNewModel

NewModel constructs a Model. In ModeInstall (the default), all 8 phases are pre-populated as pending. In ModeStatus and ModeCheck, no phases are popul

src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:314

↓ 22 callersMethodPeek

Peek returns the limit for the given identifier, without modification on current values. NOT USED

src/invocation-plane-services/ratelimiter/olric_store.go:158

↓ 22 callersMethodWithInterval

(interval time.Duration)

src/libraries/go/lib/pkg/core/eventstream.go:45

↓ 22 callersMethodWrite

Write is used to implement io.Writer.

src/compute-plane-services/ess-agent/logging/logfile.go:130

↓ 22 callersMethodcancel

(&mut self)

src/libraries/rust/stargate/crates/pylon-lib/src/request_observer/embeddings.rs:119

↓ 22 callersMethodcheckGPUs

checkGPUs performs a GPU availability check and handles state transitions.

src/compute-plane-services/nvca/pkg/nvca/gpumonitor.go:265

↓ 22 callersFunctionfile_nvct_proto_rawDescGZIP

()

src/libraries/go/worker/proto/nvct/nvct.pb.go:1586

↓ 22 callersFunctiongetNBAnnotations

(nb *nvidiaiov1.NVCFBackend)

src/compute-plane-services/nvca/pkg/operator/reconcile/reconcile_helpers.go:105

↓ 22 callersFunctionparse_args

(extra: &[&str])

src/libraries/rust/stargate/crates/pylon/src/main.rs:295

↓ 22 callersMethodreplace

( &mut self, target: &RoutingTargetKey, candidates: &[RoutedClusterSnapshot],

src/libraries/rust/stargate/crates/stargate/src/load_balancer/groq_multiregion/cache_affinity.rs:220

↓ 22 callersFunctionstart_dummy_backend

Starts a dummy HTTP backend with chat completions and health endpoints. Returns the backend's `SocketAddr`.

src/libraries/rust/stargate/crates/stargate/tests/common/mod.rs:931

↓ 22 callersFunctiontestChild

(t *testing.T)

src/compute-plane-services/ess-agent/child/child_test.go:33

↓ 22 callersMethodwith_grpc_listener

(mut self, listener: std::net::TcpListener)

src/libraries/rust/stargate/crates/stargate/src/runtime.rs:166

↓ 21 callersMethodAdd

Add adds the given dependency to the list of monitored dependencies and start the associated view. If the dependency already exists, no action is take

src/compute-plane-services/ess-agent/watch/watcher.go:148

↓ 21 callersMethodComplete

(env Environment)

src/libraries/go/lib/pkg/types/nvca/config/types.go:345

↓ 21 callersMethodCreateICMSCreationMessageRequest

(ctx context.Context, msg translate.CreationQueueMessageMetadataGetter, msgReceipt, msgID, queueURL string,

src/compute-plane-services/nvca/pkg/nvca/backendk8scache.go:2056

↓ 21 callersMethodList

List is used to list all the keys under a given prefix, up to the next prefix.

src/compute-plane-services/ess-agent/sdk/physical/physical.go:62

↓ 21 callersFunctionNewCopier

NewCopier returns a Copier that skips the given absolute exclude paths. A nil log gets a default logrus entry.

src/compute-plane-services/nvsnap/internal/treecopy/copier.go:105

↓ 21 callersFunctionNewProxiedClient

new type to force usage of NewProxiedClient

src/compute-plane-services/worker-utils/worker/httpstream/request_stream.go:45

↓ 21 callersFunctionNewQueueManager

( bk8s *BackendK8sCache, bsc health.StatusGetter, qc queue.Client, qcreds types.QueueCredentials, fff fea

src/compute-plane-services/nvca/pkg/nvca/queue_manager.go:111

↓ 21 callersFunctionNewVanityDirector

(nvcfApiHost string, transport http.RoundTripper)

src/invocation-plane-services/vanity-gateway/gateway/vanity_director.go:122

↓ 21 callersMethodPatch

(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption)

src/compute-plane-services/nvca/pkg/storage/reconcile.go:549

↓ 21 callersMethodTimeout

()

src/compute-plane-services/worker-utils/worker/work_helpers_test.go:118

↓ 21 callersMethodView

─── View ───────────────────────────────────────────────────────────────────── View renders the dashboard. View is pure: every state lives on the rece

src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:778

↓ 21 callersFunctioncompleted_observation

( input_tokens: u64, output_messages: u64, output_tokens: u64, time_to_first_o

src/libraries/rust/stargate/crates/pylon-lib/src/stats/collector.rs:458

↓ 21 callersMethodexit

(&self, _span: &tracing::span::Id)

src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:101

↓ 21 callersFunctionhasNVCFBackendChangedCheck

(ctx context.Context, nb *nvidiaiov1.NVCFBackend)

src/compute-plane-services/nvca/pkg/operator/reconcile/rollout.go:128

↓ 21 callersFunctionkubectxFor

kubectxFor returns the kubeconfig context that phase phaseNum's kubectl / helmfile invocations should target. Returns "" in single-cluster mode (both

src/clis/nvcf-cli/cmd/self_hosted_up.go:1506

← previous next →401–500 of 25,340, ranked by callers