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 callersFunctionhandleHTTPError
(op *ipOperator, rw http.ResponseWriter, req *http.Request, err error, status int)
operator/ip/operator.go:436
↓ 1 callersFunctionhandleIPLeaseStatusGet
(op *ipOperator, rw http.ResponseWriter, req *http.Request)
operator/ip/operator.go:514
↓ 1 callersMethodhandleLease
(ev event.LeaseWon, isNew bool)
manifest/service.go:349
↓ 1 callersMethodhandleManifest
(req manifestRequest)
manifest/manager.go:117
↓ 1 callersMethodhandleRequest
(req inventoryRequest, state *inventoryServiceState)
cluster/inventory.go:541
↓ 1 callersMethodhandleRequest
(req serviceDiscoveryRequest)
cluster/util/service_discovery_agent.go:108
↓ 1 callersMethodhandleUpdate
(version []byte)
manifest/manager.go:126
↓ 1 callersMethodhandleUpdate
(ctx context.Context)
cluster/manager.go:134
↓ 1 callersFunctionhealthHandler
()
sidecar/attestation/server.go:155
↓ 1 callersFunctionhex2bytes
sidecar/attestation/nvml-helper/nvml_attestation.c:72
↓ 1 callersFunctionhostCIDR
hostCIDR returns a single-host CIDR string for the given IP, using /32 for IPv4 and /128 for IPv6.
cluster/kube/builder/netpol.go:331
↓ 1 callersMethodimagePullSecrets
()
cluster/kube/builder/workload.go:575
↓ 1 callersFunctioninfoHandler
(provider tee.Provider, binding *TLSBinding)
sidecar/attestation/server.go:140
↓ 1 callersFunctioningressRules
(hostname string, kubeServiceName string, kubeServicePort int32)
operator/hostname/operator.go:764
↓ 1 callersFunctioningressRules
(hostname string, kubeServiceName string, kubeServicePort int32)
cluster/kube/client_ingress.go:160
↓ 1 callersFunctioninitDNSProviders
(providers []string)
tools/certissuer/lego.go:384
↓ 1 callersMethodinitNodeInfo
(gpusIDs RegistryGPUVendors, knode *corev1.Node, interconnectPatterns []string)
operator/inventory/node-discovery.go:719
↓ 1 callersFunctioninterconnectGroupNode
AKT-443 — bid-engine group-aware Adjust. tryAdjust now refuses to place two resources from the same interconnect group on the same node so the workloa
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:29
↓ 1 callersFunctioninterconnectGroupSpec
interconnectGroupSpec returns a representative GroupSpec carrying the placement attributes the test rows want.
cluster/kube/operators/clients/inventory/interconnect_test.go:71
↓ 1 callersFunctioninventoryRun
(ctx context.Context, endpoint string, invch chan<- inventoryState)
cluster/kube/operators/clients/inventory/client.go:378
↓ 1 callersMethodisEventIgnored
(ev chostname.ResourceEvent)
operator/hostname/operator.go:318
↓ 1 callersFunctionisNodeReady
isNodeReady reports whether the node can actually accept Akash workloads. It must be both in the Ready condition and free of any scheduling-blocking t
operator/inventory/node-discovery.go:1059
↓ 1 callersFunctionisPodAllocated
(status corev1.PodStatus)
operator/inventory/node-discovery.go:401
↓ 1 callersMethodisStaleBid
(bid mvbeta.Bid)
bidengine/order.go:159
↓ 1 callersFunctionisValidHTTPStatusCode
(codeStr string)
cluster/kube/gateway/nginx_gateway.go:167
↓ 1 callersFunctionkubeConfig
(t testing.TB)
pkg/apis/akash.network/v2beta2/k8s_integration_test.go:93
↓ 1 callersFunctionkubeNginxIngressAnnotations
(directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator.go:788
↓ 1 callersFunctionkubeNginxIngressAnnotations
(directive chostname.ConnectToDeploymentDirective)
cluster/kube/client_ingress.go:35
↓ 1 callersFunctionkubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
operator/hostname/operator.go:832
↓ 1 callersFunctionleaseAttestationCmd
()
cmd/provider-services/cmd/leaseAttestation.go:29
↓ 1 callersFunctionleaseEventsCmd
()
cmd/provider-services/cmd/leaseEvents.go:15
↓ 1 callersFunctionleaseIDFromFlags
(flags *pflag.FlagSet, owner string)
cmd/provider-services/cmd/helpers.go:108
↓ 1 callersFunctionleaseKubeEventsHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:529
↓ 1 callersFunctionleaseLogsHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:652
↓ 1 callersFunctionleaseServiceStatusHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:641
↓ 1 callersFunctionleaseShellHandler
(log log.Logger, cclient cluster.Client)
gateway/rest/router.go:243
↓ 1 callersFunctionleaseShellPingHandler
(ctx context.Context, wg *sync.WaitGroup, ws *websocket.Conn)
gateway/rest/router_shell.go:17
↓ 1 callersFunctionleaseShellWebsocketHandler
(log log.Logger, wg *sync.WaitGroup, shellWs *websocket.Conn, stdinPipeOut io.Writer, terminalSizeUpdate chan<
gateway/rest/router_shell.go:35
↓ 1 callersFunctionleaseStatusHandler
(log log.Logger, cclient cluster.ReadClient, clusterSettings map[interface{}]interface{})
gateway/rest/router.go:553
↓ 1 callersFunctionleasedIPStatus
(state *inventoryServiceState)
cluster/inventory.go:469
↓ 1 callersFunctionloadConfig
(cfg string, defaultOnErr bool)
operator/inventory/config.go:83
↓ 1 callersFunctionloadPrivateKey
(file string)
tools/certissuer/storage.go:578
↓ 1 callersMethodlocateServiceFromManifest
(ctx context.Context, leaseID mtypes.LeaseID, serviceName string, externalPort uint32)
operator/hostname/operator.go:386
↓ 1 callersFunctionlogsResourceMapping
logsResourceMapping returns the policy mapping for "logs" resource
cluster/kube/builder/permissions.go:123
↓ 1 callersMethodlookup
(order mtypes.OrderID, resources dtypes.ResourceGroup)
cluster/inventory.go:178
↓ 1 callersFunctionmakeGlobalServiceNameFromBasename
(basename string)
cluster/kube/builder/builder.go:324
↓ 1 callersFunctionmakeMetricsRouter
()
cmd/provider-services/cmd/metrics.go:9
↓ 1 callersFunctionmakeMocks
(s *orderTestScaffold)
bidengine/order_test.go:69
↓ 1 callersFunctionmakeWatchdogTestScaffoldWithBlocking
(t *testing.T, timeout time.Duration, blockUntilRelease <-chan struct{})
manifest/watchdog_test.go:39
↓ 1 callersFunctionmanifestGroupToCRD
manifestGroupToCRD returns manifest group instance from akash group
pkg/apis/akash.network/v2beta2/manifest.go:252
↓ 1 callersFunctionmanifestServiceExposeFromAkash
(amse mani.ServiceExpose)
pkg/apis/akash.network/v2beta2/manifest.go:447
↓ 1 callersFunctionmanifestServiceFromProvider
(ams mani.Service, schedulerParams *SchedulerParams)
pkg/apis/akash.network/v2beta2/manifest.go:341
↓ 1 callersMethodmaybeFetchData
maybeFetchData try fetch deployment and lease data if there is cached result the function returns nil channel which signals caller to process events
manifest/manager.go:234
↓ 1 callersMethodmaybeRemoveWatchdog
(deploymentID dtypes.DeploymentID)
manifest/service.go:343
↓ 1 callersMethodmaybeScheduleStop
()
manifest/manager.go:308
↓ 1 callersMethodmaybeStart
(ctx context.Context, auditor string)
bidengine/provider_attributes.go:296
↓ 1 callersFunctionmaybeWrapWithGPU
maybeWrapWithGPU probes for NVIDIA GPU CC support and wraps the CPU provider in a GPUCompositeProvider if available.
sidecar/attestation/tee/tee.go:112
↓ 1 callersFunctionmigrate
()
cmd/provider-services/cmd/migrate.go:7
↓ 1 callersFunctionmigrateEndpointHandler
(log log.Logger, clusterService cluster.Service, client cluster.Client)
gateway/rest/router_migrate_endpoint.go:29
↓ 1 callersFunctionmigrateHandler
(log log.Logger, hostnameService clustertypes.HostnameServiceClient, clusterService cluster.Service)
gateway/rest/router_migrate.go:22
↓ 1 callersMethodmigrateIngress
( ctx context.Context, dc dynamic.Interface, ingress *netv1.Ingress, gatewayName string, gatewayNamespace
migrations/ingress_to_httproute.go:88
↓ 1 callersFunctionmiscDevMinor
miscDevMinor reads /proc/misc to find the minor number for a named device.
sidecar/attestation/tee/setup_linux.go:165
↓ 1 callersFunctionmockManifestGroups
(m integrationMocks, leaseID mtypes.LeaseID)
gateway/rest/integration_test.go:201
↓ 1 callersMethodmonitorUntilError
()
operator/hostname/operator.go:163
↓ 1 callersMethodmonitorUntilError
(ctx context.Context)
operator/ip/operator.go:66
↓ 1 callersFunctionmountTmpfsAndCopyHelper
mountTmpfsAndCopyHelper is a no-op on non-Linux platforms.
sidecar/attestation/tee/setup_other.go:18
↓ 1 callersFunctionmultipleSvcReplicasGenReservations
(cpuUnits, gpuUnits uint64, count uint32)
cluster/kube/operators/clients/inventory/client_test.go:871
↓ 1 callersFunctionmustCreateCertWithCN
(t *testing.T, cn string)
gateway/utils/utils_test.go:119
↓ 1 callersMethodmutate
(req *admissionv1.AdmissionRequest)
cluster/kube/webhook/webhook.go:119
↓ 1 callersFunctionnegativeInventoryResources
(cluster *inventoryV1.Cluster)
operator/inventory/diagnostics.go:108
↓ 1 callersFunctionnewAccountQuerier
(ctx context.Context, cctx sdkclient.Context, log log.Logger, bus pubsub.Bus, qc aclient.Client, opts ...Accou
cmd/provider-services/cmd/certs.go:141
↓ 1 callersFunctionnewBalanceChecker
( ctx context.Context, aqc aclient.QueryClient, accAddr sdk.AccAddress, clientSession session.Session, bu
balance_checker.go:72
↓ 1 callersFunctionnewCertQuerier
(pstorage pconfig.Storage)
gateway/rest/integration_test.go:492
↓ 1 callersFunctionnewClusterNodes
(ctx context.Context, image, namespace string)
operator/inventory/nodes.go:46
↓ 1 callersFunctionnewDeployCleanupHelper
(lease mtypes.LeaseID, client Client, log logger.Logger)
cluster/manager_cleanup.go:27
↓ 1 callersFunctionnewDeploymentManager
(s *service, deployment ctypes.IDeployment, isNewLease bool)
cluster/manager.go:75
↓ 1 callersFunctionnewEventsFeedList
(ctx context.Context, events []eventsv1.Event)
cluster/kube/client.go:841
↓ 1 callersFunctionnewEventsFeedWatch
(ctx context.Context, events watch.Interface)
cluster/kube/client.go:858
↓ 1 callersFunctionnewFakeInventories
(fake *FakeAkashV2beta2)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/fake/fake_inventory.go:34
↓ 1 callersFunctionnewFakeInventoryRequests
(fake *FakeAkashV2beta2)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/fake/fake_inventoryrequest.go:34
↓ 1 callersFunctionnewFakeManifests
(fake *FakeAkashV2beta2, namespace string)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/fake/fake_manifest.go:34
↓ 1 callersFunctionnewFakeProviderHosts
(fake *FakeAkashV2beta2, namespace string)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/fake/fake_providerhost.go:34
↓ 1 callersFunctionnewFakeProviderLeasedIPs
(fake *FakeAkashV2beta2, namespace string)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/fake/fake_providerleasedip.go:34
↓ 1 callersFunctionnewHostnameOperator
(ctx context.Context, logger log.Logger, ns string, config common.OperatorConfig, ilc common.IgnoreListConfig)
operator/hostname/operator.go:64
↓ 1 callersFunctionnewInventories
newInventories returns a Inventories
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventory.go:63
↓ 1 callersFunctionnewInventory
(clState inventoryV1.Cluster)
cluster/types/v1beta3/clients/inventory/inventory.go:261
↓ 1 callersFunctionnewInventoryConnector
(ctx context.Context, svc *corev1.Service, invch chan<- inventoryState)
cluster/kube/operators/clients/inventory/client.go:239
↓ 1 callersFunctionnewInventoryRequests
newInventoryRequests returns a InventoryRequests
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventoryrequest.go:63
↓ 1 callersFunctionnewManager
(h *service, daddr dtypes.DeploymentID)
manifest/manager.go:44
↓ 1 callersFunctionnewManifests
newManifests returns a Manifests
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:59
↓ 1 callersFunctionnewNodeDiscovery
(ctx context.Context, name, namespace string, image string, sig chan<- string)
operator/inventory/node-discovery.go:64
↓ 1 callersFunctionnewOrder
(svc *service, oid mtypes.OrderID, cfg Config, pass ProviderAttrSignatureService, checkForExistingBid bool)
bidengine/order.go:102
↓ 1 callersFunctionnewProviderAttrSignatureService
(s session.Session, bus pubsub.Bus)
bidengine/provider_attributes.go:88
↓ 1 callersFunctionnewProviderHosts
newProviderHosts returns a ProviderHosts
pkg/client/clientset/versioned/typed/akash.network/v2beta2/providerhost.go:59
↓ 1 callersFunctionnewProviderLeasedIPs
newProviderLeasedIPs returns a ProviderLeasedIPs
pkg/client/clientset/versioned/typed/akash.network/v2beta2/providerleasedip.go:59
↓ 1 callersFunctionnewQuerierCluster
()
operator/inventory/types.go:110
↓ 1 callersFunctionnewQuerierNodes
()
operator/inventory/types.go:116
↓ 1 callersMethodnewRequest
(ctx context.Context, method string, path string, body io.Reader)
cluster/kube/operators/clients/hostname/client.go:51
↓ 1 callersFunctionnewServiceRouter
(apiTimeout, queryTimeout time.Duration)
operator/inventory/cmd.go:530
↓ 1 callersFunctionnodeAllocatableChanged
(prev *corev1.Node, curr *corev1.Node)
operator/inventory/node-discovery.go:703
← previousnext →901–1,000 of 2,942, ranked by callers