Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/akash-network/provider
/ functions
Functions
2,942 in github.com/akash-network/provider
⨍
Functions
2,942
◇
Types & classes
699
↓ 1 callers
Function
nodeCmd
()
cmd/provider-services/cmd/root.go:79
↓ 1 callers
Function
nodeResetAllocated
(node *v1.Node)
operator/inventory/node-discovery.go:906
↓ 1 callers
Method
observeHostnameState
(ctx context.Context)
operator/hostname/operator.go:547
↓ 1 callers
Method
obtainCert
(domain string)
tools/certissuer/lego.go:226
↓ 1 callers
Method
ordersFetcher
(ctx context.Context, aqc sclient.QueryClient)
bidengine/service.go:186
↓ 1 callers
Function
parseCPU
(res *rtypes.CPU)
bidengine/shellscript.go:55
↓ 1 callers
Method
parseCPUInfo
(ctx context.Context)
operator/inventory/node-discovery.go:1146
↓ 1 callers
Function
parseDeploymentID
(req *http.Request)
gateway/rest/middleware.go:178
↓ 1 callers
Function
parseLeaseID
(req *http.Request)
gateway/rest/middleware.go:185
↓ 1 callers
Function
parseMemory
(res *rtypes.Memory)
bidengine/shellscript.go:59
↓ 1 callers
Function
parseMultiGPUOutput
parseMultiGPUOutput parses the binary output from `nvml_attestation attest-all`.
sidecar/attestation/tee/nvidia_gpu.go:112
↓ 1 callers
Function
parseStorage
(resource rtypes.Volumes)
bidengine/shellscript.go:110
↓ 1 callers
Function
parseVersionPart
parseVersionPart parses a version part at the given index. Returns 0 if the index is out of bounds.
migrations/registry.go:213
↓ 1 callers
Function
parseWriteOpions
(opts ...WriteOption)
tools/certissuer/storage.go:127
↓ 1 callers
Function
parse_labels
(data)
script/provider_migrate_to_hostname_operator.py:23
↓ 1 callers
Method
persistentVolumeClaims
()
cluster/kube/builder/workload.go:317
↓ 1 callers
Function
placementAttrs
placementAttrs extracts the placement requirements attributes from any of the concrete ResourceGroup shapes the provider's commit path produces. Retur
cluster/kube/operators/clients/inventory/interconnect.go:115
↓ 1 callers
Function
placementFabricFromAttrs
(attrs attrtypes.Attributes)
cluster/kube/operators/clients/inventory/interconnect.go:130
↓ 1 callers
Method
processAttrReq
(ctx context.Context, req attrRequest)
bidengine/provider_attributes.go:440
↓ 1 callers
Method
prune
()
operator/hostname/operator.go:275
↓ 1 callers
Function
ptrGroup
(s string)
migrations/ingress_to_httproute.go:264
↓ 1 callers
Function
ptrKind
(s string)
migrations/ingress_to_httproute.go:269
↓ 1 callers
Method
publishStatus
(status event.ClusterDeploymentStatus)
cluster/monitor.go:212
↓ 1 callers
Method
purgeAll
(ctx context.Context)
cluster/manager_cleanup.go:49
↓ 1 callers
Method
purgeAuditor
(auditor string)
bidengine/provider_attributes.go:177
↓ 1 callers
Method
queryCPU
(ctx context.Context)
operator/inventory/node-discovery.go:132
↓ 1 callers
Method
queryGPU
(ctx context.Context)
operator/inventory/node-discovery.go:153
↓ 1 callers
Method
queryIB
queryIB asks the per-node psutil pod to walk /sys/class/infiniband and return the host's HCA prefix + fabric. A zero-valued result means the node has
operator/inventory/node-discovery.go:140
↓ 1 callers
Method
queryPCI
queryPCI asks the per-node psutil pod for the host's PCI bus enumeration. Used as a fallback when ghw's `/sys/class/drm` walk misses compute GPUs (hea
operator/inventory/node-discovery.go:149
↓ 1 callers
Function
quoteHandler
(provider tee.Provider, binding *TLSBinding)
sidecar/attestation/server.go:79
↓ 1 callers
Function
rancherStorageInventoryLogValue
(scs rancherStorageClasses)
operator/inventory/diagnostics.go:179
↓ 1 callers
Method
readFile
(domain string, extension string)
tools/certissuer/storage.go:455
↓ 1 callers
Method
ready
()
cluster/inventory.go:174
↓ 1 callers
Function
readyNode
(taints ...corev1.Taint)
operator/inventory/node-discovery_test.go:206
↓ 1 callers
Method
recordEventError
(ev chostname.ResourceEvent, failure error)
operator/hostname/operator.go:300
↓ 1 callers
Method
recordEventError
(ev cip.ResourceEvent, failure error)
operator/ip/operator.go:217
↓ 1 callers
Method
recover
(ctx context.Context, kc kubernetes.Interface, ac akashclient.Interface)
cluster/kube/client.go:286
↓ 1 callers
Function
registerError
(err IPOperatorError)
operator/ip/types/error_response.go:53
↓ 1 callers
Function
registryLoader
this function is piece of sh*t. refactor it!
operator/inventory/cmd.go:360
↓ 1 callers
Method
removeHostnameFromDeploymentGateway
(ctx context.Context, hostname string, leaseID mtypes.LeaseID, allowMissing bool)
operator/hostname/operator_gateway.go:23
↓ 1 callers
Method
removeHostnameFromDeploymentGateway
(ctx context.Context, hostname string, leaseID mtypes.LeaseID, allowMissing bool)
cluster/kube/client_gateway.go:51
↓ 1 callers
Method
removeLease
(id mtypes.LeaseID)
manifest/manager.go:109
↓ 1 callers
Function
removeManagedLabels
(in map[string]string)
operator/inventory/node-discovery.go:1038
↓ 1 callers
Function
remove_ingresses
()
script/provider_migrate_to_hostname_operator.py:122
↓ 1 callers
Function
requestLogTailLines
(req *http.Request)
gateway/rest/middleware.go:43
↓ 1 callers
Function
requestService
(req *http.Request)
gateway/rest/middleware.go:47
↓ 1 callers
Function
requireEndpointScopeForDeploymentID
(scope ajwt.PermissionScope)
gateway/rest/middleware.go:71
↓ 1 callers
Function
requireEndpointScopeForLeaseID
(scope ajwt.PermissionScope)
gateway/rest/middleware.go:88
↓ 1 callers
Function
requireService
()
gateway/rest/middleware.go:161
↓ 1 callers
Function
reservationCountEndpoints
(reservation *reservation)
cluster/inventory.go:1002
↓ 1 callers
Function
resolveProviderURL
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet, cl aclient.QueryClient, paddr sdk.AccAddre
cmd/provider-services/cmd/helpers.go:356
↓ 1 callers
Function
resourcePatternMatches
resourcePatternMatches applies one pattern to one kubelet resource name. Bare strings (no `*`, `?`, or `[`) match as a literal prefix — the rc4 contra
operator/inventory/node-discovery.go:832
↓ 1 callers
Function
resourcesFromAkash
(aru rtypes.Resources)
pkg/apis/akash.network/v2beta2/types.go:180
↓ 1 callers
Method
resourcesToCommit
(rgroup dtypes.ResourceGroup)
cluster/inventory.go:290
↓ 1 callers
Method
run
(startCh chan<- error)
balance_checker.go:214
↓ 1 callers
Method
run
()
service.go:235
↓ 1 callers
Method
run
()
tools/certissuer/lego.go:249
↓ 1 callers
Method
run
(ctx context.Context)
operator/waiter/waiter.go:58
↓ 1 callers
Method
run
(startch chan<- struct{})
operator/inventory/ceph.go:168
↓ 1 callers
Method
run
(startch chan<- struct{})
operator/inventory/rancher.go:75
↓ 1 callers
Method
run
(checkForExistingBid bool)
bidengine/order.go:174
↓ 1 callers
Method
run
(ctx context.Context)
bidengine/service.go:249
↓ 1 callers
Method
run
()
bidengine/provider_attributes.go:124
↓ 1 callers
Method
run
()
manifest/service.go:237
↓ 1 callers
Method
run
run waits for the manifest timeout, then broadcasts MsgCloseBid. Once the close-bid broadcast starts, it must not inherit watchdog shutdown cancellat
manifest/watchdog.go:65
↓ 1 callers
Method
run
(donech chan<- *manager)
manifest/manager.go:141
↓ 1 callers
Method
run
(ctx context.Context, reservationsArg []*reservation)
cluster/inventory.go:585
↓ 1 callers
Method
run
()
cluster/hostname.go:315
↓ 1 callers
Method
run
()
cluster/monitor.go:73
↓ 1 callers
Method
run
(ctx context.Context, deployments []ctypes.IDeployment)
cluster/service.go:304
↓ 1 callers
Method
run
(ctx context.Context)
cluster/manager.go:148
↓ 1 callers
Method
run
()
cluster/util/service_discovery_agent.go:63
↓ 1 callers
Method
runCheck
(ctx context.Context)
cluster/monitor.go:154
↓ 1 callers
Method
runCloseLease
(ctx context.Context)
cluster/monitor.go:195
↓ 1 callers
Method
runEscrowCheck
(ctx context.Context, lid mtypes.LeaseID, scheduledWithdraw bool, res chan<- leaseCheckResponse)
balance_checker.go:113
↓ 1 callers
Function
runMigrationsOnStartup
(ctx context.Context, cmd *cobra.Command, logger log.Logger)
cmd/provider-services/cmd/run.go:980
↓ 1 callers
Method
runPriceFeed
(ctx context.Context)
integration/e2e_test.go:566
↓ 1 callers
Function
sParamsEnsureGPU
(sparams *crd.SchedulerParams)
cluster/types/v1beta3/clients/inventory/inventory.go:657
↓ 1 callers
Function
sParamsEnsureGPU
(sparams *crd.SchedulerParams)
cluster/kube/operators/clients/inventory/inventory.go:638
↓ 1 callers
Function
sParamsEnsureResources
(sparams *crd.SchedulerParams)
cluster/types/v1beta3/clients/inventory/inventory.go:665
↓ 1 callers
Function
sanitizeCluster
(cluster *inventoryV1.Cluster)
cluster/kube/operators/clients/inventory/inventory.go:64
↓ 1 callers
Function
sanitizeNodeResources
(resources *inventoryV1.NodeResources)
cluster/kube/operators/clients/inventory/inventory.go:74
↓ 1 callers
Function
sanitizeQuantity
(quantity *resource.Quantity)
cluster/kube/operators/clients/inventory/inventory.go:90
↓ 1 callers
Function
sanitizeStatusCluster
(cluster *inventoryV1.Cluster)
cluster/inventory.go:971
↓ 1 callers
Function
sanitizeStatusNodeResources
(resources *inventoryV1.NodeResources)
cluster/inventory.go:981
↓ 1 callers
Function
sanitizeStatusQuantity
(quantity *resource.Quantity)
cluster/inventory.go:996
↓ 1 callers
Function
scWatcher
(ctx context.Context)
operator/inventory/cmd.go:485
↓ 1 callers
Method
scheduleRetry
()
cluster/monitor.go:222
↓ 1 callers
Function
servePreparedResult
(rw http.ResponseWriter, pd *preparedResult)
operator/common/prepared_data.go:60
↓ 1 callers
Function
serviceHasReadPermissions
(service manitypes.Service)
cluster/kube/builder/netpol.go:338
↓ 1 callers
Function
setCurrentVersionOrDefault
(registry *migrations.Registry)
cmd/provider-services/cmd/migrate_run.go:136
↓ 1 callers
Method
setHealthStatus
(status int)
cluster/kube/operators/clients/ip/client_test.go:34
↓ 1 callers
Method
setIPLeaseStatusResponse
(status int, body []byte)
cluster/kube/operators/clients/ip/client_test.go:38
↓ 1 callers
Method
setIPUsageResponse
(status int, body []byte)
cluster/kube/operators/clients/ip/client_test.go:43
↓ 1 callers
Method
setResult
(factory clientFactory, err error)
cluster/util/service_discovery_agent.go:117
↓ 1 callers
Method
setupClient
(ctx context.Context)
cluster/kube/operators/clients/metallb/client.go:106
↓ 1 callers
Function
setupGuestRootfs
setupGuestRootfs is a no-op on non-Linux platforms.
sidecar/attestation/tee/setup_other.go:15
↓ 1 callers
Function
setupInventoryGRPC
(ctx context.Context, group *errgroup.Group, port int)
cluster/kube/operators/clients/inventory/client_test.go:250
↓ 1 callers
Method
shouldBid
(group *dtypes.Group)
bidengine/order.go:524
↓ 1 callers
Method
shutdown
()
operator/inventory/node-discovery.go:87
← previous
next →
1,001–1,100 of 2,942, ranked by callers