MCPcopy Create free account

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

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

⨍ Functions 2,680◇ Types & classes 661
↓ 190 callersMethodError
()
utils/httperror/httperror.go:33
↓ 142 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
↓ 135 callersMethodDone
()
cluster/service.go:96
↓ 127 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
↓ 110 callersMethodString
()
operator/waiter/waiter.go:16
↓ 96 callersMethodReturn
(execResult v1beta3.ExecResult, err error)
mocks/cluster/Client_mock.go:562
↓ 92 callersFunctionrun
()
cmd/provider-services/main.go:13
↓ 55 callersMethodLeaseID
()
cluster/types/v1beta3/deployment.go:10
↓ 46 callersMethodLeaseID
()
cluster/kube/builder/builder.go:77
↓ 46 callersFunctionLidNS
LidNS generates a unique sha256 sum for identifying a provider's object name.
cluster/kube/builder/builder.go:288
↓ 45 callersMethodClose
()
cluster/service.go:94
↓ 45 callersMethodSet
([]byte)
operator/common/prepared_data.go:15
↓ 43 callersMethodString
()
cluster/types/v1beta3/clients/ip/ip.go:73
↓ 40 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
↓ 36 callersMethodLen
()
cluster/kube/client_exec.go:39
↓ 33 callersMethodAkashV2beta2
()
pkg/client/clientset/versioned/clientset.go:33
↓ 32 callersMethodError
()
operator/ip/types/error_response.go:34
↓ 30 callersMethodLen
()
tools/certissuer/lego.go:57
↓ 28 callersMethodCreate
()
cluster/kube/builder/role.go:10
↓ 28 callersMethodError
()
gateway/rest/router_test.go:70
↓ 26 callersMethodStop
()
cluster/kube/operators/clients/metallb/client.go:61
↓ 25 callersMethodName
()
cluster/kube/builder/manifest.go:13
↓ 25 callersMethodUpdate
(obj *rbacv1.Role)
cluster/kube/builder/role.go:11
↓ 22 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
pkg/apis/akash.network/v2beta2/zz_generated.deepcopy.go:1040
↓ 22 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:1034
↓ 22 callersMethodShutdown
()
cluster/types/v1beta3/types.go:75
↓ 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 callersMethodDup
()
cluster/types/v1beta3/types.go:71
↓ 19 callersMethodDone
()
cluster/types/v1beta3/types.go:76
↓ 19 callersMethodOrderID
()
cluster/types/v1beta3/reservation.go:18
↓ 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 callersMethodQuery
(ctx context.Context)
operator/inventory/types.go:165
↓ 17 callersFunctionAppendLeaseLabels
(lid mtypes.LeaseID, labels map[string]string)
cluster/kube/builder/builder.go:292
↓ 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 callersFunctionLogrFromCtx
(ctx context.Context)
tools/fromctx/context.go:52
↓ 16 callersMethodResultChan
()
cluster/types/v1beta3/types.go:77
↓ 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
↓ 15 callersMethodManifest
()
service.go:40
↓ 15 callersMethodManifestGroup
()
cluster/kube/builder/builder.go:78
↓ 15 callersMethodMetrics
()
cluster/types/v1beta3/types.go:69
↓ 15 callersMethodNS
()
cluster/kube/builder/builder.go:213
↓ 15 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
↓ 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 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
↓ 15 callersFunctionmakeOrderForTest
( t *testing.T, checkForExistingBid bool, bidState mvbeta.Bid_State, pricing BidPricingStrategy, callerCo
bidengine/order_test.go:167
↓ 14 callersMethodWithName
WithName sets the Name 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:66
↓ 13 callersMethodAdjust
(ReservationGroup, ...InventoryOption)
cluster/types/v1beta3/types.go:68
↓ 13 callersMethodFromCRD
FromCRD returns LeaseID from LeaseID details
pkg/apis/akash.network/v2beta2/types.go:59
↓ 13 callersMethodGetLeaseID
()
cluster/types/v1beta3/clients/ip/ip.go:34
↓ 13 callersFunctionNewClient
(ctx context.Context)
cluster/kube/operators/clients/inventory/client.go:60
↓ 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:35
↓ 13 callersMethodWait
(wait <-chan struct{})
cluster/hostname.go:63
↓ 13 callersFunctionclientForTest
(t *testing.T, kobjs []runtime.Object, aobjs []runtime.Object)
cluster/kube/client_test.go:28
↓ 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
↓ 12 callersMethodClient
()
session/session.go:13
↓ 12 callersMethodCopy
()
operator/inventory/config.go:129
↓ 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 callersMethodProvider
()
session/session.go:14
↓ 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 callersMethodlabels
()
cluster/kube/builder/role.go:40
↓ 12 callersMethodwaitForBlockchainEvent
(expEv interface{})
integration/e2e_test.go:787
↓ 12 callersFunctionwrapKubeCall
(label string, fn func() (T, error))
cluster/kube/client.go:77
↓ 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 callersMethodWatch
(ctx context.Context, opts metav1.ListOptions)
operator/inventory/types.go:169
↓ 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 callersFunctionNewWorkloadBuilder
( log log.Logger, settings Settings, deployment IClusterDeployment, mani *crd.Manifest, serviceIdx int, )
cluster/kube/builder/workload.go:42
↓ 10 callersMethodServiceStatus
(context.Context, mtypes.LeaseID, string)
cluster/client.go:50
↓ 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:615
↓ 9 callersFunctionAddProviderOperationFlagsToCmd
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:54
↓ 9 callersMethodDelete
(ctx context.Context, name string, opts v1.DeleteOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:43
↓ 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:216
↓ 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 callersFunctionStatusCodeFrom
(err error)
utils/httperror/httperror.go:45
↓ 9 callersFunctionaddAuthFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:79
next →1–100 of 2,680, ranked by callers