Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/akash-network/provider
/ functions
Functions
2,942 in github.com/akash-network/provider
⨍
Functions
2,942
◇
Types & classes
699
↓ 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
Deployments
(context.Context)
cluster/client.go:67
↓ 9 callers
Method
Equals
(other hostnameID)
cluster/hostname.go:28
↓ 9 callers
Method
IsObjectRevisionLatest
(map[string]string)
cluster/kube/builder/builder.go:257
↓ 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
NewDefaultSettings
()
cluster/kube/builder/settings.go:101
↓ 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:376
↓ 9 callers
Function
updateAkashLabels
(currLabels, newLabels map[string]string)
cluster/kube/builder/builder.go:343
↓ 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
Deployment
Deployment returns the cluster.Deployment that the saved manifest represents.
pkg/apis/akash.network/v2beta2/manifest.go:205
↓ 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
GetName
GetName retrieves the value of the Name field in the declarative configuration.
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:224
↓ 8 callers
Method
GetResourceVersion
()
cluster/kube/builder/builder.go:123
↓ 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
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:834
↓ 8 callers
Function
requestLeaseID
(req *http.Request)
gateway/rest/middleware.go:35
↓ 8 callers
Function
stampinterconnect
stampinterconnect mutates the workload's per-service state to simulate the post-reservation pin: the SchedulerParams that tryAdjustInterconnect stamps
cluster/kube/builder/interconnect_test.go:26
↓ 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
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:200
↓ 7 callers
Function
hostnameIDFromLeaseID
(lID mtypes.LeaseID)
cluster/hostname.go:34
↓ 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:1011
↓ 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
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
Group
(t testing.TB)
testutil/manifest/v2beta2/manifest.go:27
↓ 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
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:390
↓ 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
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:290
↓ 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
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
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
NewDefaultConfig
()
cluster/config.go:32
↓ 5 callers
Function
NewOperatorHTTP
()
operator/common/operator_server.go:32
↓ 5 callers
Function
NewOperatorWaiter
(ctx context.Context, logger log.Logger, waitOn ...Waitable)
operator/waiter/waiter.go:36
↓ 5 callers
Method
PrepareHostnamesForTransfer
(ctx context.Context, hostnames []string, leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:290
↓ 5 callers
Method
RunMigrations
RunMigrations executes all pending migrations. Returns the number of migrations that were successfully executed. After successful execution, updates t
migrations/registry.go:140
↓ 5 callers
Method
Status
(context.Context)
cluster/service.go:85
↓ 5 callers
Method
StorageClassesForNode
(name string)
operator/inventory/config.go:350
↓ 5 callers
Function
WithGPU
()
cluster/types/v1beta3/types.go:116
↓ 5 callers
Function
addLeaseFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:90
↓ 5 callers
Method
applyEvent
(ctx context.Context, ev cip.ResourceEvent)
operator/ip/operator.go:234
↓ 5 callers
Method
available
()
cluster/kube/resourcetypes.go:92
↓ 5 callers
Method
get
()
operator/common/prepared_data.go:56
← previous
next →
101–200 of 2,942, ranked by callers