MCPcopy Create free account

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

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

⨍ Functions 2,943◇ Types & classes 699
↓ 198 callersMethodError
()
utils/httperror/httperror.go:33
↓ 144 callersMethodGet
Get retrieves the Inventory from the index for a given name. Objects returned here must be treated as read-only.
pkg/client/listers/akash.network/v2beta2/inventory.go:36
↓ 138 callersMethodDone
()
cluster/service.go:96
↓ 136 callersMethodRun
Run executes the migration. This method must be idempotent. If the migration has already been applied, this should be a no-op. The context provides ac
migrations/migrations.go:29
↓ 118 callersMethodString
()
operator/waiter/waiter.go:16
↓ 97 callersMethodReturn
(execResult v1beta3.ExecResult, err error)
mocks/cluster/Client_mock.go:562
↓ 92 callersFunctionrun
()
cmd/provider-services/main.go:13
↓ 83 callersMethodInfo
(int, string, ...interface{})
operator/inventory/node-discovery_test.go:35
↓ 72 callersMethodIs
Is checks whether rc is a known runtime class matching all the given filters. With no options it matches any known runtime class.
cluster/types/v1beta3/types.go:137
↓ 57 callersMethodLeaseID
()
cluster/types/v1beta3/deployment.go:10
↓ 57 callersMethodLeaseID
()
cluster/kube/builder/builder.go:118
↓ 53 callersMethodSet
([]byte)
operator/common/prepared_data.go:15
↓ 49 callersMethodClose
()
cluster/service.go:94
↓ 48 callersFunctionLidNS
LidNS generates a unique sha256 sum for identifying a provider's object name.
cluster/kube/builder/builder.go:329
↓ 47 callersMethodString
()
cluster/types/v1beta3/clients/ip/ip.go:73
↓ 42 callersMethodList
List lists all Manifests in the indexer. Objects returned here must be treated as read-only.
pkg/client/listers/akash.network/v2beta2/manifest.go:33
↓ 40 callersMethodLen
()
cluster/kube/client_exec.go:39
↓ 34 callersMethodLen
()
tools/certissuer/lego.go:57
↓ 33 callersMethodAkashV2beta2
()
pkg/client/clientset/versioned/clientset.go:33
↓ 31 callersMethodError
()
gateway/rest/router_test.go:70
↓ 29 callersMethodCreate
()
cluster/kube/builder/role.go:10
↓ 26 callersMethodName
()
cluster/kube/builder/manifest.go:13
↓ 26 callersMethodStop
()
cluster/kube/operators/clients/metallb/client.go:61
↓ 26 callersMethodUpdate
(obj *rbacv1.Role)
cluster/kube/builder/role.go:11
↓ 24 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
pkg/apis/akash.network/v2beta2/zz_generated.deepcopy.go:1066
↓ 24 callersMethodDup
()
cluster/types/v1beta3/types.go:206
↓ 23 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
pkg/apis/akash.network/v2beta2/zz_generated.deepcopy.go:1060
↓ 22 callersMethodAdjust
(ReservationGroup, ...InventoryOption)
cluster/types/v1beta3/types.go:203
↓ 22 callersMethodShutdown
()
cluster/types/v1beta3/types.go:210
↓ 21 callersMethodCalculatePrice
(ctx context.Context, req Request)
bidengine/pricing.go:34
↓ 21 callersMethodLog
()
session/session.go:12
↓ 21 callersMethodReturn
(serviceLogs []*v1beta3.ServiceLog, err error)
mocks/cluster/ReadClient_mock.go:534
↓ 20 callersMethodError
()
operator/ip/types/error_response.go:34
↓ 20 callersMethodOrderID
()
cluster/types/v1beta3/reservation.go:18
↓ 19 callersMethodDone
()
cluster/types/v1beta3/types.go:211
↓ 19 callersMethodQuery
(ctx context.Context)
operator/inventory/types.go:167
↓ 19 callersMethodReturn
(valCh <-chan struct{})
mocks/cluster/Service_mock.go:127
↓ 19 callersFunctionrunRouterTest
TODO - add some tests in here to make sure the IP operator calls work as intended
gateway/rest/router_test.go:88
↓ 18 callersFunctionLogrFromCtx
(ctx context.Context)
tools/fromctx/context.go:52
↓ 17 callersFunctionAppendLeaseLabels
(lid mtypes.LeaseID, labels map[string]string)
cluster/kube/builder/builder.go:333
↓ 17 callersMethodError
(err error, msg string, keysAndValues ...interface{})
operator/inventory/node-discovery_test.go:37
↓ 17 callersFunctionMakeShellScriptPricing
(path string, processLimit uint, runtimeLimit time.Duration)
bidengine/shellscript.go:28
↓ 17 callersFunctionNewStateManager
NewStateManager creates a new StateManager with the given state file path.
migrations/state.go:24
↓ 17 callersFunctiondefaultGroupSpec
()
bidengine/pricing_test.go:93
↓ 17 callersMethodwaitForBlocksCommitted
(height int)
integration/e2e_test.go:772
↓ 16 callersMethodManifest
()
service.go:40
↓ 16 callersMethodManifestGroup
()
cluster/kube/builder/builder.go:119
↓ 16 callersMethodMetrics
()
cluster/types/v1beta3/types.go:204
↓ 16 callersMethodName
Name returns a unique identifier for this migration. This identifier is used to track whether the migration has been applied.
migrations/migrations.go:13
↓ 16 callersMethodResultChan
()
cluster/types/v1beta3/types.go:212
↓ 16 callersMethodWithDSeq
WithDSeq sets the DSeq 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/leaseid.go:48
↓ 16 callersFunctionmakeOrderForTest
( t *testing.T, checkForExistingBid bool, bidState mvbeta.Bid_State, pricing BidPricingStrategy, callerCo
bidengine/order_test.go:167
↓ 15 callersMethodNS
()
cluster/kube/builder/builder.go:254
↓ 15 callersFunctionRegister
Register adds a migration to the registry. This should be called from init() functions in migration files. Panics if an error occurs.
migrations/registry.go:19
↓ 15 callersMethodWithName
(string)
operator/inventory/node-discovery_test.go:57
↓ 15 callersMethodensureObjectMetaApplyConfigurationExists
()
pkg/client/applyconfiguration/akash.network/v2beta2/inventory.go:199
↓ 15 callersMethodensureObjectMetaApplyConfigurationExists
()
pkg/client/applyconfiguration/akash.network/v2beta2/providerhost.go:199
↓ 15 callersMethodensureObjectMetaApplyConfigurationExists
()
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:199
↓ 15 callersMethodensureObjectMetaApplyConfigurationExists
()
pkg/client/applyconfiguration/akash.network/v2beta2/providerleasedip.go:199
↓ 15 callersMethodensureObjectMetaApplyConfigurationExists
()
pkg/client/applyconfiguration/akash.network/v2beta2/inventoryrequest.go:199
↓ 14 callersMethodFromCRD
FromCRD returns LeaseID from LeaseID details
pkg/apis/akash.network/v2beta2/types.go:59
↓ 14 callersFunctionclientForTest
(t *testing.T, kobjs []runtime.Object, aobjs []runtime.Object)
cluster/kube/client_test.go:30
↓ 14 callersMethodlabels
()
cluster/kube/builder/role.go:40
↓ 13 callersMethodGetLeaseID
()
cluster/types/v1beta3/clients/ip/ip.go:34
↓ 13 callersFunctionNewClient
(ctx context.Context)
cluster/kube/operators/clients/inventory/client.go:62
↓ 13 callersMethodProvider
()
session/session.go:14
↓ 13 callersMethodResultChan
ResultChan returns a chan which will receive all the events. If an error occurs or Stop() is called, the implementation will close this channel and re
cluster/types/v1beta3/clients/inventory/inventory.go:36
↓ 13 callersMethodWait
(wait <-chan struct{})
cluster/hostname.go:63
↓ 13 callersMethodcontainer
()
cluster/kube/builder/workload.go:112
↓ 13 callersFunctionmakeInventoryScaffold
(t *testing.T)
cluster/kube/operators/clients/inventory/client_test.go:202
↓ 13 callersFunctionwaitForInventory
(t *testing.T, ch <-chan ctypes.Inventory)
cluster/kube/operators/clients/inventory/client_test.go:286
↓ 13 callersFunctionwrapKubeCall
(label string, fn func() (T, error))
cluster/kube/client.go:77
↓ 12 callersMethodClient
()
session/session.go:13
↓ 12 callersMethodCopy
()
operator/inventory/config.go:153
↓ 12 callersMethodGetExternalPort
()
cluster/types/v1beta3/clients/ip/ip.go:36
↓ 12 callersMethodLoad
Load reads the migration state from the file. If the file doesn't exist, returns an empty state.
migrations/state.go:32
↓ 12 callersFunctionMustKubeClientFromCtx
(ctx context.Context)
tools/fromctx/context.go:140
↓ 12 callersFunctionMustPubSubFromCtx
(ctx context.Context)
tools/fromctx/context.go:232
↓ 12 callersMethodProviderLeasedIPs
ProviderLeasedIPs returns a ProviderLeasedIPInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:36
↓ 12 callersMethodReturn
()
mocks/cluster/kube/operators/clients/metallb/Client_mock.go:437
↓ 12 callersFunctionnewInventory
(clState inventoryV1.Cluster)
cluster/kube/operators/clients/inventory/inventory.go:27
↓ 12 callersMethodwaitForBlockchainEvent
(expEv interface{})
integration/e2e_test.go:787
↓ 11 callersFunctionNewWorkloadBuilder
( log log.Logger, settings Settings, deployment IClusterDeployment, mani *crd.Manifest, serviceIdx int, )
cluster/kube/builder/workload.go:73
↓ 11 callersMethodReturn
(providerStatus *rest.ProviderStatus, err error)
mocks/client/Client_mock.go:281
↓ 11 callersMethodReturn
(orderID v1.OrderID)
mocks/cluster/types/Reservation_mock.go:210
↓ 11 callersMethodServiceStatus
(context.Context, mtypes.LeaseID, string)
cluster/client.go:50
↓ 11 callersMethodWatch
(ctx context.Context, opts metav1.ListOptions)
operator/inventory/types.go:171
↓ 11 callersFunctionstrPtr
(s builder.RuntimeClass)
cluster/kube/webhook/sidecar_test.go:14
↓ 11 callersFunctiontestSetup
(t *testing.T, sdlFile string, serviceIdx int, lid mtypes.LeaseID)
cluster/kube/builder/deployment_test.go:19
↓ 10 callersFunctionAddProviderOperationFlagsToCmd
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:54
↓ 10 callersMethodDelete
(ctx context.Context, name string, opts v1.DeleteOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:43
↓ 10 callersMethodDeleteCollection
(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:44
↓ 10 callersFunctionMakeScalePricing
( cpuScale decimal.Decimal, memoryScale decimal.Decimal, storageScale Storage, endpointScale decimal.Decim
bidengine/pricing.go:89
↓ 10 callersMethodManifestGroup
()
cluster/types/v1beta3/interfaces.go:8
↓ 10 callersMethodManifests
Manifests returns an object that can list and get Manifests.
pkg/client/listers/akash.network/v2beta2/manifest.go:35
↓ 10 callersFunctionShouldInject
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 callersFunctionStatusCodeFrom
(err error)
utils/httperror/httperror.go:45
↓ 10 callersFunctionaddAuthFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:79
↓ 10 callersFunctionmatchInterconnectResourceName
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:797
↓ 10 callersFunctionmultipleReplicasGenNodes
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
next →1–100 of 2,943, ranked by callers