MCPcopy Create free account

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

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

↓ 10 callersFunctionresList
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 callersMethodAvailable
Available returns true if this TEE surface is accessible.
sidecar/attestation/tee/tee.go:38
↓ 9 callersMethodDeployments
(context.Context)
cluster/client.go:67
↓ 9 callersMethodEquals
(other hostnameID)
cluster/hostname.go:28
↓ 9 callersMethodIsObjectRevisionLatest
(map[string]string)
cluster/kube/builder/builder.go:257
↓ 9 callersFunctionKubeClientFromCtx
(ctx context.Context)
tools/fromctx/context.go:126
↓ 9 callersMethodLeaseStatus
(context.Context, mtypes.LeaseID)
cluster/client.go:46
↓ 9 callersFunctionNewDefaultSettings
()
cluster/kube/builder/settings.go:101
↓ 9 callersFunctionNewRegistry
NewRegistry creates a new migration registry.
migrations/registry.go:71
↓ 9 callersMethodProviderHosts
ProviderHosts returns an object that can list and get ProviderHosts.
pkg/client/listers/akash.network/v2beta2/providerhost.go:35
↓ 9 callersMethodSetCurrentVersion
SetCurrentVersion sets the current provider version. This should be called before GetPending or RunMigrations.
migrations/registry.go:79
↓ 9 callersMethodWithOwner
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 callersFunctioncreateMocks
()
gateway/rest/integration_test.go:455
↓ 9 callersFunctionmakeHostnameScaffold
(t *testing.T, blockedHostnames []string)
cluster/hostname_test.go:21
↓ 9 callersFunctionmultipleReplicasGenReservations
(cpuUnits, gpuUnits uint64, count uint32)
cluster/kube/operators/clients/inventory/client_test.go:831
↓ 9 callersFunctionqueryClientOrNil
(cl aclient.Client)
cmd/provider-services/cmd/helpers.go:377
↓ 9 callersFunctionsetupProviderClient
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet, cl aclient.QueryClient, paddr sdk.AccAddre
cmd/provider-services/cmd/helpers.go:267
↓ 9 callersFunctiontryAdjustInterconnect
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 callersFunctionupdateAkashLabels
(currLabels, newLabels map[string]string)
cluster/kube/builder/builder.go:343
↓ 9 callersFunctionwithServer
( ctx context.Context, t testing.TB, keys []cryptotypes.PrivKey, pclient provider.Client, mocks integrati
gateway/rest/integration_test.go:516
↓ 8 callersFunctionDefaultErrorHandler
(w http.ResponseWriter, _ *http.Request, err error)
gateway/rest/auth.go:32
↓ 8 callersMethodDeployment
Deployment returns the cluster.Deployment that the saved manifest represents.
pkg/apis/akash.network/v2beta2/manifest.go:205
↓ 8 callersMethodExec
(ctx context.Context, lID mtypes.LeaseID, service string, podIndex uint, cmd []string, stdin io.Read
cluster/client.go:68
↓ 8 callersMethodGetName
GetName retrieves the value of the Name field in the declarative configuration.
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:224
↓ 8 callersMethodGetResourceVersion
()
cluster/kube/builder/builder.go:123
↓ 8 callersMethodHostname
()
service.go:42
↓ 8 callersFunctionMustKubeConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:117
↓ 8 callersFunctionNew
New returns new session instance with provided details
session/session.go:20
↓ 8 callersMethodRESTClient
()
pkg/client/clientset/versioned/typed/akash.network/v2beta2/akash.network_client.go:30
↓ 8 callersMethodReserveHostnames
(ctx context.Context, hostnames []string, leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:287
↓ 8 callersMethodResources
()
cluster/types/v1beta3/reservation.go:9
↓ 8 callersMethodReturn
()
mocks/cluster/types/clients/ip/Client_mock.go:244
↓ 8 callersMethodSetProviderVersion
SetProviderVersion sets the provider version in the state.
migrations/state.go:109
↓ 8 callersFunctiondiscoverInfinibandAt
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 callersFunctioninterconnectResourcePair
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 callersFunctionkubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
cluster/kube/client.go:834
↓ 8 callersFunctionrequestLeaseID
(req *http.Request)
gateway/rest/middleware.go:35
↓ 8 callersFunctionstampinterconnect
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 callersFunctionwriteJSON
(log log.Logger, w http.ResponseWriter, obj interface{})
gateway/rest/router.go:885
↓ 7 callersMethodAny
()
cluster/kube/builder/service.go:18
↓ 7 callersFunctionBuildService
(workload *Workload, requireNodePort bool)
cluster/kube/builder/service.go:28
↓ 7 callersMethodGetAuditorAttributeSignatures
(auditor string)
bidengine/provider_attributes.go:55
↓ 7 callersMethodGetServiceName
()
cluster/types/v1beta3/clients/ip/ip.go:35
↓ 7 callersMethodMarkApplied
MarkApplied adds a migration name to the applied list and saves the state.
migrations/state.go:92
↓ 7 callersFunctionNewHttpError
(statusCode int, err error)
utils/httperror/httperror.go:41
↓ 7 callersFunctionNewNullWaiter
()
operator/waiter/waiter.go:25
↓ 7 callersFunctionPubSubFromCtx
(ctx context.Context)
tools/fromctx/context.go:218
↓ 7 callersMethodReturn
(leaseID v1.LeaseID)
mocks/cluster/types/IDeployment_mock.go:120
↓ 7 callersMethodReturn
(resourceGroup v1beta4.ResourceGroup)
mocks/cluster/types/ReservationGroup_mock.go:167
↓ 7 callersMethodReturn
(err error)
mocks/cluster/types/HostnameServiceClient_mock.go:203
↓ 7 callersMethodWaitForAll
(ctx context.Context)
operator/waiter/waiter.go:11
↓ 7 callersMethodWatch
(ctx context.Context, opts v1.ListOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:47
↓ 7 callersMethodWithKind
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 callersMethodcleanup
(get getFileName, domain string)
tools/certissuer/storage.go:102
↓ 7 callersFunctionenvMap
(env []corev1.EnvVar)
cluster/kube/builder/interconnect_test.go:200
↓ 7 callersFunctionhostnameIDFromLeaseID
(lID mtypes.LeaseID)
cluster/hostname.go:34
↓ 7 callersFunctioninterconnectGroupCluster
(n int)
cluster/kube/operators/clients/inventory/interconnect_group_adjust_test.go:61
↓ 7 callersFunctioninterconnectGroupReservation
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 callersFunctionnewInventoryService
( ctx context.Context, config Config, log log.Logger, sub pubsub.Subscriber, client Client, waiter waite
cluster/inventory.go:117
↓ 7 callersFunctionshowErrorToUser
(err error)
cmd/provider-services/cmd/run.go:1011
↓ 7 callersFunctionwithExecTestScaffold
(t *testing.T, changePod func(pod *corev1.Pod) error, test func(s *execScaffold))
cluster/kube/client_exec_test.go:85
↓ 6 callersMethodAddAccount
(context.Context, sdk.Address, cryptotypes.PubKey)
tools/pconfig/pconfig.go:32
↓ 6 callersMethodGetHostname
()
cluster/types/v1beta3/clients/hostname/hostname.go:49
↓ 6 callersMethodGetPending
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 callersMethodGroup
(t testing.TB)
testutil/manifest/v2beta2/manifest.go:27
↓ 6 callersMethodIsApplied
IsApplied checks if a migration with the given name has been applied.
migrations/state.go:76
↓ 6 callersFunctionKubeConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:103
↓ 6 callersFunctionMustErrGroupFromCtx
(ctx context.Context)
tools/fromctx/context.go:209
↓ 6 callersMethodRegister
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 callersMethodWait
()
operator/inventory/nodes.go:81
↓ 6 callersMethodWithProvider
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 callersMethodaffinity
()
cluster/kube/builder/workload.go:390
↓ 6 callersFunctiongpuInterconnectResource
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 callersFunctioninterconnectGroupResource
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 callersFunctionreleaseCmdLock
()
testutil/provider/provider.go:29
↓ 6 callersFunctionrequestClaims
(req *http.Request)
gateway/rest/middleware.go:63
↓ 6 callersFunctionrequireMsgType
(t *testing.T, res interface{})
bidengine/order_test.go:242
↓ 6 callersMethodselectorLabels
()
cluster/kube/builder/builder.go:290
↓ 6 callersFunctionsetupProviderAttributesTestScaffold
( t *testing.T, ttl time.Duration, clientFactory func(scaffold *providerAttributesTestScaffold) *clientmock
bidengine/provider_attributes_test.go:36
↓ 6 callersMethodstop
(t *testing.T)
bidengine/provider_attributes_test.go:65
↓ 6 callersFunctionwriteJSON
(w http.ResponseWriter, obj interface{})
operator/psutil.go:233
↓ 5 callersMethodAddPreparedEndpoint
(path string, prepare PrepareFn)
operator/common/operator_server.go:22
↓ 5 callersFunctionCmdSetContextValue
(cmd *cobra.Command, key, val interface{})
tools/fromctx/context.go:48
↓ 5 callersMethodDoRequest
(req *http.Request)
cluster/util/service_discovery_agent_types.go:21
↓ 5 callersMethodForModule
(string)
session/session.go:15
↓ 5 callersMethodGetSharingKey
()
cluster/types/v1beta3/clients/ip/ip.go:38
↓ 5 callersMethodInformerFor
(obj runtime.Object, newFunc NewInformerFunc)
pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go:36
↓ 5 callersMethodName
Name returns the TEE type identifier ("snp" or "tdx").
sidecar/attestation/tee/tee.go:35
↓ 5 callersFunctionNewDefaultConfig
()
cluster/config.go:32
↓ 5 callersFunctionNewOperatorHTTP
()
operator/common/operator_server.go:32
↓ 5 callersFunctionNewOperatorWaiter
(ctx context.Context, logger log.Logger, waitOn ...Waitable)
operator/waiter/waiter.go:36
↓ 5 callersMethodPrepareHostnamesForTransfer
(ctx context.Context, hostnames []string, leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:290
↓ 5 callersMethodRunMigrations
RunMigrations executes all pending migrations. Returns the number of migrations that were successfully executed. After successful execution, updates t
migrations/registry.go:140
↓ 5 callersMethodStatus
(context.Context)
cluster/service.go:85
↓ 5 callersMethodStorageClassesForNode
(name string)
operator/inventory/config.go:350
↓ 5 callersFunctionWithGPU
()
cluster/types/v1beta3/types.go:116
↓ 5 callersFunctionaddLeaseFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:90
↓ 5 callersMethodapplyEvent
(ctx context.Context, ev cip.ResourceEvent)
operator/ip/operator.go:234
↓ 5 callersMethodavailable
()
cluster/kube/resourcetypes.go:92
↓ 5 callersMethodget
()
operator/common/prepared_data.go:56
← previousnext →101–200 of 2,942, ranked by callers