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

↓ 35 callersMethodfinish

(self, connection: TunnelConnection)

src/libraries/rust/stargate/crates/stargate/src/tunnel/connection.rs:288

↓ 34 callersMethodDelete

(in ChartCacheInput)

src/compute-plane-services/nvca/internal/miniservice/chartcache/chartcache.go:45

↓ 34 callersMethodGet

(in ImageCacheInput)

src/control-plane-services/helm-reval/reval/cache/image_cache.go:28

↓ 34 callersFunctionGetLogger

(ctx context.Context)

src/libraries/go/lib/pkg/core/context.go:112

↓ 34 callersMethodRequestContext

()

src/invocation-plane-services/llm-api-gateway/api/context.go:94

↓ 34 callersMethodSyncAllICMSRequests

(ctx context.Context)

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

↓ 34 callersMethodWaitForCacheSync

WaitForCacheSync blocks until all started informers' caches were synced or the stop channel gets closed.

src/compute-plane-services/nvca/pkg/client/informers/externalversions/factory.go:253

↓ 34 callersFunctionWithDefaultMetrics

(parent context.Context, ncaID, clusterName, clusterGroup, version string, opts ...DefaultMetricsOption)

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

↓ 34 callersFunctionWithRegisterer

(registerer prometheus.Registerer)

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

↓ 34 callersFunctionmake_target

(routing_key: Option<&str>, model_id: &str)

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

↓ 34 callersFunctionnestedString

--- unstructured field helpers (missing fields degrade to zero values) ---

src/clis/nvcf-cli/internal/clusteragent/k8s_inspector.go:309

↓ 34 callersMethodnowFunc

()

src/clis/nvcf-cli/internal/selfhosted/status/collector.go:218

↓ 34 callersFunctionnvsnap_zmq_restore_detected

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

↓ 34 callersMethodsetupOAuthClientSecrets

setupOAuthClientSecrets creates OAuth client secrets.

src/compute-plane-services/nvca/pkg/operator/reconcile/nvcaagent_reconcile.go:1181

↓ 34 callersMethodwritef

writef wraps fmt.Fprintf with a format string that callers MUST hard-code. Never pass user-supplied or pre-formatted strings as `format`; doing so cou

src/clis/nvcf-cli/internal/selfhosted/progress/render_plain.go:276

↓ 33 callersMethodDrain

Drain puts the cluster into CordonAndDrain maintenance.

src/clis/nvcf-cli/internal/clusteragent/maintainer.go:43

↓ 33 callersMethodUserContext

()

src/invocation-plane-services/llm-api-gateway/api/context.go:59

↓ 33 callersFunctionbuild

build is a small helper that constructs a worker from a baseline that is mutated by mutate. It returns the worker and error from NewNVCTWorker.

src/compute-plane-services/worker-task/internal/worker/worker_newnvctworker_test.go:58

↓ 33 callersMethodclose

(self)

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

↓ 33 callersFunctioncreate_load_balancer_with_config

( config: &LoadBalancerAlgorithmConfig, )

src/libraries/rust/stargate/crates/stargate/src/load_balancer/factory.rs:26

↓ 33 callersFunctionmake_stargate_runtime

(id: &str)

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

↓ 33 callersMethodread

()

src/libraries/go/lib/pkg/nvkit/auth/tokenstore.go:41

↓ 32 callersMethodClose

Close closes the client connections

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

↓ 32 callersMethodCode

()

src/compute-plane-services/ess-agent/sdk/logical/error.go:80

↓ 32 callersMethodGetZapLogger

GetZapLogger - return zap logger

src/libraries/go/lib/pkg/nvkit/logs/logs.go:74

↓ 32 callersFunctionNewAgent

(ctx context.Context, opts *AgentOptions)

src/compute-plane-services/nvca/pkg/operator/reconcile/agent.go:271

↓ 32 callersMethodSync

Sync implements zapcore.Core.

