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 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 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:317
↓ 1 callersMethodimagePullSecrets
()
cluster/kube/builder/workload.go:397
↓ 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)
operator/inventory/node-discovery.go:637
↓ 1 callersFunctioninventoryRun
(ctx context.Context, endpoint string, invch chan<- inventoryState)
cluster/kube/operators/clients/inventory/client.go:376
↓ 1 callersMethodisEventIgnored
(ev chostname.ResourceEvent)
operator/hostname/operator.go:318
↓ 1 callersFunctionisNodeReady
(conditions []corev1.NodeCondition)
operator/inventory/node-discovery.go:804
↓ 1 callersFunctionisPodAllocated
(status corev1.PodStatus)
operator/inventory/node-discovery.go:344
↓ 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 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:515
↓ 1 callersFunctionleaseLogsHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:638
↓ 1 callersFunctionleaseServiceStatusHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:627
↓ 1 callersFunctionleaseShellHandler
(log log.Logger, cclient cluster.Client)
gateway/rest/router.go:233
↓ 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:539
↓ 1 callersFunctionleasedIPStatus
(state *inventoryServiceState)
cluster/inventory.go:435
↓ 1 callersFunctionloadConfig
(cfg string, defaultOnErr bool)
operator/inventory/config.go:59
↓ 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:168
↓ 1 callersFunctionmakeGlobalServiceNameFromBasename
(basename string)
cluster/kube/builder/builder.go:283
↓ 1 callersFunctionmakeMetricsRouter
()
cmd/provider-services/cmd/metrics.go:9
↓ 1 callersFunctionmakeMocks
(s *orderTestScaffold)
bidengine/order_test.go:69
↓ 1 callersFunctionmanifestGroupToCRD
manifestGroupToCRD returns manifest group instance from akash group
pkg/apis/akash.network/v2beta2/manifest.go:221
↓ 1 callersFunctionmanifestServiceExposeFromAkash
(amse mani.ServiceExpose)
pkg/apis/akash.network/v2beta2/manifest.go:400
↓ 1 callersFunctionmanifestServiceFromProvider
(ams mani.Service, schedulerParams *SchedulerParams)
pkg/apis/akash.network/v2beta2/manifest.go:309
↓ 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 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 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 callersFunctionmultipleSvcReplicasGenReservations
(cpuUnits, gpuUnits uint64, count uint32)
cluster/kube/operators/clients/inventory/client_test.go:746
↓ 1 callersFunctionmustCreateCertWithCN
(t *testing.T, cn string)
gateway/utils/utils_test.go:119
↓ 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:260
↓ 1 callersFunctionnewInventory
(clState inventoryV1.Cluster)
cluster/kube/operators/clients/inventory/inventory.go:21
↓ 1 callersFunctionnewInventoryConnector
(ctx context.Context, svc *corev1.Service, invch chan<- inventoryState)
cluster/kube/operators/clients/inventory/client.go:237
↓ 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:59
↓ 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:108
↓ 1 callersFunctionnewQuerierNodes
()
operator/inventory/types.go:114
↓ 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:621
↓ 1 callersFunctionnodeCmd
()
cmd/provider-services/cmd/root.go:78
↓ 1 callersFunctionnodeResetAllocated
(node *v1.Node)
operator/inventory/node-discovery.go:699
↓ 1 callersFunctionnodeSelectorsFromResources
(res *crd.SchedulerResources)
cluster/kube/builder/workload.go:341
↓ 1 callersMethodobserveHostnameState
(ctx context.Context)
operator/hostname/operator.go:547
↓ 1 callersMethodobtainCert
(domain string)
tools/certissuer/lego.go:226
↓ 1 callersMethodordersFetcher
(ctx context.Context, aqc sclient.QueryClient)
bidengine/service.go:186
↓ 1 callersFunctionparseCPU
(res *rtypes.CPU)
bidengine/shellscript.go:55
↓ 1 callersMethodparseCPUInfo
(ctx context.Context)
operator/inventory/node-discovery.go:885
↓ 1 callersFunctionparseDeploymentID
(req *http.Request)
gateway/rest/middleware.go:178
↓ 1 callersFunctionparseLeaseID
(req *http.Request)
gateway/rest/middleware.go:185
↓ 1 callersFunctionparseMemory
(res *rtypes.Memory)
bidengine/shellscript.go:59
↓ 1 callersFunctionparseStorage
(resource rtypes.Volumes)
bidengine/shellscript.go:110
↓ 1 callersFunctionparseVersionPart
parseVersionPart parses a version part at the given index. Returns 0 if the index is out of bounds.
migrations/registry.go:213
↓ 1 callersFunctionparseWriteOpions
(opts ...WriteOption)
tools/certissuer/storage.go:127
↓ 1 callersFunctionparse_labels
(data)
script/provider_migrate_to_hostname_operator.py:23
↓ 1 callersMethodpersistentVolumeClaims
()
cluster/kube/builder/workload.go:226
← previousnext →801–900 of 2,680, ranked by callers