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
↓ 21 callers
Function
metrics_text
(metrics: &PylonMetrics)
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:484
↓ 21 callers
Function
newAC
(method, path, token string)
src/control-plane-services/helm-reval/pkg/authorizers/authorizers_test.go:55
↓ 21 callers
Function
newAdapterTextItem
(text string)
src/invocation-plane-services/llm-api-gateway/api/adapters/openairesponses/responses_test.go:32
↓ 21 callers
Function
nvsnap_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 callers
Function
nvsnap_zmq_trace_enabled
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:842
↓ 21 callers
Method
observe_request
(&self, observation: RequestObservation)
src/libraries/rust/stargate/crates/pylon-lib/src/runtime_state.rs:182
↓ 21 callers
Function
orDash
(s string)
src/clis/nvcf-cli/cmd/cluster_agent.go:384
↓ 21 callers
Function
podWithAnnotation
podWithAnnotation returns a minimal pod with the given annotation value.
src/compute-plane-services/nvsnap/internal/webhook/mutate_test.go:57
↓ 21 callers
Function
running_registration
( state: &StargateState, id: &str, url: &str, routing_key: Option<&str>, )
src/libraries/rust/stargate/crates/stargate/src/routing_state/tests.rs:47
↓ 21 callers
Function
stringifyBackendGPUs
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 callers
Method
styleSection
()
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1893
↓ 21 callers
Function
wait_for_unroutable_on_all
(topology: &LifecycleTopology, model: &str, timeout: Duration)
src/libraries/rust/stargate/crates/stargate/tests/suite/lifecycle.rs:2193
↓ 20 callers
Method
Close
()
src/clis/nvcf-cli/internal/selfhosted/progress/sink.go:29
↓ 20 callers
Method
Compose
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 callers
Method
DeepCopyInto
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 callers
Method
Evaluate
(ctx context.Context, ac *AuthzContext)
src/control-plane-services/helm-reval/pkg/authorizers/types.go:48
↓ 20 callers
Method
HasState
(flag ReplicationState)
src/compute-plane-services/ess-agent/sdk/helper/consts/replication.go:164
↓ 20 callers
Method
List
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 callers
Function
NewICMSIntrospect
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 callers
Method
Record
Record marks resolvedCommand as having succeeded. Idempotent.
tests/bdd/harness/cache.go:35
↓ 20 callers
Method
S
S - Zap compatible sugared-logger function
src/libraries/go/lib/pkg/nvkit/logs/logs.go:84
↓ 20 callers
Method
Save
Save writes the state to disk
src/clis/nvcf-cli/internal/state/state.go:160
↓ 20 callers
Method
SetSize
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 callers
Method
Validate
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 callers
Method
alpn_protocols
(self)
src/libraries/rust/stargate/crates/protocol/src/lib.rs:102
↓ 20 callers
Method
into_parts
(self)
src/libraries/rust/stargate/crates/stargate/src/routing_state/calibration.rs:44
↓ 20 callers
Method
layer
(&self, service: Channel)
src/invocation-plane-services/http-invocation/crates/server/src/nvcf_api/auth_client_service.rs:44
↓ 20 callers
Function
makeNode
--- helpers ---
src/compute-plane-services/nvca/internal/clustervalidator/validator_test.go:956
↓ 20 callers
Method
mutate
(context.Context, client.Object)
src/compute-plane-services/nvca/internal/miniservice/mutate.go:47
↓ 20 callers
Function
open_test_tunnel_stream
( tunnel_addr: SocketAddr, )
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:633
↓ 20 callers
Function
record_nats_error_total
()
src/invocation-plane-services/http-invocation/crates/server/src/metrics/mod.rs:274
↓ 20 callers
Function
setupTestICMSClient
()
src/compute-plane-services/nvca/pkg/nvca/icms_client_test.go:139
↓ 20 callers
Function
start_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 callers
Function
stringFromEnv
(list []string, def string)
src/compute-plane-services/ess-agent/config/config.go:679
↓ 20 callers
Method
styleHeaderValue
()
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1887
↓ 19 callers
Function
BoolGoString
BoolGoString returns the value of the boolean for printing in a string.
src/compute-plane-services/ess-agent/config/convert.go:44
↓ 19 callers
Function
DefaultConfig
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 callers
Method
Discovery
()
src/compute-plane-services/nvca/pkg/client/clientset/versioned/clientset.go:38
↓ 19 callers
Method
Empty
()
src/invocation-plane-services/llm-api-gateway/ratelimit/resources.go:140
↓ 19 callers
Function
Float64
Float64 returns a pointer to the given float64
src/compute-plane-services/ess-agent/config/convert.go:93
↓ 19 callers
Function
GenericNameRegex
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 callers
Method
GetGPUResources
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 callers
Method
InitWorkerConn
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 callers
Method
Mount
(target, lower, upper, work string)
src/compute-plane-services/nvsnap/internal/agent/restoreoverlay.go:54
↓ 19 callers
Function
NewRequestStreamHandler
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 callers
Method
Run
(ctx context.Context, cfg Config, out io.Writer)
src/control-plane-services/helm-reval/reval/run.go:203
↓ 19 callers
Method
SetIndent
SetIndent is a wrapper around [Encoder.SetIndent].
src/invocation-plane-services/llm-api-gateway/internal/encoding/json/buffered_encoder.go:92
↓ 19 callers
Method
StorageRequests
StorageRequests returns an object that can list and get StorageRequests.
src/compute-plane-services/nvca/pkg/client/listers/nvca/v2beta1/storagerequest.go:38
↓ 19 callers
Method
TryAcquire
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 callers
Function
dlopen
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/src/zmq_intercept.c:551
↓ 19 callers
Function
newTestClient
(t *testing.T, fqdn string)
src/libraries/go/worker/nvcf/coverage_test.go:134
↓ 19 callers
Function
newTestSetup
--------------------------------------------------------------------------- instrumentedCRClient method tests ----------------------------------------
src/compute-plane-services/nvca/internal/metrics/instrumented_crclient_test.go:270
↓ 19 callers
Method
query_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 callers
Method
registry
(&self)
src/libraries/rust/stargate/crates/stargate/src/metrics.rs:216
↓ 19 callers
Function
required
(request_id: &str, priority: u32, input_tokens: u64)
src/libraries/rust/stargate/crates/pylon-lib/src/queue_admission.rs:860
↓ 19 callers
Method
setBody
(body string)
src/compute-plane-services/nvca/pkg/nvca/icms_client_test.go:78
↓ 19 callers
Method
spawn
(name: &'static str, task: F)
src/libraries/rust/stargate/crates/stargate-runtime/src/owned_task.rs:48
↓ 19 callers
Function
startMock
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 callers
Method
styleHeaderLabel
─── style helpers ────────────────────────────────────────────────────────────
src/clis/nvcf-cli/internal/selfhosted/progress/render_tty.go:1884
↓ 18 callers
Method
Clone
Clone returns a copy of s.
src/invocation-plane-services/llm-api-gateway/internal/container/set/set.go:87
↓ 18 callers
Method
Emit
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 callers
Method
Init
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 callers
Method
IsAttributeEnabled
(*Attribute)
src/compute-plane-services/nvca/pkg/featureflag/fetcher.go:39
↓ 18 callers
Function
LoadStateForCurrentCommand
LoadStateForCurrentCommand loads state using the current config context
src/clis/nvcf-cli/cmd/root.go:177
↓ 18 callers
Method
Matches
(serverURL *url.URL)
src/libraries/go/lib/pkg/imagecredential/credhelper.go:52
↓ 18 callers
Method
Merge
(o *QueryOptions)
src/compute-plane-services/ess-agent/dependency/dependency.go:91
↓ 18 callers
Function
NewGPUMonitor
NewGPUMonitor creates a new GPU monitor.
src/compute-plane-services/nvca/pkg/nvca/gpumonitor.go:141
↓ 18 callers
Function
NewPlugin
NewPlugin creates a new webhook plugin instance.
src/control-plane-services/nats-auth-callout/internal/plugins/webhook/webhook.go:70
↓ 18 callers
Function
NewSelfManagedSecretsFetcher
( ctx context.Context, name string, selfHostedVaultSecretsJSONPath string, )
src/compute-plane-services/nvca/internal/auth/selfmanagedsecrets.go:70
↓ 18 callers
Method
add
(key, raw string, err error)
src/invocation-plane-services/llm-api-gateway/config/config.go:495
↓ 18 callers
Method
get_session
(&self)
src/control-plane-services/function-autoscaler/crates/server/src/cassandra/cassandra_service.rs:244
↓ 18 callers
Function
parseFlags
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 callers
Function
podPhaseToInstanceState
(pod *corev1.Pod, k8sTimeConfig *k8sutil.TimeConfig)
src/compute-plane-services/nvca/pkg/nvca/k8scomputebackend.go:1788
↓ 18 callers
Function
protocolPtr
(p corev1.Protocol)
src/compute-plane-services/nvca/internal/clustervalidator/netpol_test.go:36
↓ 18 callers
Method
proxy_request_streaming
( &self, registration: &Arc<RegistrationGeneration>, method: Method, path_and_
src/libraries/rust/stargate/crates/stargate/src/tunnel/direct.rs:199
↓ 18 callers
Function
rmrf
src/compute-plane-services/nvsnap/lib/nvsnap_intercept/tests/test_cuda_intercept.c:155
↓ 18 callers
Function
runWorkerTest
(t *testing.T, natsSuperCluster *testutils.SuperCluster, workFunc testutils.DoWorkFunc, zapLogger *logs.ZapLog
src/compute-plane-services/worker-utils/service/service_test.go:687
↓ 18 callers
Method
track_request
( &self, required: &RequiredTunnelHeaders, )
src/libraries/rust/stargate/crates/pylon-lib/src/queue_admission.rs:237
↓ 18 callers
Function
trusted_client_config
()
src/libraries/rust/stargate/crates/pylon-lib/src/quic_http_tunnel/tests.rs:4213
↓ 18 callers
Function
writeTestFile
(t *testing.T, path, content string)
tools/collect-dependencies/main_test.go:248
↓ 17 callers
Method
Close
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 callers
Function
Compute
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 callers
Method
CreateUser
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 callers
Method
Info
(msg string, keysAndValues ...interface{})
src/libraries/go/lib/pkg/nvkit/clients/retry_logger.go:33
↓ 17 callers
Method
MaxAvailable
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 callers
Function
NewKeyFileFetcher
(ctx context.Context, opts ...KeyFileFetcherOption)
src/libraries/go/lib/pkg/secret/fetcher.go:85
↓ 17 callers
Method
NewTransport
NewTransport includes the certificate revocation check with OCSP in sequential.
src/compute-plane-services/ess-agent/sdk/helper/ocsp/client.go:828
↓ 17 callers
Function
NewVaultReadQuery
NewVaultReadQuery creates a new datacenter dependency.
src/compute-plane-services/ess-agent/dependency/vault_read.go:76
↓ 17 callers
Function
TimeDurationGoString
TimeDurationGoString returns the value of the time.Duration for printing in a string.
src/compute-plane-services/ess-agent/config/convert.go:273
↓ 17 callers
Method
Type
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 callers
Function
WithLogger
(logger log.Logger)
src/libraries/go/lib/pkg/nvkit/servers/grpc.go:155
↓ 17 callers
Method
WithNGCServiceKeyFetcher
(ngcServiceKeyFetcher cmnsecret.TokenFetcher)
src/compute-plane-services/nvca/pkg/operator/reconcile/backendk8scache.go:244
↓ 17 callers
Function
basicAuth
Helper to base64 encode username:password string
tools/ncp-local-cluster/credential-provider-go/internal/provider/provider_test.go:45
↓ 17 callers
Method
evaluate
( &self, config: &RequestQualityMonitorConfig, )
src/libraries/rust/stargate/crates/pylon-lib/src/request_quality_monitor/recorder.rs:138
↓ 17 callers
Function
evaluate_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 callers
Function
file_sdk_database_dbplugin_database_proto_rawDescGZIP
()
src/compute-plane-services/ess-agent/sdk/database/dbplugin/database.pb.go:1175
↓ 17 callers
Method
http_addrs
(&self)
src/libraries/rust/stargate/crates/stargate/tests/suite/forwarding_integration.rs:57
↓ 17 callers
Function
icmsRequest
(namespace, name, functionID, versionID, action, status string, useLegacy bool)
src/clis/nvcf-cli/internal/clusteragent/k8s_inspector_test.go:67
↓ 17 callers
Method
message
(&self)
src/libraries/rust/stargate/crates/pylon-lib/src/request_observer/headers.rs:50
↓ 17 callers
Method
metrics
(&self)
src/libraries/rust/stargate/crates/stargate/src/runtime.rs:344
← previous
next →
501–600 of 25,340, ranked by callers