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

ShortHash returns the first ShortHashLen hex characters of a hash, suitable for K8s resource names, label values, and human display.

src/compute-plane-services/nvsnap/internal/checkpointstore/hash.go:104

↓ 56 callersFunctionSignal

Signal returns a pointer to the given os.Signal.

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

↓ 56 callersMethodV1

V1 provides access to shared informers for resources in V1.

src/compute-plane-services/nvca/pkg/client/informers/externalversions/nvca/interface.go:34

↓ 56 callersMethodshutdown

(self)

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

↓ 55 callersMethodName

()

src/compute-plane-services/nvca/pkg/nvca/health/liveness.go:69

↓ 55 callersMethodRun

(ctx context.Context, refURL *url.URL, creds AuthHelperCredentials)

src/libraries/go/lib/pkg/imagecredential/credhelper.go:53

↓ 55 callersMethodTrace

(args *LoggerArgs, _ *struct{})

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

↓ 55 callersMethodType

Type returns the BackendType for the particular backend

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

↓ 55 callersMethodWithDefaultLabelValues

(additionalLvs ...string)

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

↓ 55 callersFunctionprintInfo

(log *logrus.Entry, msg string)

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

↓ 55 callersFunctionstartGrpcClient

(ctx context.Context, creds grpc.DialOption, address string, t *testing.T)

src/invocation-plane-services/ratelimiter/cmd/main_test.go:495

↓ 54 callersMethodDebug

(msg string, keysAndValues ...any)

src/control-plane-services/nats-auth-callout/internal/plugins/webhook/webhook.go:266

↓ 54 callersMethodSize

()

src/compute-plane-services/ess-agent/sdk/helper/keysutil/cache.go:24

↓ 54 callersFunctionbind_ephemeral

()

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

↓ 53 callersMethodAllowed

()

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

↓ 53 callersMethodFetchToken

FetchToken returns the token in the cache if it think the token is valid, otherwise, it tries to fetch a new token and update cache first.

src/compute-plane-services/nvca/internal/auth/tokenfetcher.go:46

↓ 53 callersMethodSet

