MCPcopy Create free account

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

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

↓ 1 callersFunctionapplyDeployment
(ctx context.Context, kc kubernetes.Interface, b builder.Deployment)
cluster/kube/apply.go:144
↓ 1 callersMethodapplyEvent
(ctx context.Context, ev chostname.ResourceEvent)
operator/hostname/operator.go:322
↓ 1 callersFunctionapplyNS
(ctx context.Context, kc kubernetes.Interface, b builder.NS)
cluster/kube/apply.go:31
↓ 1 callersFunctionapplyNetPolicies
Apply list of Network Policies
cluster/kube/apply.go:60
↓ 1 callersFunctionapplyRole
(ctx context.Context, kc kubernetes.Interface, b builder.Role)
cluster/kube/apply.go:299
↓ 1 callersFunctionapplyRoleBinding
(ctx context.Context, kc kubernetes.Interface, b builder.RoleBinding)
cluster/kube/apply.go:326
↓ 1 callersFunctionapplyService
(ctx context.Context, kc kubernetes.Interface, b builder.Service)
cluster/kube/apply.go:247
↓ 1 callersFunctionapplyServiceAccount
(ctx context.Context, kc kubernetes.Interface, b builder.ServiceAccount)
cluster/kube/apply.go:273
↓ 1 callersFunctionapplyServiceCredentials
(ctx context.Context, kc kubernetes.Interface, b builder.ServiceCredentials)
cluster/kube/apply.go:116
↓ 1 callersFunctionapplyStatefulSet
(ctx context.Context, kc kubernetes.Interface, b builder.StatefulSet)
cluster/kube/apply.go:216
↓ 1 callersFunctionaqParseOpts
(opts ...AccountQuerierOption)
cmd/provider-services/cmd/certs.go:102
↓ 1 callersFunctionauthErrorResponse
(err error)
gateway/rest/auth.go:41
↓ 1 callersFunctionauthInterceptor
()
gateway/grpc/server.go:108
↓ 1 callersFunctionavailableLeasedIPs
(total, inUse, reserved uint)
cluster/inventory.go:422
↓ 1 callersFunctionbuildClusterSettings
(mgroup *mani.Group, reservation crd.ReservationClusterSettings)
cluster/kube/builder/builder.go:133
↓ 1 callersFunctionbuildDirective
(ev chostname.ResourceEvent, serviceExpose crd.ManifestServiceExpose)
operator/hostname/operator.go:354
↓ 1 callersFunctioncalculatePriceRange
(gspec *dtypes.GroupSpec)
bidengine/pricing.go:277
↓ 1 callersFunctionceilBigRatToBigInt
(v *big.Rat)
bidengine/pricing.go:121
↓ 1 callersMethodcheckHostnamesForManifest
(requestManifest maniv2beta2.Manifest, groupNames []string)
manifest/manager.go:457
↓ 1 callersMethodcheckLeaseActive
(ctx context.Context)
cluster/manager.go:569
↓ 1 callersFunctionclusterNSCmd
()
cmd/provider-services/cmd/clusterns.go:13
↓ 1 callersFunctioncmdPsutil
()
operator/psutil.go:34
↓ 1 callersFunctioncmdPsutilList
()
operator/psutil.go:113
↓ 1 callersFunctioncmdPsutilServe
()
operator/psutil.go:51
↓ 1 callersMethodcompleteAllPending
(auditor string, result atypes.AuditedProviders)
bidengine/provider_attributes.go:223
↓ 1 callersFunctionconfigWatcher
(ctx context.Context, file string)
operator/inventory/cmd.go:299
↓ 1 callersMethodconnectHostnameToDeployment
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator.go:716
↓ 1 callersMethodconnectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator_gateway.go:13
↓ 1 callersMethodconnectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
cluster/kube/client_gateway.go:31
↓ 1 callersMethodcopy
()
operator/inventory/types.go:220
↓ 1 callersFunctioncopyManagedLabels
(in map[string]string)
operator/inventory/node-discovery.go:776
↓ 1 callersMethodcrdInstalled
(log logr.Logger, rc *rookclientset.Clientset)
operator/inventory/ceph.go:152
↓ 1 callersFunctioncreateAddressHandler
(log log.Logger, providerAddr sdk.Address)
gateway/rest/router.go:405
↓ 1 callersFunctioncreateBidPricingStrategy
(strategy string)
cmd/provider-services/cmd/run.go:410
↓ 1 callersFunctioncreateClusterClient
(ctx context.Context, log log.Logger, _ *cobra.Command)
cmd/provider-services/cmd/run.go:867
↓ 1 callersMethodcreateFakeOperator
(t *testing.T)
cluster/kube/operators/clients/inventory/client_test.go:101
↓ 1 callersFunctioncreateFolderIfNotExists
(path string)
tools/certissuer/storage.go:618
↓ 1 callersFunctioncreateManifestHandler
(log log.Logger, mclient pmanifest.Client)
gateway/rest/router.go:467
↓ 1 callersFunctioncreateStatusHandler
(log log.Logger, sclient provider.StatusClient, providerAddr sdk.Address)
gateway/rest/router.go:436
↓ 1 callersFunctioncreateVersionHandler
(log log.Logger, pclient provider.Client)
gateway/rest/router.go:421
↓ 1 callersFunctioncreate_providerhosts
()
script/provider_migrate_to_hostname_operator.py:167
↓ 1 callersMethoddeploymentsForLease
(ctx context.Context, lid mtypes.LeaseID)
cluster/kube/client.go:1234
↓ 1 callersFunctiondepsFromBuildInfo
()
version/version.go:124
↓ 1 callersMethoddisable
()
operator/ip/types.go:41
↓ 1 callersMethoddiscover
()
cluster/util/service_discovery_agent.go:162
↓ 1 callersMethoddiscoverDNS
()
cluster/util/service_discovery_agent.go:227
↓ 1 callersMethoddiscoverKube
()
cluster/util/service_discovery_agent.go:170
↓ 1 callersMethoddo
(fn func() error)
cluster/manager.go:603
↓ 1 callersMethoddoCheck
(ctx context.Context)
cluster/monitor.go:161
↓ 1 callersMethoddoCheckDeploymentExists
(req checkDeploymentExistsRequest)
cluster/service.go:449
↓ 1 callersMethoddoDeploy
(pctx context.Context)
cluster/manager.go:326
↓ 1 callersMethoddoFetchData
(ctx context.Context)
manifest/manager.go:258
↓ 1 callersFunctiondoLeaseEvents
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseEvents.go:37
↓ 1 callersFunctiondoLeaseLogs
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseLogs.go:40
↓ 1 callersFunctiondoLeaseStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseStatus.go:31
↓ 1 callersFunctiondoMigrateRun
(ctx context.Context, cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:89
↓ 1 callersFunctiondoRunCmd
doRunCmd initializes all the Provider functionality, hangs, and awaits shutdown signals.
cmd/provider-services/cmd/run.go:468
↓ 1 callersFunctiondoSendManifest
(cmd *cobra.Command, sdlpath string)
cmd/provider-services/cmd/manifest.go:123
↓ 1 callersFunctiondoServiceStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/serviceStatus.go:36
↓ 1 callersFunctiondoStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/status.go:46
↓ 1 callersMethoddoTeardown
(ctx context.Context)
cluster/manager.go:501
↓ 1 callersFunctiondseqFromFlags
(flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:104
↓ 1 callersMethoddup
nolint: unused
operator/inventory/ceph.go:97
↓ 1 callersMethodeach
(f func(k mtypes.LeaseID, failure error, failedAt time.Time, count uint, extra ...string) error)
operator/common/ignore_list.go:89
↓ 1 callersMethodemitReceivedEvents
()
manifest/manager.go:338
↓ 1 callersMethodenable
()
operator/ip/types.go:37
↓ 1 callersFunctionencodeAuth
(username, password string)
cluster/kube/builder/service_credentials.go:105
↓ 1 callersMethodensureDirStructure
()
tools/certissuer/storage.go:628
↓ 1 callersMethodenter
()
operator/ip/types.go:45
↓ 1 callersFunctionerrorIsKubernetesResourceNotFound
(failure error)
operator/hostname/operator.go:281
↓ 1 callersFunctioneventsResourceMapping
eventsResourceMapping returns the policy mapping for "events" resource
cluster/kube/builder/permissions.go:154
↓ 1 callersMethodfailAllPending
(auditor string, err error)
bidengine/provider_attributes.go:215
↓ 1 callersFunctionfakeIPOperatorHandler
()
cluster/kube/operators/clients/ip/client_test.go:48
↓ 1 callersMethodfetch
(ctx context.Context, auditor string)
bidengine/provider_attributes.go:314
↓ 1 callersMethodfetchData
(ctx context.Context)
manifest/manager.go:246
↓ 1 callersFunctionfindDeployments
( ctx context.Context, log log.Logger, client Client, )
cluster/service.go:479
↓ 1 callersMethodfromCRD
()
pkg/apis/akash.network/v2beta2/manifest.go:239
↓ 1 callersFunctiongenerateLabels
(cfg Config, knode *corev1.Node, node v1.Node, sc storageClasses)
operator/inventory/node-discovery.go:814
↓ 1 callersFunctiongeneratePrivateKey
(file string, keyType certcrypto.KeyType)
tools/certissuer/storage.go:555
↓ 1 callersMethodgetBidTimeout
()
bidengine/order.go:151
↓ 1 callersFunctiongetCertificateChain
(certRes *certificate.Resource)
tools/certissuer/storage.go:678
↓ 1 callersMethodgetCleanupRetryOpts
(ctx context.Context)
cluster/manager.go:484
↓ 1 callersMethodgetFileName
(domain string, extension string)
tools/certissuer/storage.go:444
↓ 1 callersMethodgetHostnameDeploymentConnections
(ctx context.Context)
operator/hostname/operator.go:503
↓ 1 callersMethodgetHostnameDeploymentConnectionsGateway
(ctx context.Context)
operator/hostname/operator_gateway.go:28
↓ 1 callersMethodgetHostnameDeploymentConnectionsGateway
(ctx context.Context)
cluster/kube/client_gateway.go:56
↓ 1 callersFunctiongetKubernetesIP
()
integration/e2e_test.go:741
↓ 1 callersMethodgetManifestGroup
(ctx context.Context, lID mtypes.LeaseID)
operator/hostname/operator.go:665
↓ 1 callersFunctiongetManifestHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:492
↓ 1 callersFunctiongetPFXEncoder
(pfxFormat string)
tools/certissuer/storage.go:662
↓ 1 callersMethodgetPermissions
getPermissions returns the read permissions list for backward compatibility. Deprecated: Use GetWorkloadPermissions() for access to all permission typ
cluster/kube/builder/workload.go:451
↓ 1 callersFunctiongetSDKVersion
()
version/version.go:152
↓ 1 callersMethodgetStatus
(state *inventoryServiceState)
cluster/inventory.go:805
↓ 1 callersFunctionget_tenant_namespaces
()
script/provider_migrate_to_hostname_operator.py:82
↓ 1 callersMethodhandleEvent
(ev pubsub.Event)
bidengine/provider_attributes.go:196
↓ 1 callersFunctionhandleHTTPError
(op *ipOperator, rw http.ResponseWriter, req *http.Request, err error, status int)
operator/ip/operator.go:436
↓ 1 callersFunctionhandleIPLeaseStatusGet
(op *ipOperator, rw http.ResponseWriter, req *http.Request)
operator/ip/operator.go:514
↓ 1 callersMethodhandleLease
(ev event.LeaseWon, isNew bool)
manifest/service.go:349
↓ 1 callersMethodhandleManifest
(req manifestRequest)
manifest/manager.go:117
↓ 1 callersMethodhandleRequest
(req inventoryRequest, state *inventoryServiceState)
cluster/inventory.go:446
← previousnext →701–800 of 2,680, ranked by callers