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
↓ 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:706
↓ 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 callersFunctionupdateAkashLabels
(currLabels, newLabels map[string]string)
cluster/kube/builder/builder.go:302
↓ 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 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:82
↓ 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 callersMethodReserveHostnames
(ctx context.Context, hostnames []string, leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:152
↓ 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 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
↓ 8 callersFunctionkubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
cluster/kube/client.go:834
↓ 8 callersFunctionqueryClientOrNil
(cl aclient.Client)
cmd/provider-services/cmd/helpers.go:356
↓ 8 callersFunctionwriteJSON
(log log.Logger, w http.ResponseWriter, obj interface{})
gateway/rest/router.go:871
↓ 7 callersMethodAny
()
cluster/kube/builder/service.go:18
↓ 7 callersFunctionBuildService
(workload *Workload, requireNodePort bool)
cluster/kube/builder/service.go:28
↓ 7 callersMethodDeployment
Deployment returns the cluster.Deployment that the saved manifest represents.
pkg/apis/akash.network/v2beta2/manifest.go:177
↓ 7 callersMethodGetAuditorAttributeSignatures
(auditor string)
bidengine/provider_attributes.go:55
↓ 7 callersMethodGetServiceName
()
cluster/types/v1beta3/clients/ip/ip.go:35
↓ 7 callersMethodHostname
()
service.go:42
↓ 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 callersMethodRESTClient
()
pkg/client/clientset/versioned/typed/akash.network/v2beta2/akash.network_client.go:30
↓ 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 callersFunctionhostnameIDFromLeaseID
(lID mtypes.LeaseID)
cluster/hostname.go:34
↓ 7 callersFunctionnewInventoryService
( ctx context.Context, config Config, log log.Logger, sub pubsub.Subscriber, client Client, waiter waite
cluster/inventory.go:113
↓ 7 callersFunctionrequestLeaseID
(req *http.Request)
gateway/rest/middleware.go:35
↓ 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 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 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:249
↓ 6 callersFunctionsetupProviderAttributesTestScaffold
( t *testing.T, ttl time.Duration, clientFactory func(scaffold *providerAttributesTestScaffold) *clientmock
bidengine/provider_attributes_test.go:36
↓ 6 callersFunctionshowErrorToUser
(err error)
cmd/provider-services/cmd/run.go:880
↓ 6 callersMethodstop
(t *testing.T)
bidengine/provider_attributes_test.go:65
↓ 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 callersMethodGroup
(t testing.TB)
testutil/manifest/v2beta2/manifest.go:27
↓ 5 callersMethodInformerFor
(obj runtime.Object, newFunc NewInformerFunc)
pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go:36
↓ 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:155
↓ 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:315
↓ 5 callersMethodapplyEvent
(ctx context.Context, ev cip.ResourceEvent)
operator/ip/operator.go:234
↓ 5 callersMethodavailable
()
cluster/kube/resourcetypes.go:92
↓ 5 callersMethodcontainer
()
cluster/kube/builder/workload.go:81
↓ 5 callersMethodget
()
operator/common/prepared_data.go:56
↓ 5 callersFunctioninitTestBackends
(t *testing.T)
tools/pconfig/bbolt_test.go:31
↓ 5 callersFunctionmarkRPCServerError
(err error)
cmd/provider-services/cmd/helpers.go:228
↓ 5 callersFunctionnewestLease
(leases []mvbeta.QueryLeaseResponse)
integration/e2e_test.go:725
↓ 5 callersFunctionqueryAppWithRetries
nolint: unparam
integration/test_helpers.go:64
↓ 5 callersMethodreserve
(order mtypes.OrderID, resources dtypes.ResourceGroup)
cluster/inventory.go:185
↓ 5 callersFunctionrunIPOperator
(t *testing.T, run bool, aobj []runtime.Object, prerun, fn func(ctx context.Context, s ipOperatorScaffold))
operator/ip/operator_test.go:42
↓ 5 callersFunctiontakeCmdLock
()
testutil/provider/provider.go:25
↓ 5 callersFunctionwriteClusterError
(w http.ResponseWriter, err error)
gateway/rest/router.go:67
↓ 5 callersFunctionwriteJSON
(w http.ResponseWriter, obj interface{})
operator/psutil.go:220
↓ 4 callersMethodAddAccountCertificate
(context.Context, sdk.Address, *x509.Certificate, crypto.PublicKey)
tools/pconfig/pconfig.go:34
↓ 4 callersMethodAddError
(id mtypes.LeaseID, err error, extra ...string)
operator/common/ignore_list.go:22
↓ 4 callersFunctionAkashClientFromCtx
(ctx context.Context)
tools/fromctx/context.go:149
↓ 4 callersFunctionApplyToContext
(ctx context.Context, config map[interface{}]interface{})
tools/fromctx/context.go:366
↓ 4 callersMethodBuildAnnotations
BuildAnnotations converts directive options to implementation-specific annotations. These annotations are applied to the HTTPRoute metadata and contro
cluster/kube/gateway/gateway.go:21
↓ 4 callersMethodClose
()
tools/pconfig/pconfig.go:47
↓ 4 callersMethodFlag
()
operator/common/prepared_data.go:14
↓ 4 callersMethodGetAccountCertificate
(context.Context, sdk.Address, *big.Int)
tools/pconfig/pconfig.go:27
↓ 4 callersFunctionGetAll
GetAll returns all registered migrations.
migrations/registry.go:40
↓ 4 callersMethodGetAttributes
()
bidengine/provider_attributes.go:56
↓ 4 callersMethodGetPort
()
cluster/types/v1beta3/clients/ip/ip.go:37
↓ 4 callersMethodGetProviderVersion
GetProviderVersion returns the provider version from the state.
migrations/state.go:120
↓ 4 callersMethodGetRouter
()
operator/common/operator_server.go:23
↓ 4 callersMethodIsFlagged
(id mtypes.LeaseID)
operator/common/ignore_list.go:15
↓ 4 callersMethodLeaseID
()
cluster/types/v1beta3/deployment.go:25
↓ 4 callersFunctionMakeRandomRangePricing
()
bidengine/pricing.go:249
← previousnext →101–200 of 2,680, ranked by callers