MCPcopy Create free account

hub / github.com/NVIDIA/nvcf / functions

Functions25,340 in github.com/NVIDIA/nvcf

↓ 21 callersFunctionmetrics_text
(metrics: &PylonMetrics)
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:484
↓ 21 callersFunctionnewAC
(method, path, token string)
src/control-plane-services/helm-reval/pkg/authorizers/authorizers_test.go:55
↓ 21 callersFunctionnewAdapterTextItem
(text string)
src/invocation-plane-services/llm-api-gateway/api/adapters/openairesponses/responses_test.go:32
↓ 21 callersFunctionnvsnap_get_current_device
═══════════════════════════════════════════════════════════════════════ * Reliable device query * * nvsnap_current_device (thread-local) can be wro
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/gpu/interpose_cudart.c:35
↓ 21 callersFunctionnvsnap_zmq_trace_enabled
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:842
↓ 21 callersMethodobserve_request
(&self, observation: RequestObservation)
src/libraries/rust/stargate/crates/pylon-lib/src/runtime_state.rs:182
↓ 21 callersFunctionorDash
(s string)
src/clis/nvcf-cli/cmd/cluster_agent.go:384
↓ 21 callersFunctionpodWithAnnotation
podWithAnnotation returns a minimal pod with the given annotation value.
src/compute-plane-services/nvsnap/internal/webhook/mutate_test.go:57
↓ 21 callersFunctionrunning_registration
( state: &StargateState, id: &str, url: &str, routing_key: Option<&str>, )
src/libraries/rust/stargate/crates/stargate/src/routing_state/tests.rs:47
↓ 21 callersFunctionstringifyBackendGPUs
The String() method on resources mutates the underlying type so equality fails unless tests do the same.
src/compute-plane-services/nvca/pkg/nodefeatures/dynamic_client_test.go:1457
↓ 21 callersMethodstyleSection
()
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1893
↓ 21 callersFunctionwait_for_unroutable_on_all
(topology: &LifecycleTopology, model: &str, timeout: Duration)
src/libraries/rust/stargate/crates/stargate/tests/suite/lifecycle.rs:2193
↓ 20 callersMethodClose
()
src/clis/nvcf-cli/internal/selfhosted/progress/sink.go:29
↓ 20 callersMethodCompose
Compose returns the HashInput for the given pod. mainContainer is the index in pod.spec.containers whose image / args / env drive composition. nil pod
src/compute-plane-services/nvsnap/internal/rootfsonly/composer.go:53
↓ 20 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/v1/zz_generated.deepcopy.go:106
↓ 20 callersMethodEvaluate
(ctx context.Context, ac *AuthzContext)
src/control-plane-services/helm-reval/pkg/authorizers/types.go:48
↓ 20 callersMethodHasState
(flag ReplicationState)
src/compute-plane-services/ess-agent/sdk/helper/consts/replication.go:164
↓ 20 callersMethodList
List returns every object whose key starts with prefix. Used by the pull path to enumerate a capture's tree (the manifest records volumes, not individ
src/compute-plane-services/nvsnap/internal/objectstore/objectstore.go:64
↓ 20 callersFunctionNewICMSIntrospect
NewICMSIntrospect builds an introspection authorizer. introspectURL is required. A cacheTTL of 0 disables caching.
src/control-plane-services/helm-reval/pkg/authorizers/icms_introspect.go:123
↓ 20 callersMethodRecord
Record marks resolvedCommand as having succeeded. Idempotent.
tests/bdd/harness/cache.go:35
↓ 20 callersMethodS
S - Zap compatible sugared-logger function
src/libraries/go/lib/pkg/nvkit/logs/logs.go:84
↓ 20 callersMethodSave
Save writes the state to disk
src/clis/nvcf-cli/internal/state/state.go:160
↓ 20 callersMethodSetSize
SetSize is a test seam for forcing terminal dimensions without sending tea.WindowSizeMsg through the bubbletea event loop.
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:406
↓ 20 callersMethodValidate
Validate runs the cluster-level checks selected by opts and returns one CheckResult per check that ran, along with the cluster identity.
src/clis/nvcf-cli/internal/clusteragent/validator.go:33
↓ 20 callersMethodalpn_protocols
(self)
src/libraries/rust/stargate/crates/protocol/src/lib.rs:102
↓ 20 callersMethodinto_parts
(self)
src/libraries/rust/stargate/crates/stargate/src/routing_state/calibration.rs:44
↓ 20 callersMethodlayer
(&self, service: Channel)
src/invocation-plane-services/http-invocation/crates/server/src/nvcf_api/auth_client_service.rs:44
↓ 20 callersFunctionmakeNode
--- helpers ---
src/compute-plane-services/nvca/internal/clustervalidator/validator_test.go:956
↓ 20 callersMethodmutate
(context.Context, client.Object)
src/compute-plane-services/nvca/internal/miniservice/mutate.go:47
↓ 20 callersFunctionopen_test_tunnel_stream
( tunnel_addr: SocketAddr, )
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:633
↓ 20 callersFunctionrecord_nats_error_total
()
src/invocation-plane-services/http-invocation/crates/server/src/metrics/mod.rs:274
↓ 20 callersFunctionsetupTestICMSClient
()
src/compute-plane-services/nvca/pkg/nvca/icms_client_test.go:139
↓ 20 callersFunctionstart_and_register_backend
Starts a dummy backend, optionally wraps it with a QUIC tunnel (when `reverse_tunnel` is false), and registers it with the given stargate seeds.
src/libraries/rust/stargate/crates/stargate/tests/common/mod.rs:1337
↓ 20 callersFunctionstringFromEnv
(list []string, def string)
src/compute-plane-services/ess-agent/config/config.go:679
↓ 20 callersMethodstyleHeaderValue
()
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1887
↓ 19 callersFunctionBoolGoString
BoolGoString returns the value of the boolean for printing in a string.
src/compute-plane-services/ess-agent/config/convert.go:44
↓ 19 callersFunctionDefaultConfig
DefaultConfig returns a default configuration for the client. It is safe to modify the return value of this function. The default Address is https://
src/compute-plane-services/ess-agent/api/client.go:247
↓ 19 callersMethodDiscovery
()
src/compute-plane-services/nvca/pkg/client/clientset/versioned/clientset.go:38
↓ 19 callersMethodEmpty
()
src/invocation-plane-services/llm-api-gateway/ratelimit/resources.go:140
↓ 19 callersFunctionFloat64
Float64 returns a pointer to the given float64
src/compute-plane-services/ess-agent/config/convert.go:93
↓ 19 callersFunctionGenericNameRegex
Helper which returns a generic regex string for creating endpoint patterns that are identified by the given name in the backends
src/compute-plane-services/ess-agent/sdk/framework/path.go:33
↓ 19 callersMethodGetGPUResources
GetGPUResources calculates the GPU capacity in the cluster for a specific GPU type across all instances.
src/compute-plane-services/nvca/pkg/nodefeatures/client.go:36
↓ 19 callersMethodInitWorkerConn
InitWorkerConn may return nil if the worker connection for this function id and version id was already closed
src/invocation-plane-services/grpc-proxy/proxy/worker/connections.go:79
↓ 19 callersMethodMount
(target, lower, upper, work string)
src/compute-plane-services/nvsnap/internal/agent/restoreoverlay.go:54
↓ 19 callersFunctionNewRequestStreamHandler
NewRequestStreamHandler connects to the target URI using separate GET and POST connections
src/compute-plane-services/worker-utils/worker/httpstream/request_stream.go:100
↓ 19 callersMethodRun
(ctx context.Context, cfg Config, out io.Writer)
src/control-plane-services/helm-reval/reval/run.go:203
↓ 19 callersMethodSetIndent
SetIndent is a wrapper around [Encoder.SetIndent].
src/invocation-plane-services/llm-api-gateway/internal/encoding/json/buffered_encoder.go:92
↓ 19 callersMethodStorageRequests
StorageRequests returns an object that can list and get StorageRequests.
src/compute-plane-services/nvca/pkg/client/listers/nvca/v2beta1/storagerequest.go:38
↓ 19 callersMethodTryAcquire
TryAcquire acquires the semaphore with a weight of n without blocking. On success, returns true. On failure, returns false and leaves the semaphore un
src/libraries/go/worker/semaphore/semaphore.go:106
↓ 19 callersFunctiondlopen
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:551
↓ 19 callersFunctionnewTestClient
(t *testing.T, fqdn string)
src/libraries/go/worker/nvcf/coverage_test.go:134
↓ 19 callersFunctionnewTestSetup
--------------------------------------------------------------------------- instrumentedCRClient method tests ----------------------------------------
src/compute-plane-services/nvca/internal/metrics/instrumented_crclient_test.go:270
↓ 19 callersMethodquery_range
( &self, query: &str, start: DateTime<Utc>, end: DateTime<Utc>, step:
src/control-plane-services/function-autoscaler/crates/server/src/timeseries_db/timeseries_db_client.rs:200
↓ 19 callersMethodregistry
(&self)
src/libraries/rust/stargate/crates/stargate/src/metrics.rs:216
↓ 19 callersFunctionrequired
(request_id: &str, priority: u32, input_tokens: u64)
src/libraries/rust/stargate/crates/pylon-lib/src/queue_admission.rs:860
↓ 19 callersMethodsetBody
(body string)
src/compute-plane-services/nvca/pkg/nvca/icms_client_test.go:78
↓ 19 callersMethodspawn
(name: &'static str, task: F)
src/libraries/rust/stargate/crates/stargate-runtime/src/owned_task.rs:48
↓ 19 callersFunctionstartMock
startMock spins up the mock on 127.0.0.1:0 (ephemeral) and returns the "http://host:port" FQDN. It registers cleanup to gracefully stop.
src/libraries/go/worker/nvct/coverage_test.go:127
↓ 19 callersMethodstyleHeaderLabel
─── style helpers ────────────────────────────────────────────────────────────
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1884
↓ 18 callersMethodClone
Clone returns a copy of s.
src/invocation-plane-services/llm-api-gateway/internal/container/set/set.go:87
↓ 18 callersMethodEmit
Emit forwards check events into the embedded model. Final flushes the static dashboard to the writer.
src/clis/nvcf-cli/internal/selfhosted/progress/render_check_oneshot.go:59
↓ 18 callersMethodInit
Init is called on `$ vault write database/config/:db-name`, or when you do a creds call after Vault's been restarted. The config provided won't hold a
src/compute-plane-services/ess-agent/sdk/database/dbplugin/plugin.go:82
↓ 18 callersMethodIsAttributeEnabled
(*Attribute)
src/compute-plane-services/nvca/pkg/featureflag/fetcher.go:39
↓ 18 callersFunctionLoadStateForCurrentCommand
LoadStateForCurrentCommand loads state using the current config context
src/clis/nvcf-cli/cmd/root.go:177
↓ 18 callersMethodMatches
(serverURL *url.URL)
src/libraries/go/lib/pkg/imagecredential/credhelper.go:52
↓ 18 callersMethodMerge
(o *QueryOptions)
src/compute-plane-services/ess-agent/dependency/dependency.go:91
↓ 18 callersFunctionNewGPUMonitor
NewGPUMonitor creates a new GPU monitor.
src/compute-plane-services/nvca/pkg/nvca/gpumonitor.go:141
↓ 18 callersFunctionNewPlugin
NewPlugin creates a new webhook plugin instance.
src/control-plane-services/nats-auth-callout/internal/plugins/webhook/webhook.go:70
↓ 18 callersFunctionNewSelfManagedSecretsFetcher
( ctx context.Context, name string, selfHostedVaultSecretsJSONPath string, )
src/compute-plane-services/nvca/internal/auth/selfmanagedsecrets.go:70
↓ 18 callersMethodadd
(key, raw string, err error)
src/invocation-plane-services/llm-api-gateway/config/config.go:495
↓ 18 callersMethodget_session
(&self)
src/control-plane-services/function-autoscaler/crates/server/src/cassandra/cassandra_service.rs:244
↓ 18 callersFunctionparseFlags
parseFlags responsible for parse out the feature flag usage. Returns an error if invalid flag combinations are detected.
src/compute-plane-services/nvca/pkg/featureflag/featureflag.go:213
↓ 18 callersFunctionpodPhaseToInstanceState
(pod *corev1.Pod, k8sTimeConfig *k8sutil.TimeConfig)
src/compute-plane-services/nvca/pkg/nvca/k8scomputebackend.go:1788
↓ 18 callersFunctionprotocolPtr
(p corev1.Protocol)
src/compute-plane-services/nvca/internal/clustervalidator/netpol_test.go:36
↓ 18 callersMethodproxy_request_streaming
( &self, registration: &Arc<RegistrationGeneration>, method: Method, path_and_
src/libraries/rust/stargate/crates/stargate/src/tunnel/direct.rs:199
↓ 18 callersFunctionrmrf
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/tests/test_cuda_intercept.c:155
↓ 18 callersFunctionrunWorkerTest
(t *testing.T, natsSuperCluster *testutils.SuperCluster, workFunc testutils.DoWorkFunc, zapLogger *logs.ZapLog
src/compute-plane-services/worker-utils/service/service_test.go:687
↓ 18 callersMethodtrack_request
( &self, required: &RequiredTunnelHeaders, )
src/libraries/rust/stargate/crates/pylon-lib/src/queue_admission.rs:237
↓ 18 callersFunctiontrusted_client_config
()
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:4213
↓ 18 callersFunctionwriteTestFile
(t *testing.T, path, content string)
tools/collect-dependencies/main_test.go:248
↓ 17 callersMethodClose
Close attempts to close the underlying database connection that was established by the backend.
src/compute-plane-services/ess-agent/sdk/database/dbplugin/v5/database.go:50
↓ 17 callersFunctionCompute
Compute derives a PodTiming for each pod in the input slice. Pods without a CreationTimestamp are skipped (impossible in practice but keeps Compute to
src/compute-plane-services/nvsnap/internal/podtimings/podtimings.go:99
↓ 17 callersMethodCreateUser
CreateUser is called on `$ vault read database/creds/:role-name` and it's also the first time anything is touched from `$ vault write database/roles/:
src/compute-plane-services/ess-agent/sdk/database/dbplugin/plugin.go:46
↓ 17 callersMethodInfo
(msg string, keysAndValues ...interface{})
src/libraries/go/lib/pkg/nvkit/clients/retry_logger.go:33
↓ 17 callersMethodMaxAvailable
MaxAvailable checks what the current max weight available is without blocking. It does not guarantee that number will not immediately change.
src/libraries/go/worker/semaphore/semaphore.go:130
↓ 17 callersFunctionNewKeyFileFetcher
(ctx context.Context, opts ...KeyFileFetcherOption)
src/libraries/go/lib/pkg/secret/fetcher.go:85
↓ 17 callersMethodNewTransport
NewTransport includes the certificate revocation check with OCSP in sequential.
src/compute-plane-services/ess-agent/sdk/helper/ocsp/client.go:828
↓ 17 callersFunctionNewVaultReadQuery
NewVaultReadQuery creates a new datacenter dependency.
src/compute-plane-services/ess-agent/dependency/vault_read.go:76
↓ 17 callersFunctionTimeDurationGoString
TimeDurationGoString returns the value of the time.Duration for printing in a string.
src/compute-plane-services/ess-agent/config/convert.go:273
↓ 17 callersMethodType
Type returns the Name for the particular database backend implementation. This type name is usually set as a constant within the database backend impl
src/compute-plane-services/ess-agent/sdk/database/dbplugin/v5/database.go:46
↓ 17 callersFunctionWithLogger
(logger log.Logger)
src/libraries/go/lib/pkg/nvkit/servers/grpc.go:155
↓ 17 callersMethodWithNGCServiceKeyFetcher
(ngcServiceKeyFetcher cmnsecret.TokenFetcher)
src/compute-plane-services/nvca/pkg/operator/reconcile/backendk8scache.go:244
↓ 17 callersFunctionbasicAuth
Helper to base64 encode username:password string
tools/ncp-local-cluster/credential-provider-go/internal/provider/provider_test.go:45
↓ 17 callersMethodevaluate
( &self, config: &RequestQualityMonitorConfig, )
src/libraries/rust/stargate/crates/pylon-lib/src/request_quality_monitor/recorder.rs:138
↓ 17 callersFunctionevaluate_quality
( output_text: &str, output_tokens: u64, median_logprob: Option<f32>, config: &RequestQualityM
src/libraries/rust/stargate/crates/pylon-lib/src/request_quality_monitor/quality.rs:34
↓ 17 callersFunctionfile_sdk_database_dbplugin_database_proto_rawDescGZIP
()
src/compute-plane-services/ess-agent/sdk/database/dbplugin/database.pb.go:1175
↓ 17 callersMethodhttp_addrs
(&self)
src/libraries/rust/stargate/crates/stargate/tests/suite/forwarding_integration.rs:57
↓ 17 callersFunctionicmsRequest
(namespace, name, functionID, versionID, action, status string, useLegacy bool)
src/clis/nvcf-cli/internal/clusteragent/k8s_inspector_test.go:67
↓ 17 callersMethodmessage
(&self)
src/libraries/rust/stargate/crates/pylon-lib/src/request_observer/headers.rs:50
↓ 17 callersMethodmetrics
(&self)
src/libraries/rust/stargate/crates/stargate/src/runtime.rs:344
← previousnext →501–600 of 25,340, ranked by callers