MCPcopy Create free account

hub / github.com/akash-network/provider / functions

Functions2,942 in github.com/akash-network/provider

⨍ Functions 2,942◇ Types & classes 699
↓ 1 callersFunctionauthInterceptor
authInterceptor returns a gRPC unary interceptor that validates JWT/mTLS credentials. The serverCtx carries application-level values (e.g. AccountQuer
gateway/grpc/server.go:119
↓ 1 callersFunctionavailableLeasedIPs
(total, inUse, reserved uint)
cluster/inventory.go:456
↓ 1 callersFunctionbuildClusterSettings
(mgroup *mani.Group, reservation crd.ReservationClusterSettings)
cluster/kube/builder/builder.go:174
↓ 1 callersFunctionbuildDirective
(ev chostname.ResourceEvent, serviceExpose crd.ManifestServiceExpose)
operator/hostname/operator.go:354
↓ 1 callersFunctionbuildMockGPUReport
buildMockGPUReport creates a synthetic GPU attestation report. - Bytes 0-3: "MGPU" - Bytes 4-7: report length (little-endian uint32) - Bytes 8-11: dev
sidecar/attestation/tee/mock.go:114
↓ 1 callersFunctionbuildMockReport
buildMockReport creates a synthetic report that mirrors the structure of real attestation reports enough to test the control plane: - Bytes 0-3: "MOCK
sidecar/attestation/tee/mock.go:80
↓ 1 callersFunctionbuildSidecarContainer
(image string, isGPU bool, extraEnv []corev1.EnvVar)
cluster/kube/webhook/sidecar.go:120
↓ 1 callersFunctionbuildSidecarVolumes
(isGPU bool, mockMode bool)
cluster/kube/webhook/sidecar.go:202
↓ 1 callersFunctionbytesEqual
(a, b []byte)
cmd/provider-services/cmd/leaseAttestation.go:194
↓ 1 callersFunctioncalculatePriceRange
(gspec *dtypes.GroupSpec)
bidengine/pricing.go:277
↓ 1 callersFunctionceilBigRatToBigInt
(v *big.Rat)
bidengine/pricing.go:121
↓ 1 callersFunctioncephStorageInventoryLogValue
(scs cephStorageClasses)
operator/inventory/diagnostics.go:150
↓ 1 callersMethodcheckHostnamesForManifest
(requestManifest maniv2beta2.Manifest, groupNames []string)
manifest/manager.go:462
↓ 1 callersMethodcheckLeaseActive
(ctx context.Context)
cluster/manager.go:569
↓ 1 callersFunctionclusterNSCmd
()
cmd/provider-services/cmd/clusterns.go:13
↓ 1 callersFunctioncmdPsutil
()
operator/psutil.go:36
↓ 1 callersFunctioncmdPsutilList
()
operator/psutil.go:116
↓ 1 callersFunctioncmdPsutilServe
()
operator/psutil.go:53
↓ 1 callersMethodcompleteAllPending
(auditor string, result atypes.AuditedProviders)
bidengine/provider_attributes.go:223
↓ 1 callersFunctionconfigWatcher
(ctx context.Context, file string)
operator/inventory/cmd.go:299
↓ 1 callersMethodconnectHostnameToDeployment
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator.go:716
↓ 1 callersMethodconnectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator_gateway.go:13
↓ 1 callersMethodconnectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
cluster/kube/client_gateway.go:31
↓ 1 callersMethodcopy
()
operator/inventory/types.go:222
↓ 1 callersFunctioncopyManagedLabels
(in map[string]string)
operator/inventory/node-discovery.go:1024
↓ 1 callersMethodcrdInstalled
(log logr.Logger, rc *rookclientset.Clientset)
operator/inventory/ceph.go:152
↓ 1 callersFunctioncreateAddressHandler
(log log.Logger, providerAddr sdk.Address)
gateway/rest/router.go:419
↓ 1 callersFunctioncreateAttestationQuoteHandler
createAttestationQuoteHandler handles attestation quote requests by calling the sidecar via the cluster.Client interface, which resolves the pod IP fr
gateway/rest/attestation.go:21
↓ 1 callersFunctioncreateBidPricingStrategy
(strategy string)
cmd/provider-services/cmd/run.go:417
↓ 1 callersFunctioncreateClusterClient
(ctx context.Context, log log.Logger, _ *cobra.Command)
cmd/provider-services/cmd/run.go:998
↓ 1 callersMethodcreateFakeOperator
(t *testing.T)
cluster/kube/operators/clients/inventory/client_test.go:101
↓ 1 callersFunctioncreateFolderIfNotExists
(path string)
tools/certissuer/storage.go:618
↓ 1 callersFunctioncreateManifestHandler
(log log.Logger, mclient pmanifest.Client)
gateway/rest/router.go:481
↓ 1 callersFunctioncreateStatusHandler
(log log.Logger, sclient provider.StatusClient, providerAddr sdk.Address)
gateway/rest/router.go:450
↓ 1 callersFunctioncreateVersionHandler
(log log.Logger, pclient provider.Client)
gateway/rest/router.go:435
↓ 1 callersFunctioncreate_providerhosts
()
script/provider_migrate_to_hostname_operator.py:167
↓ 1 callersMethoddeploymentsForLease
(ctx context.Context, lid mtypes.LeaseID)
cluster/kube/client.go:1236
↓ 1 callersFunctiondepsFromBuildInfo
()
version/version.go:124
↓ 1 callersMethoddetectProvider
detectProvider creates a temporary TSM entry and reads the "provider" attribute to determine the underlying TEE type. Returns NameTDX for TDX guests,
sidecar/attestation/tee/configfs.go:36
↓ 1 callersMethoddisable
()
operator/ip/types.go:41
↓ 1 callersMethoddiscover
()
cluster/util/service_discovery_agent.go:162
↓ 1 callersMethoddiscoverDNS
()
cluster/util/service_discovery_agent.go:227
↓ 1 callersMethoddiscoverKube
()
cluster/util/service_discovery_agent.go:170
↓ 1 callersMethoddo
(fn func() error)
cluster/manager.go:603
↓ 1 callersMethoddoCheck
(ctx context.Context)
cluster/monitor.go:161
↓ 1 callersMethoddoCheckDeploymentExists
(req checkDeploymentExistsRequest)
cluster/service.go:449
↓ 1 callersMethoddoDeploy
(pctx context.Context)
cluster/manager.go:326
↓ 1 callersMethoddoFetchData
(ctx context.Context)
manifest/manager.go:258
↓ 1 callersFunctiondoLeaseAttestation
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseAttestation.go:57
↓ 1 callersFunctiondoLeaseEvents
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseEvents.go:37
↓ 1 callersFunctiondoLeaseLogs
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseLogs.go:40
↓ 1 callersFunctiondoLeaseStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseStatus.go:31
↓ 1 callersFunctiondoMigrateRun
(ctx context.Context, cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:89
↓ 1 callersFunctiondoRunCmd
doRunCmd initializes all the Provider functionality, hangs, and awaits shutdown signals.
cmd/provider-services/cmd/run.go:475
↓ 1 callersFunctiondoSendManifest
(cmd *cobra.Command, sdlpath string)
cmd/provider-services/cmd/manifest.go:123
↓ 1 callersFunctiondoServiceStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/serviceStatus.go:36
↓ 1 callersFunctiondoStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/status.go:46
↓ 1 callersMethoddoTeardown
(ctx context.Context)
cluster/manager.go:501
↓ 1 callersFunctiondseqFromFlags
(flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:104
↓ 1 callersMethoddup
nolint: unused
operator/inventory/ceph.go:97
↓ 1 callersMethoddup
()
cluster/kube/operators/clients/inventory/inventory.go:40
↓ 1 callersMethodeach
(f func(k mtypes.LeaseID, failure error, failedAt time.Time, count uint, extra ...string) error)
operator/common/ignore_list.go:89
↓ 1 callersMethodemitReceivedEvents
()
manifest/manager.go:338
↓ 1 callersMethodenable
()
operator/ip/types.go:37
↓ 1 callersFunctionencodeAuth
(username, password string)
cluster/kube/builder/service_credentials.go:105
↓ 1 callersFunctionensureConfigfsTSM
ensureConfigfsTSM is a no-op on non-Linux platforms.
sidecar/attestation/tee/setup_other.go:6
↓ 1 callersMethodensureDirStructure
()
tools/certissuer/storage.go:628
↓ 1 callersFunctionensureNvidiaDevices
ensureNvidiaDevices is a no-op on non-Linux platforms.
sidecar/attestation/tee/setup_other.go:12
↓ 1 callersFunctionensureSEVGuestDev
ensureSEVGuestDev is a no-op on non-Linux platforms.
sidecar/attestation/tee/setup_other.go:9
↓ 1 callersMethodenter
()
operator/ip/types.go:45
↓ 1 callersFunctionerrorIsKubernetesResourceNotFound
(failure error)
operator/hostname/operator.go:281
↓ 1 callersFunctioneventsResourceMapping
eventsResourceMapping returns the policy mapping for "events" resource
cluster/kube/builder/permissions.go:154
↓ 1 callersFunctionfabricOfFirstHCA
fabricOfFirstHCA reads `<root>/<first device>/ports/1/link_layer` and translates the result into the provider's fabric string. Returns the empty strin
operator/inventory/infiniband.go:131
↓ 1 callersMethodfailAllPending
(auditor string, err error)
bidengine/provider_attributes.go:215
↓ 1 callersFunctionfakeIPOperatorHandler
()
cluster/kube/operators/clients/ip/client_test.go:48
↓ 1 callersFunctionfamilyPrefix
familyPrefix returns the HCA family portion of a device name by stripping the trailing instance index (and the optional `_` separator preceding it). E
operator/inventory/infiniband.go:110
↓ 1 callersMethodfetch
(ctx context.Context, auditor string)
bidengine/provider_attributes.go:314
↓ 1 callersMethodfetchData
(ctx context.Context)
manifest/manager.go:246
↓ 1 callersMethodfindAttestationSidecarPod
findAttestationSidecarPod finds a running pod in the lease namespace that contains the attestation sidecar container. Returns the pod name. When serv
cluster/kube/client_attestation.go:77
↓ 1 callersFunctionfindDeployments
( ctx context.Context, log log.Logger, client Client, )
cluster/service.go:479
↓ 1 callersMethodfromCRD
()
pkg/apis/akash.network/v2beta2/manifest.go:270
↓ 1 callersFunctiongenerateJWT
generateJWT creates a signed JWT token for gRPC auth, replicating the chain-sdk client's newJWT().
cmd/provider-services/cmd/leaseAttestation.go:175
↓ 1 callersFunctiongeneratePrivateKey
(file string, keyType certcrypto.KeyType)
tools/certissuer/storage.go:555
↓ 1 callersMethodgetBidTimeout
()
bidengine/order.go:151
↓ 1 callersFunctiongetCertificateChain
(certRes *certificate.Resource)
tools/certissuer/storage.go:678
↓ 1 callersMethodgetCleanupRetryOpts
(ctx context.Context)
cluster/manager.go:484
↓ 1 callersMethodgetFileName
(domain string, extension string)
tools/certissuer/storage.go:444
↓ 1 callersMethodgetHostnameDeploymentConnections
(ctx context.Context)
operator/hostname/operator.go:503
↓ 1 callersMethodgetHostnameDeploymentConnectionsGateway
(ctx context.Context)
operator/hostname/operator_gateway.go:28
↓ 1 callersMethodgetHostnameDeploymentConnectionsGateway
(ctx context.Context)
cluster/kube/client_gateway.go:56
↓ 1 callersFunctiongetKubernetesIP
()
integration/e2e_test.go:741
↓ 1 callersMethodgetManifestGroup
(ctx context.Context, lID mtypes.LeaseID)
operator/hostname/operator.go:665
↓ 1 callersFunctiongetManifestHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:506
↓ 1 callersFunctiongetPFXEncoder
(pfxFormat string)
tools/certissuer/storage.go:662
↓ 1 callersMethodgetPermissions
getPermissions returns the read permissions list for backward compatibility. Deprecated: Use GetWorkloadPermissions() for access to all permission typ
cluster/kube/builder/workload.go:665
↓ 1 callersFunctiongetSDKVersion
()
version/version.go:152
↓ 1 callersMethodgetStatus
(state *inventoryServiceState)
cluster/inventory.go:901
↓ 1 callersFunctionget_tenant_namespaces
()
script/provider_migrate_to_hostname_operator.py:82
↓ 1 callersFunctiongrpcAddrFromProviderURL
grpcAddrFromProviderURL takes the provider's REST URL and returns host:8444 for gRPC.
cmd/provider-services/cmd/leaseAttestation.go:166
↓ 1 callersMethodhandleEvent
(ev pubsub.Event)
bidengine/provider_attributes.go:196
← previousnext →801–900 of 2,942, ranked by callers