MCPcopy Create free account

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

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

⨍ Functions 2,680◇ Types & classes 661
↓ 1 callersMethodprocessAttrReq
(ctx context.Context, req attrRequest)
bidengine/provider_attributes.go:440
↓ 1 callersMethodprune
()
operator/hostname/operator.go:275
↓ 1 callersFunctionptrGroup
(s string)
migrations/ingress_to_httproute.go:264
↓ 1 callersFunctionptrKind
(s string)
migrations/ingress_to_httproute.go:269
↓ 1 callersMethodpublishStatus
(status event.ClusterDeploymentStatus)
cluster/monitor.go:212
↓ 1 callersMethodpurgeAll
(ctx context.Context)
cluster/manager_cleanup.go:49
↓ 1 callersMethodpurgeAuditor
(auditor string)
bidengine/provider_attributes.go:177
↓ 1 callersMethodqueryCPU
(ctx context.Context)
operator/inventory/node-discovery.go:88
↓ 1 callersMethodqueryGPU
(ctx context.Context)
operator/inventory/node-discovery.go:121
↓ 1 callersMethodreadFile
(domain string, extension string)
tools/certissuer/storage.go:455
↓ 1 callersMethodready
()
cluster/inventory.go:164
↓ 1 callersMethodrecordEventError
(ev chostname.ResourceEvent, failure error)
operator/hostname/operator.go:300
↓ 1 callersMethodrecordEventError
(ev cip.ResourceEvent, failure error)
operator/ip/operator.go:217
↓ 1 callersMethodrecover
(ctx context.Context, kc kubernetes.Interface, ac akashclient.Interface)
cluster/kube/client.go:286
↓ 1 callersFunctionregisterError
(err IPOperatorError)
operator/ip/types/error_response.go:53
↓ 1 callersFunctionregistryLoader
this function is piece of sh*t. refactor it!
operator/inventory/cmd.go:360
↓ 1 callersMethodremoveHostnameFromDeploymentGateway
(ctx context.Context, hostname string, leaseID mtypes.LeaseID, allowMissing bool)
operator/hostname/operator_gateway.go:23
↓ 1 callersMethodremoveHostnameFromDeploymentGateway
(ctx context.Context, hostname string, leaseID mtypes.LeaseID, allowMissing bool)
cluster/kube/client_gateway.go:51
↓ 1 callersMethodremoveLease
(id mtypes.LeaseID)
manifest/manager.go:109
↓ 1 callersFunctionremoveManagedLabels
(in map[string]string)
operator/inventory/node-discovery.go:790
↓ 1 callersFunctionremove_ingresses
()
script/provider_migrate_to_hostname_operator.py:122
↓ 1 callersFunctionrequestLogTailLines
(req *http.Request)
gateway/rest/middleware.go:43
↓ 1 callersFunctionrequestService
(req *http.Request)
gateway/rest/middleware.go:47
↓ 1 callersFunctionrequireEndpointScopeForDeploymentID
(scope ajwt.PermissionScope)
gateway/rest/middleware.go:71
↓ 1 callersFunctionrequireEndpointScopeForLeaseID
(scope ajwt.PermissionScope)
gateway/rest/middleware.go:88
↓ 1 callersFunctionrequireService
()
gateway/rest/middleware.go:161
↓ 1 callersFunctionreservationCountEndpoints
(reservation *reservation)
cluster/inventory.go:872
↓ 1 callersFunctionresourcesFromAkash
(aru rtypes.Resources)
pkg/apis/akash.network/v2beta2/types.go:180
↓ 1 callersMethodresourcesToCommit
(rgroup dtypes.ResourceGroup)
cluster/inventory.go:280
↓ 1 callersMethodrun
(startCh chan<- error)
balance_checker.go:214
↓ 1 callersMethodrun
()
service.go:234
↓ 1 callersMethodrun
()
tools/certissuer/lego.go:249
↓ 1 callersMethodrun
(ctx context.Context)
operator/waiter/waiter.go:58
↓ 1 callersMethodrun
(startch chan<- struct{})
operator/inventory/ceph.go:168
↓ 1 callersMethodrun
(startch chan<- struct{})
operator/inventory/rancher.go:75
↓ 1 callersMethodrun
(checkForExistingBid bool)
bidengine/order.go:174
↓ 1 callersMethodrun
(ctx context.Context)
bidengine/service.go:249
↓ 1 callersMethodrun
()
bidengine/provider_attributes.go:124
↓ 1 callersMethodrun
()
manifest/service.go:237
↓ 1 callersMethodrun
()
manifest/watchdog.go:61
↓ 1 callersMethodrun
(donech chan<- *manager)
manifest/manager.go:141
↓ 1 callersMethodrun
(ctx context.Context, reservationsArg []*reservation)
cluster/inventory.go:489
↓ 1 callersMethodrun
()
cluster/hostname.go:315
↓ 1 callersMethodrun
()
cluster/monitor.go:73
↓ 1 callersMethodrun
(ctx context.Context, deployments []ctypes.IDeployment)
cluster/service.go:304
↓ 1 callersMethodrun
(ctx context.Context)
cluster/manager.go:148
↓ 1 callersMethodrun
()
cluster/util/service_discovery_agent.go:63
↓ 1 callersMethodrunCheck
(ctx context.Context, state *inventoryServiceState)
cluster/inventory.go:757
↓ 1 callersMethodrunCheck
(ctx context.Context)
cluster/monitor.go:154
↓ 1 callersMethodrunCloseLease
(ctx context.Context)
cluster/monitor.go:195
↓ 1 callersMethodrunEscrowCheck
(ctx context.Context, lid mtypes.LeaseID, scheduledWithdraw bool, res chan<- leaseCheckResponse)
balance_checker.go:113
↓ 1 callersFunctionrunMigrationsOnStartup
(ctx context.Context, cmd *cobra.Command, logger log.Logger)
cmd/provider-services/cmd/run.go:849
↓ 1 callersMethodrunPriceFeed
(ctx context.Context)
integration/e2e_test.go:566
↓ 1 callersFunctionsParamsEnsureGPU
(sparams *crd.SchedulerParams)
cluster/kube/operators/clients/inventory/inventory.go:397
↓ 1 callersFunctionsParamsEnsureResources
(sparams *crd.SchedulerParams)
cluster/kube/operators/clients/inventory/inventory.go:405
↓ 1 callersFunctionscWatcher
(ctx context.Context)
operator/inventory/cmd.go:485
↓ 1 callersMethodscheduleHealthcheck
()
cluster/monitor.go:226
↓ 1 callersMethodscheduleRetry
()
cluster/monitor.go:222
↓ 1 callersFunctionservePreparedResult
(rw http.ResponseWriter, pd *preparedResult)
operator/common/prepared_data.go:60
↓ 1 callersFunctionserviceHasReadPermissions
(service manitypes.Service)
cluster/kube/builder/netpol.go:324
↓ 1 callersFunctionsetCurrentVersionOrDefault
(registry *migrations.Registry)
cmd/provider-services/cmd/migrate_run.go:136
↓ 1 callersMethodsetHealthStatus
(status int)
cluster/kube/operators/clients/ip/client_test.go:34
↓ 1 callersMethodsetIPLeaseStatusResponse
(status int, body []byte)
cluster/kube/operators/clients/ip/client_test.go:38
↓ 1 callersMethodsetIPUsageResponse
(status int, body []byte)
cluster/kube/operators/clients/ip/client_test.go:43
↓ 1 callersMethodsetResult
(factory clientFactory, err error)
cluster/util/service_discovery_agent.go:117
↓ 1 callersMethodsetupClient
(ctx context.Context)
cluster/kube/operators/clients/metallb/client.go:106
↓ 1 callersFunctionsetupInventoryGRPC
(ctx context.Context, group *errgroup.Group, port int)
cluster/kube/operators/clients/inventory/client_test.go:250
↓ 1 callersMethodshouldBid
(group *dtypes.Group)
bidengine/order.go:524
↓ 1 callersMethodshutdown
()
operator/inventory/node-discovery.go:82
↓ 1 callersMethodshutdown
()
cluster/monitor.go:65
↓ 1 callersMethodstartMonitor
()
cluster/manager.go:255
↓ 1 callersMethodstartTeardown
()
cluster/manager.go:312
↓ 1 callersMethodstartWithdraw
(ctx context.Context, lid mtypes.LeaseID)
balance_checker.go:202
↓ 1 callersMethodstatusRun
()
service.go:277
↓ 1 callersFunctionstrPtr
strPtr returns a pointer to the given string. TODO: go 1.26 makes this helper unnecessary.
cluster/kube/gateway/nginx_gateway.go:163
↓ 1 callersFunctionstrToBidPriceScale
(val string)
cmd/provider-services/cmd/run.go:397
↓ 1 callersFunctionsubAllocatedNLZ
(allocated *resource.Quantity, val resource.Quantity)
operator/inventory/node-discovery.go:736
↓ 1 callersMethodsubMilliNLZ
type clusterStorage map[string]*resourcePair func (cs clusterStorage) dup() clusterStorage { res := make(clusterStorage) for class, resources := ra
cluster/kube/resourcetypes.go:51
↓ 1 callersFunctionsubPodAllocatedResources
(node *v1.Node, pod *corev1.Pod)
operator/inventory/node-discovery.go:745
↓ 1 callersMethodsubmitPriceEntry
(ctx context.Context)
integration/e2e_test.go:592
↓ 1 callersMethodsubscriber
(in <-chan inventoryV1.Cluster, out chan<- ctypes.Inventory)
cluster/types/v1beta3/clients/inventory/inventory.go:231
↓ 1 callersMethodsubscriber
(in <-chan inventoryV1.Cluster, out chan<- ctypes.Inventory)
cluster/kube/operators/clients/inventory/client.go:208
↓ 1 callersMethodteardown
()
cluster/manager.go:125
↓ 1 callersMethodteardownLease
(lid mtypes.LeaseID)
cluster/service.go:461
↓ 1 callersMethodtimerFunc
(ctx context.Context, d time.Duration, lid mtypes.LeaseID, scheduledWithdraw bool, ch chan<- leaseCheckRespons
balance_checker.go:343
↓ 1 callersMethodtoAkash
()
pkg/apis/akash.network/v2beta2/manifest.go:368
↓ 1 callersFunctiontraverse_ingresses
()
script/provider_migrate_to_hostname_operator.py:134
↓ 1 callersMethodtrimCache
()
bidengine/provider_attributes.go:249
↓ 1 callersMethodtryAdjust
tryAdjust cluster inventory It returns two boolean values. First indicates if node-wide resources satisfy (true) requirements Seconds indicates if clu
cluster/types/v1beta3/clients/inventory/inventory.go:285
↓ 1 callersMethodtryAdjust
tryAdjust cluster inventory It returns two boolean values. First indicates if node-wide resources satisfy (true) requirements Seconds indicates if clu
cluster/kube/operators/clients/inventory/inventory.go:46
↓ 1 callersFunctiontryAdjustCPU
(rp *inventoryV1.ResourcePair, res *rtypes.CPU)
cluster/types/v1beta3/clients/inventory/inventory.go:360
↓ 1 callersFunctiontryAdjustCPU
(rp *inventoryV1.ResourcePair, res *rtypes.CPU)
cluster/kube/operators/clients/inventory/inventory.go:121
↓ 1 callersFunctiontryAdjustEphemeralStorage
(rp *inventoryV1.ResourcePair, res *rtypes.Storage)
cluster/kube/operators/clients/inventory/inventory.go:205
↓ 1 callersFunctiontryAdjustGPU
(rp *inventoryV1.GPU, res *rtypes.GPU, sparams *crd.SchedulerParams)
cluster/types/v1beta3/clients/inventory/inventory.go:364
↓ 1 callersFunctiontryAdjustGPU
(rp *inventoryV1.GPU, res *rtypes.GPU, sparams *crd.SchedulerParams)
cluster/kube/operators/clients/inventory/inventory.go:125
↓ 1 callersMethodtryFetchAttributes
(ctx context.Context)
bidengine/provider_attributes.go:408
↓ 1 callersMethodtryRecoverRegistration
(privateKey crypto.PrivateKey)
tools/certissuer/storage.go:599
↓ 1 callersMethodupdate
(deployment ctypes.IDeployment)
cluster/manager.go:116
↓ 1 callersMethodupdateCounts
(parentCtx context.Context)
operator/ip/operator.go:198
↓ 1 callersMethodupdateDeploymentManagerGauge
()
cluster/service.go:300
← previousnext →901–1,000 of 2,680, ranked by callers