(ctx context.Context, registry string, scheme orasauth.Scheme, key string, fetch func(context.Context) (string

src/control-plane-services/helm-reval/reval/image.go:356

↓ 53 callersFunctionstart_dummy_inst

Starts a dummy HTTP backend fronted by a QUIC HTTP tunnel. Returns `(http_addr, quic_url, tunnel_handle)`. Callers must hold the tunnel handle for the

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

↓ 52 callersMethodGather

()

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

↓ 52 callersMethodapply_update

( &mut self, update: StatsAggregatorUpdate, )

src/libraries/rust/stargate/crates/pylon-lib/src/stats/aggregator.rs:241

↓ 51 callersMethodReset

(ctx context.Context, key ...string)

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

↓ 51 callersMethodSetJSONBody

SetJSONBody is used to set a request body that is a JSON-encoded value.

src/compute-plane-services/ess-agent/api/request.go:61

↓ 51 callersMethodStatus

Status returns the NVCA agent status from the NVCFBackend CR in namespace.

src/clis/nvcf-cli/internal/clusteragent/types.go:126

↓ 51 callersFunctionnvsnap_zmq_errno

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

↓ 50 callersMethodIsFeatureFlagEnabled

(*FeatureFlag)

src/compute-plane-services/nvca/pkg/featureflag/fetcher.go:30

↓ 50 callersMethodNamespace

Namespace returns the namespace currently set in this client. It will return an empty string if there is no namespace set.

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

↓ 50 callersFunctionfile_sdk_plugin_pb_backend_proto_rawDescGZIP

()

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

↓ 50 callersMethodinc

(url string)

src/compute-plane-services/nvsnap/internal/agent/peer_load.go:68

↓ 50 callersMethodis_empty

(&self)

src/libraries/rust/stargate/crates/stargate-k8s-router/src/endpoints.rs:108

↓ 50 callersMethodrecv_header

(&mut self)

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

↓ 50 callersFunctionstream_counter_update

( request_id: &str, tokens_processed: u64, tokens_generated: u64, finished: bo

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

↓ 49 callersMethodDefault

()

src/libraries/go/lib/pkg/icms-translate/translate/common/translator.go:81

↓ 48 callersMethodGenerateKey

GenerateKey generates a key in the KMS if it didn't yet exist, returning the id. If it already existed, returns the existing id. KMSKey's key materia

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

↓ 48 callersMethodStop

()

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

↓ 48 callersMethodconnect

( endpoint: &str, token_provider: Option<AuthTokenProvider>, )

src/libraries/rust/stargate/crates/stargate/src/auth.rs:40

↓ 47 callersFunctionOutputJSON

(data interface{})

src/clis/nvcf-cli/cmd/json_output.go:32

↓ 46 callersMethodLogical

()

src/compute-plane-services/ess-agent/watch/vault_token.go:133

↓ 46 callersFunctionNewGRPCServer

NewGRPCServer - factory method for grpc based services

src/libraries/go/lib/pkg/nvkit/servers/grpc.go:136

↓ 46 callersMethodServe

Serve wraps an already-bound listener with the connection-tracking interceptor and hands it to the embedded http.Server. Callers that need to discover

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

↓ 46 callersMethodlisten_addr

(&self)

src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/server.rs:105

↓ 46 callersMethodwrite

(*oauth2.Token)

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

↓ 45 callersFunctionParseSecret

ParseSecret is used to parse a secret value from JSON from an io.Reader.

src/compute-plane-services/ess-agent/api/secret.go:318

↓ 45 callersFunctiongetConfigValueWithDefault

getConfigValueWithDefault reads configuration value with proper priority order: 1. Environment variable (highest priority - explicit user override) 2.

src/clis/nvcf-cli/cmd/apikey.go:41

↓ 45 callersFunctionmockKubeClients

(extraK8sObjs ...runtime.Object)

src/compute-plane-services/nvca/pkg/nvca/backendk8scache_test.go:214

↓ 44 callersMethodComplete

( ctx context.Context, reqCtx *requestctx.RequestContext, request *NormalizedRequest, )

src/invocation-plane-services/llm-api-gateway/provider/provider.go:75

↓ 44 callersMethodFd

()

src/clis/nvcf-cli/cmd/self_hosted_status.go:257

↓ 44 callersMethodHeader

()

src/libraries/go/lib/pkg/core/httpservice_test.go:522

↓ 44 callersMethodUpdateStatus

(ctx context.Context, sr *nvcav2beta1new.ICMSRequest, options metav1.UpdateOptions)

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

↓ 44 callersMethodgetRequest

()

src/compute-plane-services/nvca/pkg/nvca/icms_client_test.go:114

↓ 44 callersFunctionregistration_update

( running: &RunningRegistration, model_id: &str, status: i32, stats: ModelStats, )

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

↓ 43 callersMethodInsert

Insert adds the given value to s if it does not already exist. The boolean return indicates whether the value was inserted.

src/invocation-plane-services/llm-api-gateway/internal/container/set/set.go:61

↓ 43 callersMethodNVCFBackends

NVCFBackends returns an object that can list and get NVCFBackends.

src/compute-plane-services/nvca/pkg/client/listers/nvcf/v1/nvcfbackend.go:38

↓ 43 callersMethodNvcfV1

()

src/compute-plane-services/nvca/pkg/client/clientset/versioned/clientset.go:42

↓ 43 callersFunctionSetUseUUIDForRequestObjName

SetUseUUIDForRequestObjName sets the naming convention for request objects. Used by tests.

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

↓ 43 callersMethodshutdown

(self)

src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/server.rs:113

↓ 42 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/nvcf/v1/zz_generated.deepcopy.go:144

↓ 42 callersMethodServeHTTP

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

src/invocation-plane-services/grpc-proxy/proxy/director.go:188

↓ 42 callersFunctionapp

( config: AppConfig, secrets: Option<Arc<SecretFileWatcher>>, )

src/invocation-plane-services/http-invocation/crates/server/src/app.rs:59

↓ 42 callersFunctionprintSuccess

(log *logrus.Entry, msg string)

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

↓ 42 callersMethodto_bytes

(self)

src/libraries/rust/stargate/crates/protocol/src/webtransport.rs:41

↓ 41 callersMethodCheckLimit

( ctx context.Context, key string, l RateLimit, tokensRequested int64, testOnly bool, requestID st

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

↓ 41 callersMethodGetState

GetState returns the current state

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

↓ 41 callersMethodToken

Token returns the access token being used by this client. It will return the empty string if there is no token set.

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

↓ 41 callersFunctionassertGolden

assertGolden compares actual output to a golden file. With -update-golden, rewrites the file to match. The convention follows Go's stdlib (cmd/gofmt,

src/clis/nvcf-cli/internal/selfhosted/progress/helpers_test.go:60

↓ 41 callersMethodset_model_stats

(&self, model_id: impl Into<String>, stats: CurrentModelStats)

src/libraries/rust/stargate/crates/pylon-lib/src/runtime_state.rs:130

↓ 40 callersMethodConnect

(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption)

src/libraries/go/worker/proto/nvct/nvct_grpc.pb.go:37

↓ 40 callersMethodSetStatus

(status InfraStatus)

src/libraries/go/worker/metering/infra.go:205

↓ 40 callersMethodVault

Vault returns the Vault client for this set.

src/compute-plane-services/ess-agent/dependency/client_set.go:518

↓ 40 callersFunctionfixtures

()

src/invocation-plane-services/http-invocation/crates/server/tests/mocks/mod.rs:56

↓ 40 callersFunctionnewFeatureFlag

newFeatureFlag creates a newFeatureFlag feature flag

src/compute-plane-services/nvca/pkg/featureflag/featureflag.go:164

↓ 40 callersFunctionnewTestServerWithCatalog

newTestServerWithCatalog returns a Server with an in-memory catalog DB so peer-routing handlers can be exercised without K8s/agent fakes. Reuses newTe

src/compute-plane-services/nvsnap/internal/server/sources_test.go:35

↓ 40 callersFunctionprintError

(log *logrus.Entry, msg string)

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

↓ 39 callersFunctionFromContext

(ctx context.Context)

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

↓ 39 callersMethodSuccess

Success prints a success message in green

src/clis/nvcf-cli/internal/logging/logger.go:107

↓ 39 callersMethodWithClients

(clients *kubeclients.KubeClients)

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

↓ 39 callersFunctioncheck

(ret, msg)

src/compute-plane-services/nvsnap/tests/cuda_va_pytorch_test.py:61

↓ 39 callersMethodwriteJSON

--- HTTP helpers ---

src/compute-plane-services/nvsnap/internal/server/server.go:2402

↓ 38 callersMethodGetNamespace

()

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

↓ 38 callersMethodHandler

()

src/compute-plane-services/ess-agent/sdk/framework/path.go:146

↓ 38 callersMethodHas

Has reports whether resolvedCommand has been Record-ed in this suite.

tests/bdd/harness/cache.go:40

↓ 38 callersMethodID

()

src/libraries/go/lib/pkg/nvkit/errors/errors.go:81

↓ 38 callersMethodWarning

Warning prints a warning message in yellow

src/clis/nvcf-cli/internal/logging/logger.go:117

↓ 38 callersMethodfirst

first returns the first address which satisfies strategy, or if none do, then the first address of any kind.

src/libraries/go/worker/proxy/h3.go:301

↓ 38 callersFunctiongroq_multiregion_algorithm_config

( configure: impl FnOnce(&mut GroqMultiregionAlgorithmConfig), )

src/libraries/rust/stargate/crates/stargate/src/load_balancer/tests.rs:78

↓ 38 callersFunctionlog

Simple logging with timestamp

src/compute-plane-services/nvsnap/lib/nvsnap_intercept/tests/test_local_criu_uvloop.py:46

↓ 38 callersFunctionmockKubeClients

()

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

↓ 38 callersFunctionopenTestDB

(t *testing.T)

src/compute-plane-services/nvsnap/internal/db/db_test.go:26

↓ 37 callersMethodFlush

()

src/libraries/go/worker/nvct/result.go:47

↓ 37 callersMethodMerge

Merge combines all values in this configuration with the values in the other configuration, with values in the other configuration taking precedence.

src/compute-plane-services/ess-agent/config/env.go:94

↓ 37 callersMethodShutdown

Shutdown marks a factory as shutting down. At that point no new informers can be started anymore and Start will return without doing anything. In add

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

↓ 37 callersMethodStart

(ctx context.Context)

src/libraries/go/lib/pkg/core/kubeconfigurator.go:37

↓ 37 callersFunctionStringGoString

StringGoString returns the value of the string for printing in a string.

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

↓ 37 callersMethodsend_header

(&mut self, header: http::HeaderMap)

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

↓ 37 callersMethodset

(&mut self, key: &str, value: String)

src/invocation-plane-services/http-invocation/crates/server/src/nats/mod.rs:950

↓ 36 callersMethodLog

()

src/libraries/go/worker/metering/metering.go:126

↓ 36 callersFunctionNewBackendk8sCacheBuilder

()

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

↓ 36 callersMethodfinish

(&mut self)

src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/core.rs:395

↓ 35 callersMethodMutate

Mutate returns the patch ops to apply to pod, or nil patches when the pod should be admitted unchanged. Fail-open philosophy: any internal error retu

src/compute-plane-services/nvsnap/internal/webhook/mutate.go:393

↓ 35 callersMethodStart

()

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

↓ 35 callersMethodWithNamespaceLabels

(nsl labels.Set)

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

← previous next →201–300 of 25,340, ranked by callers