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
↓ 5 callersFunctioninitTestBackends
(t *testing.T)
tools/pconfig/bbolt_test.go:31
↓ 5 callersFunctioninterconnectParamsWith
interconnectParamsWith constructs scheduler params for a given fabric + HCA prefix list, so individual tests (e.g. RoCE GID injection) can override th
cluster/kube/builder/interconnect_test.go:39
↓ 5 callersMethodleaseExists
(ctx context.Context, lid mtypes.LeaseID)
cluster/kube/client.go:1219
↓ 5 callersFunctionmarkRPCServerError
(err error)
cmd/provider-services/cmd/helpers.go:228
↓ 5 callersFunctionnewestLease
(leases []mvbeta.QueryLeaseResponse)
integration/e2e_test.go:725
↓ 5 callersFunctionqueryAppWithRetries
nolint: unparam
integration/test_helpers.go:64
↓ 5 callersMethodreserve
(order mtypes.OrderID, resources dtypes.ResourceGroup)
cluster/inventory.go:195
↓ 5 callersFunctionrunIPOperator
(t *testing.T, run bool, aobj []runtime.Object, prerun, fn func(ctx context.Context, s ipOperatorScaffold))
operator/ip/operator_test.go:42
↓ 5 callersFunctiontakeCmdLock
()
testutil/provider/provider.go:25
↓ 5 callersFunctionwriteClusterError
(w http.ResponseWriter, err error)
gateway/rest/router.go:67
↓ 4 callersMethodAddAccountCertificate
(context.Context, sdk.Address, *x509.Certificate, crypto.PublicKey)
tools/pconfig/pconfig.go:34
↓ 4 callersMethodAddError
(id mtypes.LeaseID, err error, extra ...string)
operator/common/ignore_list.go:22
↓ 4 callersFunctionAkashClientFromCtx
(ctx context.Context)
tools/fromctx/context.go:149
↓ 4 callersFunctionApplyToContext
(ctx context.Context, config map[interface{}]interface{})
tools/fromctx/context.go:366
↓ 4 callersMethodBuildAnnotations
BuildAnnotations converts directive options to implementation-specific annotations. These annotations are applied to the HTTPRoute metadata and contro
cluster/kube/gateway/gateway.go:21
↓ 4 callersFunctionBuildSidecarPatch
BuildSidecarPatch generates a JSON Patch (RFC 6902) that injects the attestation sidecar container, required volumes, and volume mounts into the pod s
cluster/kube/webhook/sidecar.go:65
↓ 4 callersMethodClose
()
tools/pconfig/pconfig.go:47
↓ 4 callersMethodFlag
()
operator/common/prepared_data.go:14
↓ 4 callersMethodGetAccountCertificate
(context.Context, sdk.Address, *big.Int)
tools/pconfig/pconfig.go:27
↓ 4 callersFunctionGetAll
GetAll returns all registered migrations.
migrations/registry.go:40
↓ 4 callersMethodGetAttributes
()
bidengine/provider_attributes.go:56
↓ 4 callersMethodGetPort
()
cluster/types/v1beta3/clients/ip/ip.go:37
↓ 4 callersMethodGetProviderVersion
GetProviderVersion returns the provider version from the state.
migrations/state.go:120
↓ 4 callersMethodGetRouter
()
operator/common/operator_server.go:23
↓ 4 callersMethodIsCC
IsCC returns true if this TEE type represents a confidential compute workload.
cluster/types/v1beta3/types.go:84
↓ 4 callersMethodIsFlagged
(id mtypes.LeaseID)
operator/common/ignore_list.go:15
↓ 4 callersMethodLeaseID
()
cluster/types/v1beta3/deployment.go:25
↓ 4 callersFunctionMakeRandomRangePricing
()
bidengine/pricing.go:249
↓ 4 callersFunctionMustGatewayConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:357
↓ 4 callersFunctionMustStartupChFromCtx
(ctx context.Context)
tools/fromctx/context.go:71
↓ 4 callersFunctionNewClient
NewClient returns new Kubernetes Client instance with provided logger, host and ns. Returns error in-case of failure configPath may be the empty strin
cluster/kube/client.go:93
↓ 4 callersFunctionNewIgnoreList
(config IgnoreListConfig)
operator/common/ignore_list.go:39
↓ 4 callersFunctionNewIngressToHTTPRouteMigration
()
migrations/ingress_to_httproute.go:32
↓ 4 callersFunctionNewNginxGateway
NewNginxGateway creates a new NGINX Gateway Fabric provider.
cluster/kube/gateway/nginx_gateway.go:28
↓ 4 callersFunctionNewStorage
NewStorage Creates a new AccountsStorage.
tools/certissuer/storage.go:193
↓ 4 callersFunctionOpenKubeConfig
(cfgPath string, log log.Logger)
cluster/kube/clientcommon/open_kube_config.go:19
↓ 4 callersMethodPrepareAll
()
operator/common/operator_server.go:24
↓ 4 callersFunctionRecoverLeaseIDFromLabels
TODO - move to provider/cluster/util since this is generic
cluster/kube/clientcommon/recover_lease_id_from_labels.go:19
↓ 4 callersFunctionRuntimeClassForTEEType
RuntimeClassForTEEType maps a TEE type ("cpu", "cpu-gpu") to the corresponding Kata runtime class using the detected TEE platform ("tdx" or "snp").
cluster/kube/builder/workload.go:39
↓ 4 callersMethodSave
Save writes the migration state to the file. Creates the directory if it doesn't exist.
migrations/state.go:55
↓ 4 callersMethodShutdown
Shutdown gracefully shuts down the server.
cluster/kube/webhook/webhook.go:74
↓ 4 callersMethodStatusV1
(context.Context)
cluster/service.go:86
↓ 4 callersMethodValidate
()
cluster/kube/builder/builder.go:256
↓ 4 callersFunctionValidateSettings
(settings Settings)
cluster/kube/builder/settings.go:87
↓ 4 callersFunctionWithCC
()
cluster/types/v1beta3/types.go:112
↓ 4 callersMethodautomountServiceAccountToken
()
cluster/kube/builder/workload.go:673
↓ 4 callersFunctionfakeIBNode
fakeIBNode constructs a fixture mirroring `/sys/class/infiniband` on a real node: each device is a directory (symlink target in production) with `port
operator/inventory/infiniband_test.go:14
↓ 4 callersMethodgetStatusV1
(state *inventoryServiceState)
cluster/inventory.go:934
↓ 4 callersFunctioninterconnectParams
()
cluster/kube/builder/interconnect_test.go:32
↓ 4 callersFunctionmakeBaseCluster
()
cluster/kube/operators/clients/inventory/client_test.go:318
↓ 4 callersFunctionmakeInventoryScaffold
(t *testing.T, leaseQty uint)
cluster/inventory_test.go:308
↓ 4 callersFunctionnewDeploymentMonitor
(dm *deploymentManager)
cluster/monitor.go:48
↓ 4 callersFunctionnewPreparedResult
()
operator/common/prepared_data.go:28
↓ 4 callersMethodpodAnnotations
()
cluster/kube/builder/workload.go:358
↓ 4 callersFunctionqueryAppWithHostname
nolint: unparam
integration/test_helpers.go:118
↓ 4 callersMethodreplicas
()
cluster/kube/builder/workload.go:383
↓ 4 callersFunctionrequestOwner
(req *http.Request)
gateway/rest/middleware.go:59
↓ 4 callersFunctionrequestProvider
(req *http.Request)
gateway/rest/middleware.go:55
↓ 4 callersFunctionrun_kubectl
(*args, ojson = True, stdin_data = None)
script/provider_migrate_to_hostname_operator.py:48
↓ 4 callersMethodruntimeClass
()
cluster/kube/builder/workload.go:368
↓ 4 callersMethodserviceAccountName
()
cluster/kube/builder/workload.go:682
↓ 4 callersFunctiontestCertHelper
(t *testing.T, test *routerTest)
gateway/rest/router_test.go:168
↓ 4 callersMethodunreserve
(order mtypes.OrderID)
cluster/inventory.go:228
↓ 3 callersMethodArchiveDomain
(string)
tools/certissuer/storage.go:87
↓ 3 callersMethodAttestationQuote
AttestationQuote forwards an attestation quote request to the sidecar running inside a confidential compute pod. The requestBody (containing the tenan
cluster/client.go:106
↓ 3 callersFunctionBuildRole
BuildRole creates a new Role builder for the given workload. It uses the default PolicyRuleRegistry which includes mappings for all supported resource
cluster/kube/builder/role.go:24
↓ 3 callersMethodCanReserveHostnames
(hostnames []string, ownerAddr sdktypes.Address)
cluster/types/v1beta3/types.go:289
↓ 3 callersMethodCluster
()
service.go:41
↓ 3 callersMethodClusterParams
()
cluster/types/v1beta3/deployment.go:12
↓ 3 callersMethodClusterParams
()
cluster/kube/builder/builder.go:121
↓ 3 callersMethodCreateRequest
(ctx context.Context, method, path string, body io.Reader)
cluster/util/service_discovery_agent_types.go:20
↓ 3 callersMethodDeploy
(ctx context.Context, deployment ctypes.IDeployment)
cluster/client.go:65
↓ 3 callersFunctionDetectPort
(ctx context.Context, flags *flag.FlagSet, flag string, container, portName string)
operator/common/operator_flags.go:55
↓ 3 callersMethodDiscovery
()
pkg/client/clientset/versioned/clientset.go:32
↓ 3 callersFunctionErrGroupFromCtx
(ctx context.Context)
tools/fromctx/context.go:195
↓ 3 callersMethodForwardedPortStatus
(context.Context, mtypes.LeaseID)
cluster/client.go:47
↓ 3 callersMethodFromVersion
FromVersion returns the provider version this migration applies from. Migrations will only run when upgrading from a version < FromVersion. For fresh
migrations/migrations.go:22
↓ 3 callersMethodGenerateRules
GenerateRules generates all policy rules for the given permissions
cluster/kube/builder/permissions.go:85
↓ 3 callersMethodGetAccountPublicKey
(context.Context, sdk.Address)
tools/pconfig/pconfig.go:26
↓ 3 callersMethodGetAccountPublicKey
(context.Context, sdk.Address)
types/types.go:20
↓ 3 callersMethodGetAddress
()
gateway/rest/integration_test.go:52
↓ 3 callersMethodGetClient
(ctx context.Context, isHTTPS, secure bool)
cluster/util/service_discovery_agent_types.go:15
↓ 3 callersFunctionGetEndpointQuantityOfResourceGroup
(resources dtypes.ResourceGroup, kind rtypes.Endpoint_Kind)
cluster/util/endpoint_quantity.go:8
↓ 3 callersMethodGetIPAddressStatus
(context.Context, mtypes.OrderID)
cluster/types/v1beta3/clients/ip/ip.go:72
↓ 3 callersMethodGetIPAddressUsage
(ctx context.Context)
cluster/kube/operators/clients/metallb/client.go:53
↓ 3 callersMethodGetManifestGroup
(context.Context, mtypes.LeaseID)
cluster/client.go:53
↓ 3 callersMethodGetProtocol
()
cluster/types/v1beta3/clients/ip/ip.go:39
↓ 3 callersMethodHasAny
HasAny returns true if any permissions are defined
cluster/kube/builder/permissions.go:21
↓ 3 callersMethodHostnameService
()
cluster/service.go:97
↓ 3 callersMethodInformer
()
pkg/client/informers/externalversions/generic.go:32
↓ 3 callersMethodLess
(i, j int)
tools/certissuer/lego.go:61
↓ 3 callersFunctionMakeIPSharingKey
(lID mtypes.LeaseID, endpointName string)
cluster/util/ip_sharing_key.go:16
↓ 3 callersFunctionManifestSubmitErrorToHTTP
ManifestSubmitErrorToHTTP maps manifest submit errors to HttpError for gateway responses.
manifest/gateway.go:13
↓ 3 callersFunctionNewDeployment
(workload *Workload)
cluster/kube/builder/deployment.go:22
↓ 3 callersFunctionNewInfo
()
version/version.go:102
↓ 3 callersFunctionNewMemory
()
tools/pconfig/memory/memory.go:40
↓ 3 callersFunctionNewPolicyRuleRegistry
NewPolicyRuleRegistry creates a new registry with default resource mappings
cluster/kube/builder/permissions.go:67
↓ 3 callersMethodPrune
()
operator/common/ignore_list.go:23
↓ 3 callersMethodReturn
(providerStatus *rest.ProviderStatus, err error)
mocks/client/StatusClient_mock.go:94
↓ 3 callersMethodReturn
(err error)
mocks/manifest/Client_mock.go:161
← previousnext →201–300 of 2,942, ranked by callers