Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/akash-network/provider
/ functions
Functions
2,992 in github.com/akash-network/provider
⨍
Functions
2,992
◇
Types & classes
704
↓ 10 callers
Function
ShouldInject
ShouldInject returns true if the pod should have the attestation sidecar injected. Trigger conditions: - Pod has the akash.network managed label - Pod
cluster/kube/webhook/sidecar.go:26
↓ 10 callers
Function
StatusCodeFrom
(err error)
utils/httperror/httperror.go:45
↓ 10 callers
Function
addAuthFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:79
↓ 10 callers
Function
matchInterconnectResourceName
matchInterconnectResourceName returns the first extended-resource name from `quantities` that matches any of `patterns`, or empty if no pattern matche
operator/inventory/node-discovery.go:821
↓ 10 callers
Function
multipleReplicasGenNodes
multipleReplicasGenNodes generates four nodes with following CPUs available node1: 68780 node2: 68800 node3: 119525 node4: 119495
cluster/kube/operators/clients/inventory/client_test.go:740
↓ 10 callers
Function
resList
AKT-493: matchInterconnectResourceName should keep working unchanged for providers running the Mellanox/NVIDIA k8s-rdma-shared-device-plugin (the rc4
operator/inventory/interconnect_resource_match_test.go:19
↓ 9 callers
Method
Available
Available returns true if this TEE surface is accessible.
sidecar/attestation/tee/tee.go:38
↓ 9 callers
Method
Equals
(other hostnameID)
cluster/hostname.go:28
↓ 9 callers
Method
GetResourceVersion
()
cluster/kube/builder/builder.go:133
↓ 9 callers
Method
IsObjectRevisionLatest
(map[string]string)
cluster/kube/builder/builder.go:267
↓ 9 callers
Function
KubeClientFromCtx
(ctx context.Context)
tools/fromctx/context.go:126
↓ 9 callers
Method
LeaseStatus
(context.Context, mtypes.LeaseID)
cluster/client.go:46
↓ 9 callers
Function
NewRegistry
NewRegistry creates a new migration registry.
migrations/registry.go:71
↓ 9 callers
Method
ProviderHosts
ProviderHosts returns an object that can list and get ProviderHosts.
pkg/client/listers/akash.network/v2beta2/providerhost.go:35
↓ 9 callers
Method
SetCurrentVersion
SetCurrentVersion sets the current provider version. This should be called before GetPending or RunMigrations.
migrations/registry.go:79
↓ 9 callers
Method
WithOwner
WithOwner sets the Owner field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining
pkg/client/applyconfiguration/akash.network/v2beta2/leaseid.go:40
↓ 9 callers
Function
createMocks
()
gateway/rest/integration_test.go:455
↓ 9 callers
Function
makeHostnameScaffold
(t *testing.T, blockedHostnames []string)
cluster/hostname_test.go:21
↓ 9 callers
Function
multipleReplicasGenReservations
(cpuUnits, gpuUnits uint64, count uint32)
cluster/kube/operators/clients/inventory/client_test.go:831
↓ 9 callers
Function
queryClientOrNil
(cl aclient.Client)
cmd/provider-services/cmd/helpers.go:377
↓ 9 callers
Function
setupProviderClient
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet, cl aclient.QueryClient, paddr sdk.AccAddre
cmd/provider-services/cmd/helpers.go:267
↓ 9 callers
Function
tryAdjustInterconnect
tryAdjustInterconnect pins one interconnect HCA per GPU unit (the locked 1:1 invariant) when the per-resource opt-in `gpu.attributes.interconnect=true
cluster/kube/operators/clients/inventory/inventory.go:396
↓ 9 callers
Function
updateAkashLabels
(currLabels, newLabels map[string]string)
cluster/kube/builder/builder.go:353
↓ 9 callers
Function
withServer
( ctx context.Context, t testing.TB, keys []cryptotypes.PrivKey, pclient provider.Client, mocks integrati
gateway/rest/integration_test.go:516
↓ 8 callers
Function
DefaultErrorHandler
(w http.ResponseWriter, _ *http.Request, err error)
gateway/rest/auth.go:32
↓ 8 callers
Method
Exec
(ctx context.Context, lID mtypes.LeaseID, service string, podIndex uint, cmd []string, stdin io.Read
cluster/client.go:68
↓ 8 callers
Method
Group
(t testing.TB)
testutil/manifest/v2beta2/manifest.go:27
↓ 8 callers
Method
Hostname
()
service.go:42
↓ 8 callers
Function
MustKubeConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:117
↓ 8 callers
Function
New
New returns new session instance with provided details
session/session.go:20
↓ 8 callers
Method
RESTClient
()
pkg/client/clientset/versioned/typed/akash.network/v2beta2/akash.network_client.go:30
↓ 8 callers
Method
ReserveHostnames
(ctx context.Context, hostnames []string, leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:287
↓ 8 callers
Method
Resources
()
cluster/types/v1beta3/reservation.go:9
↓ 8 callers
Method
Return
()
mocks/cluster/types/clients/ip/Client_mock.go:244
↓ 8 callers
Method
SetProviderVersion
SetProviderVersion sets the provider version in the state.
migrations/state.go:109
↓ 8 callers
Function
discoverInfinibandAt
discoverInfinibandAt is the testable seam: callers pass an explicit directory so the unit tests can populate a fixture without needing real `/host/sys
operator/inventory/infiniband.go:48
↓ 8 callers
Function
interconnectParamsWith
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
↓ 8 callers
Function
interconnectResourcePair
interconnectCapNode returns a NodeResources / NodeCapabilities pair the per-bid tests can stamp custom GPU interconnect capacity onto.
cluster/kube/operators/clients/inventory/interconnect_adjust_test.go:18
↓ 8 callers
Function
kubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
cluster/kube/client.go:916
↓ 8 callers
Method
podAnnotations
()
cluster/kube/builder/workload.go:358
↓ 8 callers
Function
requestLeaseID
(req *http.Request)
gateway/rest/middleware.go:35
↓ 8 callers
Function
writeJSON
(log log.Logger, w http.ResponseWriter, obj interface{})
gateway/rest/router.go:885
↓ 7 callers
Method
Any
()
cluster/kube/builder/service.go:18
↓ 7 callers
Function
BuildService
(workload *Workload, requireNodePort bool)
cluster/kube/builder/service.go:28
↓ 7 callers
Method
Deploy
(ctx context.Context, deployment ctypes.IDeployment)
cluster/client.go:65
↓ 7 callers
Method
GetAuditorAttributeSignatures
(auditor string)
bidengine/provider_attributes.go:55
↓ 7 callers
Method
GetServiceName
()
cluster/types/v1beta3/clients/ip/ip.go:35
↓ 7 callers
Method
MarkApplied
MarkApplied adds a migration name to the applied list and saves the state.
migrations/state.go:92
↓ 7 callers
Function
NewHttpError
(statusCode int, err error)
utils/httperror/httperror.go:41
↓ 7 callers
Function
NewNullWaiter
()
operator/waiter/waiter.go:25
↓ 7 callers
Function
PubSubFromCtx
(ctx context.Context)
tools/fromctx/context.go:218
↓ 7 callers
Method
Return
(leaseID v1.LeaseID)
mocks/cluster/types/IDeployment_mock.go:120
↓ 7 callers
Method
Return
(resourceGroup v1beta4.ResourceGroup)
mocks/cluster/types/ReservationGroup_mock.go:167
↓ 7 callers
Method
Return
(err error)
mocks/cluster/types/HostnameServiceClient_mock.go:203
↓ 7 callers
Method
WaitForAll
(ctx context.Context)
operator/waiter/waiter.go:11
↓ 7 callers
Method
Watch
(ctx context.Context, opts v1.ListOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:47
↓ 7 callers
Method
WithKind
WithKind sets the Kind field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "W
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:50
↓ 7 callers
Method
cleanup
(get getFileName, domain string)
tools/certissuer/storage.go:102
↓ 7 callers
Function
envMap
(env []corev1.EnvVar)
cluster/kube/builder/interconnect_test.go:253
↓ 7 callers
Function
hostnameIDFromLeaseID
(lID mtypes.LeaseID)
cluster/hostname.go:34
↓ 7 callers
Function
httpOptionsSnippet
httpOptionsSnippet renders the directive's http_options (plus the provider-wide proxyBufferSize) as nginx directives for the location context. Returns
cluster/kube/gateway/nginx_gateway.go:157
↓ 7 callers
Function
interconnectGroupCluster
(n int)
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:61
↓ 7 callers
Function
interconnectGroupReservation
interconnectGroupReservation wraps several ResourceUnits with the placement requirements an interconnect SDL declares (capabilities/gpu-interconnect=t
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:115
↓ 7 callers
Function
newInventoryService
( ctx context.Context, config Config, log log.Logger, sub pubsub.Subscriber, client Client, waiter waite
cluster/inventory.go:117
↓ 7 callers
Function
showErrorToUser
(err error)
cmd/provider-services/cmd/run.go:1017
↓ 7 callers
Function
withExecTestScaffold
(t *testing.T, changePod func(pod *corev1.Pod) error, test func(s *execScaffold))
cluster/kube/client_exec_test.go:85
↓ 6 callers
Method
AddAccount
(context.Context, sdk.Address, cryptotypes.PubKey)
tools/pconfig/pconfig.go:32
↓ 6 callers
Method
ClusterParams
()
cluster/kube/builder/builder.go:131
↓ 6 callers
Method
GetHostname
()
cluster/types/v1beta3/clients/hostname/hostname.go:49
↓ 6 callers
Method
GetPending
GetPending returns all migrations that have not been applied yet. Migrations are only included if: 1. They haven't been applied (not in state file) 2.
migrations/registry.go:88
↓ 6 callers
Method
IsApplied
IsApplied checks if a migration with the given name has been applied.
migrations/state.go:76
↓ 6 callers
Function
KubeConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:103
↓ 6 callers
Function
MustErrGroupFromCtx
(ctx context.Context)
tools/fromctx/context.go:209
↓ 6 callers
Method
Register
Register adds a Gateway provider factory to the registry. The factory function takes a logger and returns a GatewayProvider instance.
cluster/kube/gateway/registry.go:28
↓ 6 callers
Method
SetResourceVersion
(string)
cluster/kube/builder/builder.go:132
↓ 6 callers
Method
Wait
()
operator/inventory/nodes.go:81
↓ 6 callers
Method
WithProvider
WithProvider sets the Provider field in the declarative configuration to the given value and returns the receiver, so that objects can be built by cha
pkg/client/applyconfiguration/akash.network/v2beta2/leaseid.go:72
↓ 6 callers
Method
affinity
()
cluster/kube/builder/workload.go:407
↓ 6 callers
Function
gpuInterconnectResource
gpuInterconnectResource builds the per-resource shape that ResourceRequiresInterconnect inspects — units=N with an `interconnect/group` attribute. The
cluster/kube/operators/clients/inventory/interconnect_adjust_test.go:26
↓ 6 callers
Function
interconnectGroupResource
interconnectGroupResource builds a full-node ResourceUnit (8 GPUs) for an interconnect service. group is the on-chain `interconnect/group` attribute v
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:74
↓ 6 callers
Function
nadFakeClient
nadFakeClient builds a client over a fake dynamic clientset holding the given NADs. Objects are created through the fake (not seeded via the tracker)
cluster/kube/roce_networks_test.go:72
↓ 6 callers
Function
releaseCmdLock
()
testutil/provider/provider.go:29
↓ 6 callers
Function
requestClaims
(req *http.Request)
gateway/rest/middleware.go:63
↓ 6 callers
Function
requireMsgType
(t *testing.T, res interface{})
bidengine/order_test.go:242
↓ 6 callers
Method
selectorLabels
()
cluster/kube/builder/builder.go:300
↓ 6 callers
Function
setupProviderAttributesTestScaffold
( t *testing.T, ttl time.Duration, clientFactory func(scaffold *providerAttributesTestScaffold) *clientmock
bidengine/provider_attributes_test.go:36
↓ 6 callers
Method
stop
(t *testing.T)
bidengine/provider_attributes_test.go:65
↓ 6 callers
Function
writeJSON
(w http.ResponseWriter, obj interface{})
operator/psutil.go:233
↓ 5 callers
Method
AddPreparedEndpoint
(path string, prepare PrepareFn)
operator/common/operator_server.go:22
↓ 5 callers
Function
CmdSetContextValue
(cmd *cobra.Command, key, val interface{})
tools/fromctx/context.go:48
↓ 5 callers
Function
CreateOrUpdateHTTPRoute
CreateOrUpdateHTTPRoute creates or updates an HTTPRoute for a hostname directive. It uses the provided Provider to build annotations and the HTTPRoute
cluster/kube/gateway/httproute.go:66
↓ 5 callers
Method
DoRequest
(req *http.Request)
cluster/util/service_discovery_agent_types.go:21
↓ 5 callers
Method
ForModule
(string)
session/session.go:15
↓ 5 callers
Method
GetNamespace
GetNamespace retrieves the value of the Namespace field in the declarative configuration.
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:230
↓ 5 callers
Method
GetSharingKey
()
cluster/types/v1beta3/clients/ip/ip.go:38
↓ 5 callers
Method
InformerFor
(obj runtime.Object, newFunc NewInformerFunc)
pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go:36
↓ 5 callers
Method
Name
Name returns the TEE type identifier ("snp" or "tdx").
sidecar/attestation/tee/tee.go:35
↓ 5 callers
Function
NewClient
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:103
↓ 5 callers
Function
NewDefaultConfig
()
cluster/config.go:32
↓ 5 callers
Function
NewOperatorHTTP
()
operator/common/operator_server.go:32
← previous
next →
101–200 of 2,992, ranked by callers