src/libraries/go/lib/pkg/zapotelspan/adaptor.go:108

↓ 32 callersFunctionget_desired_instances

( utilization_samples: &[f64], policy: &ResolvedScalingPolicy, current_instances: usize, decay

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

↓ 32 callersMethodmakeRequest

makeRequest makes an HTTP request to the NVCF API using direct HTTP calls

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

↓ 32 callersFunctionmkPod

helper: build a pod with the given annotations + ready transition. readyAfter=0 means not-ready. Created/ready times are absolute.

src/compute-plane-services/nvsnap/internal/podtimings/podtimings_test.go:33

↓ 32 callersMethodsend_body

(&mut self, body: bytes::Bytes)

src/libraries/rust/stargate/crates/protocol/src/stream.rs:51

↓ 31 callersMethodAddInt32

AddInt32 implements zapcore.ObjectEncoder.

src/libraries/go/lib/pkg/zapotelspan/encoder.go:112

↓ 31 callersMethodGetCheckpoint

GetCheckpoint returns a single checkpoint by ID.

src/compute-plane-services/nvsnap/internal/db/checkpoint.go:389

↓ 31 callersMethodGetValue

()

src/compute-plane-services/ess-agent/sdk/plugin/pb/backend.pb.go:2021

↓ 31 callersMethodcluster_candidates_for_target

( &self, target: &RoutingTargetKey, )

src/libraries/rust/stargate/crates/stargate/src/routing_state/mod.rs:233

↓ 31 callersFunctionparse

(line: &[u8])

src/libraries/rust/stargate/crates/pylon-lib/src/stats/engine_stats_stream.rs:1116

↓ 31 callersFunctionspanAttr

(s tracetest.SpanStub, key attribute.Key)

src/invocation-plane-services/vanity-gateway/gateway/shadow_tracing_test.go:56

↓ 30 callersMethodDebug

(msg string, keysAndValues ...any)

src/libraries/go/lib/pkg/http/logger.go:41

↓ 30 callersMethodDestroy

()

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

↓ 30 callersMethodHandleRequest

HandleRequest is the logical.Backend implementation.

src/compute-plane-services/ess-agent/sdk/framework/backend.go:206

↓ 30 callersMethodLister

()

src/compute-plane-services/nvca/pkg/client/informers/externalversions/generic.go:39

↓ 30 callersMethodRead

(b []byte)

src/libraries/go/worker/proxy/quicconn/conn.go:30

↓ 30 callersMethodRecall

Recall gets the current value for the given dependency in the Brain.

src/compute-plane-services/ess-agent/template/brain.go:48

↓ 30 callersMethodRegister

(ctx context.Context, req *types.ICMSRegistrationRequest)

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

↓ 30 callersMethodSet

Set stores the key-value pair.

src/libraries/go/worker/tracing/nats.go:38

↓ 30 callersMethodSet

Set sets the value in the format min[:max] for a wait timer.

src/compute-plane-services/ess-agent/config/wait.go:180

↓ 30 callersMethodSignal

(os.Signal)

src/compute-plane-services/byoo-otel-collector/internal/otelcollector/otelcollector.go:63

↓ 30 callersMethodTrackK8sAPICall

TrackK8sAPICall is a helper function to track K8s API Get calls It takes the result of a K8s API Get call and records success or failure metrics based

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

↓ 30 callersMethodWithNamespace

WithNamespace makes a shallow copy of Client, modifies it to use the given namespace, and returns it. Passing an empty string will temporarily unset t

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

↓ 30 callersMethodend_registration

(&self, running: RunningRegistration)

src/libraries/rust/stargate/crates/stargate/src/routing_state/mod.rs:86

↓ 30 callersFunctiongetVaultConfigData

(nb *nvidiaiov1.NVCFBackend)

src/compute-plane-services/nvca/pkg/operator/reconcile/vault_reconcile.go:54

↓ 30 callersMethodkeys

()

src/compute-plane-services/nvca/pkg/storage/controller_modelcache.go:203

↓ 30 callersFunctionsummarize_distribution

(values: &[f64], bootstrap_seed: u64)

src/libraries/rust/stargate/crates/stargate-bench/src/statistics.rs:54

↓ 30 callersFunctionwithDefaultLabels

(additionalLabels ...string)

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

↓ 29 callersMethodAddMessage

(queueURL string, msg queue.ReceiveMessageOutput)

src/compute-plane-services/nvca/pkg/queue/mock/mock.go:45

↓ 29 callersMethodHasGPUs

HasGPUs returns whether GPUs are currently available.

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

↓ 29 callersMethodIsFeatureFlagEnabled

(*featureflag.FeatureFlag)

src/compute-plane-services/nvca/internal/util/k8sutil/nvcf_resources.go:325

↓ 29 callersMethodSendEvent

SendEvent sends a typed event to the client

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

↓ 29 callersFunctionWithDefaultLogger

(parent context.Context)

src/libraries/go/lib/pkg/core/context.go:81

↓ 29 callersMethodaccept

(incoming: quinn::Incoming, upstream_template: &str)

src/libraries/rust/stargate/crates/stargate/src/bin/stargate_webtransport_l7_proxy/session.rs:123

↓ 29 callersMethodload

(path: &Path)

src/libraries/rust/stargate/crates/stargate-bench/src/config.rs:152

↓ 29 callersFunctionmakeNetworkPolicy

( name, namespace string, podSelector map[string]string, policyTypes []networkingv1.PolicyType, ingress []

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

↓ 29 callersMethodrecv_body

(&mut self)

src/libraries/rust/stargate/crates/protocol/src/stream.rs:158

↓ 28 callersMethodDeepCopyInto

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

src/compute-plane-services/nvca/pkg/apis/nvca/v2beta1/zz_generated.deepcopy.go:68

↓ 28 callersMethodListenAndServe

()

src/invocation-plane-services/grpc-proxy/proxy/h2.go:54

↓ 28 callersFunctionNewInputTextContent

NewInputTextContent creates a new InputContent with text content

src/invocation-plane-services/llm-api-gateway/api/adapters/openairesponses/items.go:626

↓ 28 callersMethodObserve

Observe implements Histogram.

src/libraries/go/lib/pkg/nvkit/middleware/metrics/request_test.go:97

↓ 28 callersMethodResponse

( data, internal map[string]interface{}, )

src/compute-plane-services/ess-agent/sdk/framework/secret.go:61

↓ 28 callersMethodServeHTTP

(writer http.ResponseWriter, request *http.Request)

src/invocation-plane-services/vanity-gateway/router/swappable_router.go:34

↓ 28 callersMethodUpsertCheckpoint

UpsertCheckpoint inserts a checkpoint row or updates an existing one (by ID). Used by the agent's post-capture registration path — agents creating che

src/compute-plane-services/nvsnap/internal/db/checkpoint.go:101

↓ 28 callersFunctionbind_ephemeral_udp

()

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

↓ 28 callersMethodgather_text

(&self)

src/libraries/rust/stargate/crates/pylon-lib/src/stats/metrics.rs:153

↓ 28 callersMethodinto_background_task

(self)

src/invocation-plane-services/http-invocation/crates/server/tests/mocks/nvcf_worker_mock.rs:147

↓ 28 callersMethodinto_response

(self)

src/invocation-plane-services/http-invocation/crates/server/src/routes/app_error.rs:28

↓ 28 callersFunctionnewScenarioContext

(t *testing.T)

tests/bdd/steps/steps_test.go:54

↓ 28 callersFunctionstart_lifecycle_dummy_backend

(model: &str)

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

↓ 27 callersMethodDelete

(context.Context, string)

src/compute-plane-services/ess-agent/sdk/logical/storage.go:45

↓ 27 callersMethodDelete

Delete removes a capture from the store. Used by retention policy. Returns ErrNotFound if the hash was already absent.

src/compute-plane-services/nvsnap/internal/checkpointstore/store.go:141

↓ 27 callersMethodGetOk

GetOk gets the value for the given field. The second return value will be false if the key is invalid or the key is not set at all. If the field k is

src/compute-plane-services/ess-agent/sdk/framework/field_data.go:122

↓ 27 callersMethodLogger

Logger provides an interface to access the underlying logger. This is useful when a struct embeds a Backend-implemented struct that contains a private

src/compute-plane-services/ess-agent/sdk/logical/logical.go:80

↓ 27 callersMethodLookup

(id string)

src/compute-plane-services/ess-agent/api/sys_leases.go:53

↓ 27 callersFunctionNewBackendK8sCacheBuilder

()

src/compute-plane-services/nvca/pkg/operator/reconcile/backendk8scache.go:188

↓ 27 callersFunctionNewClient

NewClient returns a new client for the given configuration. If the configuration is nil, Vault will use configuration from DefaultConfig(), which is

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

↓ 27 callersFunctionNewContextMiddleware

(cfg *config.Config)

src/invocation-plane-services/llm-api-gateway/api/middleware.go:49

↓ 27 callersFunctionNewHandlers

( cfg *config.Config, p provider.InferenceProvider, limiter ratelimit.RateLimiter, opts ...HandlerOption,

src/invocation-plane-services/llm-api-gateway/api/handlers.go:79

↓ 27 callersMethodPut

Put is used to insert or update an entry

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

↓ 27 callersMethodPut

Put copies all sources into the store under hash and writes the manifest. Each source's content lands at <tree>/<DstSubpath>; the orchestrator pre-cla

src/compute-plane-services/nvsnap/internal/checkpointstore/store.go:123

↓ 27 callersMethodRecordOrphanedResourceCleanup

RecordOrphanedResourceCleanup increments the orphaned resource cleanup counter

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

↓ 27 callersMethodRun

(ctx context.Context, commandText string)

tests/bdd/harness/runner.go:50

↓ 27 callersFunctiongetCounterValue

getCounterValue returns the counter value for the given metric name and resource label.

src/compute-plane-services/nvca/internal/metrics/instrumented_crclient_test.go:51

↓ 27 callersFunctiongrpc_endpoint

(authority_addr: &str)

src/libraries/rust/stargate/crates/pylon-lib/src/registration/tests.rs:58

↓ 27 callersFunctionmergeMaps

(m1, m2 map[string]string)

src/compute-plane-services/nvca/internal/miniservice/mutate.go:453

↓ 27 callersFunctionprefixed_opts

(metric_name: &str, help: &str)

src/libraries/rust/stargate/crates/pylon-lib/src/stats/metrics.rs:896

↓ 27 callersFunctionrunning_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:56

↓ 26 callersMethodGetAllBackendGPUs

GetAllBackendGPUs returns the cluster's GPU and corresponding instance types.

src/compute-plane-services/nvca/pkg/nodefeatures/client.go:33

↓ 26 callersMethodKill

()

src/compute-plane-services/byoo-otel-collector/internal/otelcollector/otelcollector.go:64

↓ 26 callersMethodLog

(...interface{})

src/compute-plane-services/ess-agent/test/helpers.go:110

↓ 26 callersFunctionNewNVCFWorker

(ctx context.Context, zapLogger *logs.ZapLogger, config Config)

src/compute-plane-services/worker-utils/worker/worker.go:145

↓ 26 callersMethodNgcApiKey

Get NGC API key

src/compute-plane-services/worker-task/internal/secrets/secrets.go:170

↓ 26 callersMethodRecordGCCleanerRun

RecordGCCleanerRun increments the GC cleaner run counter

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

← previous next →301–400 of 25,340, ranked by callers