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
↓ 1 callersMethodshutdown
()
cluster/monitor.go:65
↓ 1 callersFunctionsidecarResources
(isGPU bool)
cluster/kube/webhook/sidecar.go:174
↓ 1 callersMethodstartMonitor
()
cluster/manager.go:255
↓ 1 callersMethodstartTeardown
()
cluster/manager.go:312
↓ 1 callersMethodstartWithdraw
(ctx context.Context, lid mtypes.LeaseID)
balance_checker.go:202
↓ 1 callersMethodstatusRun
()
service.go:278
↓ 1 callersFunctionstrPtr
strPtr returns a pointer to the given string. TODO: go 1.26 makes this helper unnecessary.
cluster/kube/gateway/nginx_gateway.go:163
↓ 1 callersFunctionstrToBidPriceScale
(val string)
cmd/provider-services/cmd/run.go:404
↓ 1 callersFunctionsubAllocatedResource
(log logr.Logger, node *v1.Node, pod *corev1.Pod, resourceName string, allocated *resource.Quantity, val resou
operator/inventory/node-discovery.go:960
↓ 1 callersMethodsubMilliNLZ
type clusterStorage map[string]*resourcePair func (cs clusterStorage) dup() clusterStorage { res := make(clusterStorage) for class, resources := ra
cluster/kube/resourcetypes.go:51
↓ 1 callersMethodsubmitPriceEntry
(ctx context.Context)
integration/e2e_test.go:592
↓ 1 callersMethodsubscriber
(in <-chan inventoryV1.Cluster, out chan<- ctypes.Inventory)
cluster/types/v1beta3/clients/inventory/inventory.go:232
↓ 1 callersMethodsubscriber
(in <-chan inventoryV1.Cluster, out chan<- ctypes.Inventory)
cluster/kube/operators/clients/inventory/client.go:210
↓ 1 callersMethodteardown
()
cluster/manager.go:125
↓ 1 callersMethodteardownLease
(lid mtypes.LeaseID)
cluster/service.go:461
↓ 1 callersFunctionteeTypeFromClusterParams
teeTypeFromClusterParams extracts the TEE type from stored cluster params (used for existing reservations loaded at startup).
cluster/inventory.go:509
↓ 1 callersFunctionteeTypeFromResourceGroup
teeTypeFromResourceGroup extracts the TEE type from the placement requirement attributes of a resource group (e.g. tee/type=cpu-gpu).
cluster/inventory.go:482
↓ 1 callersMethodtimerFunc
(ctx context.Context, d time.Duration, lid mtypes.LeaseID, scheduledWithdraw bool, ch chan<- leaseCheckRespons
balance_checker.go:343
↓ 1 callersMethodtoAkash
()
pkg/apis/akash.network/v2beta2/manifest.go:415
↓ 1 callersFunctiontraverse_ingresses
()
script/provider_migrate_to_hostname_operator.py:134
↓ 1 callersMethodtrimCache
()
bidengine/provider_attributes.go:249
↓ 1 callersMethodtryAdjust
tryAdjust cluster inventory It returns two boolean values. First indicates if node-wide resources satisfy (true) requirements Seconds indicates if clu
cluster/types/v1beta3/clients/inventory/inventory.go:286
↓ 1 callersMethodtryAdjust
tryAdjust cluster inventory It returns two boolean values. First indicates if node-wide resources satisfy (true) requirements Seconds indicates if clu
cluster/kube/operators/clients/inventory/inventory.go:114
↓ 1 callersFunctiontryAdjustCPU
(rp *inventoryV1.ResourcePair, res *rtypes.CPU)
cluster/types/v1beta3/clients/inventory/inventory.go:383
↓ 1 callersFunctiontryAdjustCPU
(rp *inventoryV1.ResourcePair, res *rtypes.CPU)
cluster/kube/operators/clients/inventory/inventory.go:258
↓ 1 callersFunctiontryAdjustEphemeralStorage
(rp *inventoryV1.ResourcePair, res *rtypes.Storage)
cluster/kube/operators/clients/inventory/inventory.go:408
↓ 1 callersFunctiontryAdjustGPU
(rp *inventoryV1.GPU, res *rtypes.GPU, sparams *crd.SchedulerParams, teeType ctypes.TEEType, teePlatform ctype
cluster/types/v1beta3/clients/inventory/inventory.go:387
↓ 1 callersFunctiontryAdjustGPU
(rp *inventoryV1.GPU, res *rtypes.GPU, sparams *crd.SchedulerParams, teeType ctypes.TEEType, teePlatform ctype
cluster/kube/operators/clients/inventory/inventory.go:262
↓ 1 callersMethodtryFetchAttributes
(ctx context.Context)
bidengine/provider_attributes.go:408
↓ 1 callersMethodtryRecoverRegistration
(privateKey crypto.PrivateKey)
tools/certissuer/storage.go:599
↓ 1 callersMethodupdate
(deployment ctypes.IDeployment)
cluster/manager.go:116
↓ 1 callersMethodupdateCounts
(parentCtx context.Context)
operator/ip/operator.go:198
↓ 1 callersMethodupdateDeploymentManagerGauge
()
cluster/service.go:300
↓ 1 callersMethodupdateGauges
()
manifest/service.go:127
↓ 1 callersMethodupdateInventoryMetrics
(metrics inventoryV1.Metrics)
cluster/inventory.go:365
↓ 1 callersMethodupdateOrderManagerGauge
()
bidengine/service.go:182
↓ 1 callersFunctionupdateReservationMetrics
(reservations []*reservation)
cluster/inventory.go:387
↓ 1 callersMethodvalidate
()
cluster/kube/builder/builder.go:217
↓ 1 callersMethodvalidateRequests
()
manifest/manager.go:373
↓ 1 callersMethodverifyHTTPRouteAnnotations
verifyHTTPRouteAnnotations checks that the HTTPRoute has correct annotations for HTTP options. Expected annotations based on deployment-v2-gateway-api
integration/gateway_api_test.go:413
↓ 1 callersMethodverifyHTTPRouteDeleted
verifyHTTPRouteDeleted checks that an HTTPRoute no longer exists. Only a NotFound error indicates successful deletion; other errors (auth, network, et
integration/gateway_api_test.go:328
↓ 1 callersMethodverifyHTTPRouteLabels
verifyHTTPRouteLabels checks that the HTTPRoute has correct Akash labels
integration/gateway_api_test.go:360
↓ 1 callersMethodverifyHTTPRouteParentRef
verifyHTTPRouteParentRef checks that the HTTPRoute references the correct Gateway
integration/gateway_api_test.go:379
↓ 1 callersMethodvolumes
()
cluster/kube/builder/workload.go:283
↓ 1 callersFunctionwaitForTCPSocket
(ctx context.Context, dialer net.Dialer, host string, t *testing.T)
integration/e2e_test.go:536
↓ 1 callersMethodwaitUntilClear
(ctx context.Context)
operator/ip/types.go:59
↓ 1 callersFunctionwithGatewayApi
(ctx context.Context)
operator/hostname/cmd.go:126
↓ 1 callersFunctionwithNamespace
(ctx context.Context, t testing.TB, fn func(*rest.Config, string))
pkg/apis/akash.network/v2beta2/k8s_integration_test.go:65
↓ 1 callersFunctionwithWriterRollback
(val *writerRollback)
tools/certissuer/storage.go:118
↓ 1 callersMethodworkloadServiceType
()
cluster/kube/builder/service.go:47
↓ 1 callersMethodwritePFXFile
(domain string, certRes *certificate.Resource, opts ...WriteOption)
tools/certissuer/storage.go:503
↓ 1 callersFunctionwsEventWriter
(ctx context.Context, ws *websocket.Conn, cfg wsStreamConfig)
gateway/rest/router.go:805
↓ 1 callersFunctionwsLogWriter
(ctx context.Context, ws *websocket.Conn, cfg wsStreamConfig)
gateway/rest/router.go:710
MethodAccountLoad
(crypto.PrivateKey)
tools/certissuer/storage.go:85
MethodAccountSetup
()
tools/certissuer/storage.go:237
MethodAddAccount
(_ context.Context, address sdk.Address, pubkey cryptotypes.PubKey)
tools/pconfig/memory/memory.go:53
MethodAddAccount
(_ context.Context, acc sdk.Address, pubkey cryptotypes.PubKey)
tools/pconfig/bbolt/bbolt.go:96
MethodAddAccountCertificate
(_ context.Context, address sdk.Address, cert *x509.Certificate, pubkey crypto.PublicKey)
tools/pconfig/memory/memory.go:148
MethodAddAccountCertificate
(_ context.Context, acc sdk.Address, cert *x509.Certificate, pubkey crypto.PublicKey)
tools/pconfig/bbolt/bbolt.go:198
MethodAddAccountCertificate
(ctx context.Context, addr sdk.Address, cert *x509.Certificate, pubkey crypto.PublicKey)
gateway/rest/integration_test.go:498
MethodAddError
(k mtypes.LeaseID, failure error, extra ...string)
operator/common/ignore_list.go:103
FunctionAddKubeConfigPathFlag
(cmd *cobra.Command)
cmd/provider-services/cmd/flags/kube_config.go:12
MethodAddPreparedEndpoint
(path string, prepare PrepareFn)
operator/common/operator_server.go:68
FunctionAddServiceEndpointFlag
(cmd *cobra.Command, serviceName string)
cmd/provider-services/cmd/flags/service_endpoint_flag.go:20
MethodAdjust
(ctypes.ReservationGroup, ...ctypes.InventoryOption)
cluster/inventory_test.go:44
MethodAdjust
(reservation ctypes.ReservationGroup, opts ...ctypes.InventoryOption)
cluster/types/v1beta3/clients/inventory/inventory.go:474
MethodAdjust
(reservation ctypes.ReservationGroup, opts ...ctypes.InventoryOption)
cluster/kube/operators/clients/inventory/inventory.go:417
MethodAkash
()
pkg/client/informers/externalversions/factory.go:257
MethodAkashV2beta2
AkashV2beta2 retrieves the AkashV2beta2Client
pkg/client/clientset/versioned/clientset.go:43
MethodAkashV2beta2
AkashV2beta2 retrieves the AkashV2beta2Client
pkg/client/clientset/versioned/fake/clientset_generated.go:129
MethodAllHostnames
AllHostnames provides a mock function for the type ReadClient
mocks/cluster/ReadClient_mock.go:47
MethodAllHostnames
AllHostnames is a helper method to define mock.On call - context1 context.Context
mocks/cluster/ReadClient_mock.go:81
MethodAllHostnames
AllHostnames provides a mock function for the type Client
mocks/cluster/Client_mock.go:51
MethodAllHostnames
AllHostnames is a helper method to define mock.On call - context1 context.Context
mocks/cluster/Client_mock.go:85
MethodAllHostnames
(context.Context)
cluster/client.go:311
MethodAllHostnames
(ctx context.Context)
cluster/kube/client_hostname_connections.go:283
MethodAllLessThenOrEqual
AllLessThenOrEqual check all storage classes fit into max limits note better have dedicated limits for each class
bidengine/pricing.go:71
MethodAllocated
Allocated provides a mock function for the type Reservation
mocks/cluster/types/Reservation_mock.go:41
MethodAllocated
Allocated is a helper method to define mock.On call
mocks/cluster/types/Reservation_mock.go:63
MethodAllocated
()
cluster/reservation.go:56
MethodAllocated
()
cluster/kube/operators/clients/inventory/client_test.go:80
MethodAny
()
cluster/kube/builder/service.go:109
MethodApply
(ctx context.Context, inventory *applyconfigurationakashnetworkv2beta2.InventoryApplyConfiguration, opts v1.Ap
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventory.go:51
MethodApply
(ctx context.Context, providerHost *applyconfigurationakashnetworkv2beta2.ProviderHostApplyConfiguration, opts
pkg/client/clientset/versioned/typed/akash.network/v2beta2/providerhost.go:49
MethodApply
(ctx context.Context, manifest *applyconfigurationakashnetworkv2beta2.ManifestApplyConfiguration, opts v1.Appl
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:49
MethodApply
(ctx context.Context, providerLeasedIP *applyconfigurationakashnetworkv2beta2.ProviderLeasedIPApplyConfigurati
pkg/client/clientset/versioned/typed/akash.network/v2beta2/providerleasedip.go:49
MethodApply
(ctx context.Context, inventoryRequest *applyconfigurationakashnetworkv2beta2.InventoryRequestApplyConfigurati
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventoryrequest.go:51
MethodApplyStatus
Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventory.go:53
MethodApplyStatus
Add a +genclient:noStatus comment above the type to avoid generating ApplyStatus().
pkg/client/clientset/versioned/typed/akash.network/v2beta2/inventoryrequest.go:53
MethodArchiveDomain
(domain string)
tools/certissuer/storage.go:311
MethodAttestationQuote
(ctx context.Context, lID v1.LeaseID, service string, podIndex uint, requestBody []byte)
mocks/cluster/Client_mock.go:1712
MethodAttestationQuote
(ctx context.Context, req *leasev1.AttestationQuoteRequest)
gateway/grpc/lease_server.go:24
MethodAttestationQuote
(_ context.Context, _ mtypes.LeaseID, _ string, _ uint, _ []byte)
cluster/client.go:327
MethodAttestationQuote
AttestationQuote forwards an attestation quote request to the sidecar running inside a confidential compute pod. It uses the K8s API server's pod prox
cluster/kube/client_attestation.go:35
MethodAvailable
()
sidecar/attestation/tee/mock.go:43
MethodAvailable
Available returns true if the guest rootfs is accessible and at least one GPU has Confidential Computing mode enabled.
sidecar/attestation/tee/nvidia_gpu.go:43
MethodAvailable
()
sidecar/attestation/tee/composite.go:30
MethodBidEngine
()
tools/pconfig/memory/memory.go:49
MethodBidEngine
()
tools/pconfig/bbolt/bbolt.go:80
MethodBidScreening
(ctx context.Context, request *providerv1.BidScreeningRequest)
gateway/grpc/server.go:43
← previousnext →1,101–1,200 of 2,942, ranked by callers