MCPcopy Create free account

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

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

↓ 2 callersFunctionNewSharedInformerFactoryWithOptions
NewSharedInformerFactoryWithOptions constructs a new instance of a SharedInformerFactory with additional options.
pkg/client/informers/externalversions/factory.go:106
↓ 2 callersFunctionOpenLogger
()
operator/common/logger.go:11
↓ 2 callersFunctionOperatorsCmd
()
operator/cmd.go:27
↓ 2 callersFunctionParseIngressMode
ParseIngressMode parses a string into an IngressMode, returning an error if the value is invalid.
cluster/kube/builder/settings.go:22
↓ 2 callersFunctionParseStorageAttributes
(attrs attrtypes.Attributes)
cluster/types/v1beta3/clients/inventory/metrics.go:127
↓ 2 callersMethodPatch
(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...stri
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:48
↓ 2 callersFunctionPersistentConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:269
↓ 2 callersFunctionPlacementRequiredFabric
PlacementRequiredFabric reports whether a deployment-group's placement requirements pin interconnect to a specific fabric. Returns (fabric, true) when
cluster/kube/operators/clients/inventory/interconnect.go:107
↓ 2 callersMethodPrepare
(pd PreparedResult)
operator/common/ignore_list.go:21
↓ 2 callersMethodProviderHosts
ProviderHosts returns a ProviderHostInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:34
↓ 2 callersMethodPurgeIPPassthrough
(ctx context.Context, directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:57
↓ 2 callersMethodRegister
Register adds a new resource policy mapping to the registry
cluster/kube/builder/permissions.go:80
↓ 2 callersMethodReleaseHostnames
(leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:288
↓ 2 callersFunctionResourceInterconnectGroup
ResourceInterconnectGroup returns the peer-group label declared on this per-service resource and whether the interconnect opt-in attribute is present
cluster/kube/operators/clients/inventory/interconnect.go:69
↓ 2 callersFunctionRunCmd
RunCmd launches the Akash Provider service
cmd/provider-services/cmd/run.go:198
↓ 2 callersMethodServiceStatus
ServiceStatus provides a mock function for the type Client
mocks/cluster/Client_mock.go:1577
↓ 2 callersMethodSetAllocatedResources
(dtypes.ResourceUnits)
cluster/types/v1beta3/reservation.go:10
↓ 2 callersMethodSize
()
operator/common/ignore_list.go:16
↓ 2 callersMethodString
()
version/version.go:141
↓ 2 callersMethodTeardownLease
(context.Context, mtypes.LeaseID)
cluster/client.go:66
↓ 2 callersMethodToAkash
()
pkg/apis/akash.network/v2beta2/types.go:170
↓ 2 callersMethodUnwrap
()
utils/httperror/httperror.go:37
↓ 2 callersFunctionaccumEndpointsOfResources
(r rtypes.Resources, kind rtypes.Endpoint_Kind, accum map[uint32]struct{})
cluster/util/endpoint_quantity.go:17
↓ 2 callersFunctionaddManifestFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:83
↓ 2 callersMethodadjustOpts
(teeType ctypes.TEEType)
cluster/inventory.go:533
↓ 2 callersFunctionappEnv
appEnv asserts that there is an addressable docker container for KinD
integration/test_helpers.go:168
↓ 2 callersMethodbidTimeoutEnabled
()
bidengine/order.go:147
↓ 2 callersMethodbuildHTTPRoute
( name string, labels map[string]string, ingressAnnotations map[string]string, gatewayName string, gatewa
migrations/ingress_to_httproute.go:144
↓ 2 callersFunctionbuildIPDirective
(ev cip.ResourceEvent)
operator/ip/operator.go:273
↓ 2 callersMethodbuildPolicyRules
buildPolicyRules generates Kubernetes RBAC policy rules based on the workload permissions. It uses the PolicyRuleRegistry to map resource types (logs,
cluster/kube/builder/role.go:50
↓ 2 callersFunctioncanReserveHostnamesImpl
(store map[string]hostnameID, hostnames []string, ownerAddr sdktypes.Address, chErr chan<- error)
cluster/hostname.go:204
↓ 2 callersMethodchrootExec
chrootExec runs a binary inside the guest rootfs using SysProcAttr.Chroot. This uses the kernel chroot syscall directly, no external `chroot` binary n
sidecar/attestation/tee/nvidia_gpu.go:219
↓ 2 callersMethodchrootExecHelper
chrootExecHelper runs the nvml_attestation helper inside the chroot.
sidecar/attestation/tee/nvidia_gpu.go:235
↓ 2 callersMethodclearFetched
()
manifest/manager.go:134
↓ 2 callersMethodcloseDeployments
()
integration/e2e_test.go:626
↓ 2 callersMethodconvertAnnotations
(ingressAnnotations map[string]string)
migrations/ingress_to_httproute.go:212
↓ 2 callersFunctioncountReservedIPs
(state *inventoryServiceState)
cluster/inventory.go:445
↓ 2 callersFunctioncreateIPPassthroughResourceName
(directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:327
↓ 2 callersFunctiondetermineStatePath
(cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:112
↓ 2 callersFunctiondirExists
dirExists returns true if the path exists and is a directory.
sidecar/attestation/tee/tee.go:124
↓ 2 callersMethoddoEscrowCheck
(ctx context.Context, lid mtypes.LeaseID, scheduledWithdraw bool)
balance_checker.go:122
↓ 2 callersMethoddone
()
cluster/monitor.go:69
↓ 2 callersMethoddup
()
cluster/types/v1beta3/clients/inventory/inventory.go:269
↓ 2 callersMethodencodeSecret
()
cluster/kube/builder/service_credentials.go:89
↓ 2 callersMethodensureManager
(did dtypes.DeploymentID)
manifest/service.go:364
↓ 2 callersMethodensureMount
ensureMount prepares the chroot environment. Platform-specific setup (mknod, mount) is in setupGuestRootfs() defined per-platform. Uses sync.Once to g
sidecar/attestation/tee/nvidia_gpu.go:186
↓ 2 callersMethodexit
()
operator/ip/types.go:55
↓ 2 callersFunctionextractRemoteError
(response *http.Response)
cluster/kube/operators/clients/ip/client.go:155
↓ 2 callersFunctionfakeProviderHost
(hostname string, leaseID mtypes.LeaseID, serviceName string, externalPort uint32)
cluster/kube/client_test.go:47
↓ 2 callersMethodfetchAttributes
()
bidengine/provider_attributes.go:181
↓ 2 callersFunctionfileExists
(path string)
sidecar/attestation/tee/nvidia_gpu.go:239
↓ 2 callersMethodfillAllRequests
(response error)
manifest/manager.go:326
↓ 2 callersFunctiongenerateLabels
(cfg Config, knode *corev1.Node, node v1.Node, sc storageClasses)
operator/inventory/node-discovery.go:1075
↓ 2 callersMethodgetAnnotationInt
(annotations map[string]string, key string, defaultValue int)
migrations/ingress_to_httproute.go:252
↓ 2 callersMethodgetAnnotationValue
(annotations map[string]string, key string, defaultValue string)
migrations/ingress_to_httproute.go:245
↓ 2 callersFunctioninterconnectCapsSuitable
interconnectCapsSuitable reports whether a node's immutable capabilities can serve an interconnect resource at all: the inventory operator discovered
cluster/kube/operators/clients/inventory/interconnect.go:87
↓ 2 callersFunctioninterconnectGroupResourceN
interconnectGroupResourceN is like interconnectGroupResource but lets a test request fewer than a node's worth of GPUs. Tests that prove cross-group c
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:82
↓ 2 callersMethodisHostnameBlocked
(hostname string)
cluster/hostname.go:373
↓ 2 callersFunctionisLabelManaged
(key string)
operator/inventory/node-discovery.go:1020
↓ 2 callersFunctionisMockMode
(extraEnv []corev1.EnvVar)
cluster/kube/webhook/sidecar.go:193
↓ 2 callersFunctionjwtErrorToHTTP
jwtErrorToHTTP maps JWT parse results to HttpError for gateway responses.
gateway/utils/utils.go:164
↓ 2 callersMethodlabels
()
cluster/kube/builder/serviceaccount.go:26
↓ 2 callersMethodlabels
()
cluster/kube/builder/rolebinding.go:35
↓ 2 callersMethodlabels
()
cluster/kube/builder/manifest.go:36
↓ 2 callersMethodlabels
()
cluster/kube/builder/namespace.go:24
↓ 2 callersFunctionleaseLogsCmd
()
cmd/provider-services/cmd/leaseLogs.go:17
↓ 2 callersFunctionleaseStatusCmd
()
cmd/provider-services/cmd/leaseStatus.go:12
↓ 2 callersFunctionloadAuthOpts
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:242
↓ 2 callersFunctionlogNegativeClusterInventory
(log logr.Logger, cluster *inventoryV1.Cluster, source string)
operator/inventory/diagnostics.go:96
↓ 2 callersFunctionnccLHCAPrefixesOf
nccLHCAPrefixesOf returns every distinct HCA family prefix among the device names. For ConnectX-6/7 devices named `mlx5_0, mlx5_1, mlx5_2` this is ["m
operator/inventory/infiniband.go:72
↓ 2 callersFunctionnewDataForScript
(r Request)
bidengine/shellscript.go:193
↓ 2 callersFunctionnewHTTPWrapperServiceClient
(isHTTPS, secure bool, baseURL string)
cluster/util/service_client.go:26
↓ 2 callersFunctionnewHTTPWrapperServiceClientWithTransport
(transport http.RoundTripper, baseURL string)
cluster/util/service_client.go:59
↓ 2 callersFunctionnewHostnameService
(ctx context.Context, cfg Config, initialData map[string]mtypes.LeaseID)
cluster/hostname.go:279
↓ 2 callersFunctionnewIPOperator
(ctx context.Context, logger log.Logger, ns string, cfg common.OperatorConfig, ilc common.IgnoreListConfig, ml
operator/ip/operator.go:457
↓ 2 callersFunctionnewOrderInternal
(svc *service, oid mtypes.OrderID, cfg Config, pass ProviderAttrSignatureService, checkForExistingBid bool, re
bidengine/order.go:106
↓ 2 callersFunctionnewProviderAttrSignatureServiceInternal
(s session.Session, bus pubsub.Bus, ttl time.Duration)
bidengine/provider_attributes.go:92
↓ 2 callersFunctionnewReservation
(order mtypes.OrderID, resources dtypes.ResourceGroup)
cluster/reservation.go:12
↓ 2 callersFunctionnewRouter
(log log.Logger, addr sdk.Address, pclient provider.Client, ctxConfig map[interface{}]interface{}, middlewares
gateway/rest/router.go:93
↓ 2 callersFunctionnewWatchdog
(sess session.Session, parent <-chan struct{}, done chan<- dtypes.DeploymentID, leaseID mtypes.LeaseID, timeou
manifest/watchdog.go:31
↓ 2 callersFunctionnodeSelectorsFromResources
(res *crd.SchedulerResources)
cluster/kube/builder/workload.go:510
↓ 2 callersMethodobserveIPState
(ctx context.Context)
operator/ip/operator.go:765
↓ 2 callersFunctionparseGPU
(resource *rtypes.GPU)
bidengine/shellscript.go:63
↓ 2 callersMethodparseGPUInfo
(ctx context.Context, info RegistryGPUVendors)
operator/inventory/node-discovery.go:1169
↓ 2 callersMethodparseIBInfo
parseIBInfo asks the per-node psutil pod for the host's InfiniBand / RoCE inventory. A failure is logged but never fatal — the result is a zero-value
operator/inventory/node-discovery.go:763
↓ 2 callersFunctionplacementRequirements
placementRequirements extracts the on-chain placement requirements from the concrete ResourceGroup shapes the bid path produces. The committed copy mu
cluster/inventory.go:350
↓ 2 callersFunctionpodKey
(pod *corev1.Pod)
operator/inventory/node-discovery.go:394
↓ 2 callersMethodports
()
cluster/kube/builder/service.go:131
↓ 2 callersFunctionprepareHostnamesImpl
(store map[string]hostnameID, hostnames []string, hID hostnameID, errCh chan<- error)
cluster/hostname.go:93
↓ 2 callersMethodprobe
()
sidecar/attestation/tee/nvidia_gpu.go:53
↓ 2 callersFunctionproviderAttrSize
(entries atypes.AuditedProviders)
bidengine/provider_attributes.go:241
↓ 2 callersMethodpushCurrAttributes
()
bidengine/provider_attributes.go:189
↓ 2 callersFunctionqueryApp
(t *testing.T, appURL string, limit int)
integration/test_helpers.go:112
↓ 2 callersFunctionread_from_datafile
(fin)
script/provider_migrate_to_hostname_operator.py:111
↓ 2 callersFunctionreleaseHostnamesImpl
(store map[string]hostnameID, hID hostnameID)
cluster/hostname.go:232
↓ 2 callersFunctionremove
(slice []T, s int)
operator/inventory/util.go:76
↓ 2 callersMethodremoveHostnameFromDeployment
(ctx context.Context, hostname string, leaseID mtypes.LeaseID, allowMissing bool)
operator/hostname/operator.go:682
↓ 2 callersFunctionrequestDeploymentID
(req *http.Request)
gateway/rest/middleware.go:67
↓ 2 callersFunctionrequestLogFollow
(req *http.Request)
gateway/rest/middleware.go:39
↓ 2 callersFunctionrequestServices
(req *http.Request)
gateway/rest/middleware.go:51
← previousnext →401–500 of 2,942, ranked by callers