Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/akash-network/provider
/ functions
Functions
2,680 in github.com/akash-network/provider
⨍
Functions
2,680
◇
Types & classes
661
↓ 1 callers
Function
applyDeployment
(ctx context.Context, kc kubernetes.Interface, b builder.Deployment)
cluster/kube/apply.go:144
↓ 1 callers
Method
applyEvent
(ctx context.Context, ev chostname.ResourceEvent)
operator/hostname/operator.go:322
↓ 1 callers
Function
applyNS
(ctx context.Context, kc kubernetes.Interface, b builder.NS)
cluster/kube/apply.go:31
↓ 1 callers
Function
applyNetPolicies
Apply list of Network Policies
cluster/kube/apply.go:60
↓ 1 callers
Function
applyRole
(ctx context.Context, kc kubernetes.Interface, b builder.Role)
cluster/kube/apply.go:299
↓ 1 callers
Function
applyRoleBinding
(ctx context.Context, kc kubernetes.Interface, b builder.RoleBinding)
cluster/kube/apply.go:326
↓ 1 callers
Function
applyService
(ctx context.Context, kc kubernetes.Interface, b builder.Service)
cluster/kube/apply.go:247
↓ 1 callers
Function
applyServiceAccount
(ctx context.Context, kc kubernetes.Interface, b builder.ServiceAccount)
cluster/kube/apply.go:273
↓ 1 callers
Function
applyServiceCredentials
(ctx context.Context, kc kubernetes.Interface, b builder.ServiceCredentials)
cluster/kube/apply.go:116
↓ 1 callers
Function
applyStatefulSet
(ctx context.Context, kc kubernetes.Interface, b builder.StatefulSet)
cluster/kube/apply.go:216
↓ 1 callers
Function
aqParseOpts
(opts ...AccountQuerierOption)
cmd/provider-services/cmd/certs.go:102
↓ 1 callers
Function
authErrorResponse
(err error)
gateway/rest/auth.go:41
↓ 1 callers
Function
authInterceptor
()
gateway/grpc/server.go:108
↓ 1 callers
Function
availableLeasedIPs
(total, inUse, reserved uint)
cluster/inventory.go:422
↓ 1 callers
Function
buildClusterSettings
(mgroup *mani.Group, reservation crd.ReservationClusterSettings)
cluster/kube/builder/builder.go:133
↓ 1 callers
Function
buildDirective
(ev chostname.ResourceEvent, serviceExpose crd.ManifestServiceExpose)
operator/hostname/operator.go:354
↓ 1 callers
Function
calculatePriceRange
(gspec *dtypes.GroupSpec)
bidengine/pricing.go:277
↓ 1 callers
Function
ceilBigRatToBigInt
(v *big.Rat)
bidengine/pricing.go:121
↓ 1 callers
Method
checkHostnamesForManifest
(requestManifest maniv2beta2.Manifest, groupNames []string)
manifest/manager.go:457
↓ 1 callers
Method
checkLeaseActive
(ctx context.Context)
cluster/manager.go:569
↓ 1 callers
Function
clusterNSCmd
()
cmd/provider-services/cmd/clusterns.go:13
↓ 1 callers
Function
cmdPsutil
()
operator/psutil.go:34
↓ 1 callers
Function
cmdPsutilList
()
operator/psutil.go:113
↓ 1 callers
Function
cmdPsutilServe
()
operator/psutil.go:51
↓ 1 callers
Method
completeAllPending
(auditor string, result atypes.AuditedProviders)
bidengine/provider_attributes.go:223
↓ 1 callers
Function
configWatcher
(ctx context.Context, file string)
operator/inventory/cmd.go:299
↓ 1 callers
Method
connectHostnameToDeployment
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator.go:716
↓ 1 callers
Method
connectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
operator/hostname/operator_gateway.go:13
↓ 1 callers
Method
connectHostnameToDeploymentGateway
(ctx context.Context, directive chostname.ConnectToDeploymentDirective)
cluster/kube/client_gateway.go:31
↓ 1 callers
Method
copy
()
operator/inventory/types.go:220
↓ 1 callers
Function
copyManagedLabels
(in map[string]string)
operator/inventory/node-discovery.go:776
↓ 1 callers
Method
crdInstalled
(log logr.Logger, rc *rookclientset.Clientset)
operator/inventory/ceph.go:152
↓ 1 callers
Function
createAddressHandler
(log log.Logger, providerAddr sdk.Address)
gateway/rest/router.go:405
↓ 1 callers
Function
createBidPricingStrategy
(strategy string)
cmd/provider-services/cmd/run.go:410
↓ 1 callers
Function
createClusterClient
(ctx context.Context, log log.Logger, _ *cobra.Command)
cmd/provider-services/cmd/run.go:867
↓ 1 callers
Method
createFakeOperator
(t *testing.T)
cluster/kube/operators/clients/inventory/client_test.go:101
↓ 1 callers
Function
createFolderIfNotExists
(path string)
tools/certissuer/storage.go:618
↓ 1 callers
Function
createManifestHandler
(log log.Logger, mclient pmanifest.Client)
gateway/rest/router.go:467
↓ 1 callers
Function
createStatusHandler
(log log.Logger, sclient provider.StatusClient, providerAddr sdk.Address)
gateway/rest/router.go:436
↓ 1 callers
Function
createVersionHandler
(log log.Logger, pclient provider.Client)
gateway/rest/router.go:421
↓ 1 callers
Function
create_providerhosts
()
script/provider_migrate_to_hostname_operator.py:167
↓ 1 callers
Method
deploymentsForLease
(ctx context.Context, lid mtypes.LeaseID)
cluster/kube/client.go:1234
↓ 1 callers
Function
depsFromBuildInfo
()
version/version.go:124
↓ 1 callers
Method
disable
()
operator/ip/types.go:41
↓ 1 callers
Method
discover
()
cluster/util/service_discovery_agent.go:162
↓ 1 callers
Method
discoverDNS
()
cluster/util/service_discovery_agent.go:227
↓ 1 callers
Method
discoverKube
()
cluster/util/service_discovery_agent.go:170
↓ 1 callers
Method
do
(fn func() error)
cluster/manager.go:603
↓ 1 callers
Method
doCheck
(ctx context.Context)
cluster/monitor.go:161
↓ 1 callers
Method
doCheckDeploymentExists
(req checkDeploymentExistsRequest)
cluster/service.go:449
↓ 1 callers
Method
doDeploy
(pctx context.Context)
cluster/manager.go:326
↓ 1 callers
Method
doFetchData
(ctx context.Context)
manifest/manager.go:258
↓ 1 callers
Function
doLeaseEvents
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseEvents.go:37
↓ 1 callers
Function
doLeaseLogs
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseLogs.go:40
↓ 1 callers
Function
doLeaseStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/leaseStatus.go:31
↓ 1 callers
Function
doMigrateRun
(ctx context.Context, cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:89
↓ 1 callers
Function
doRunCmd
doRunCmd initializes all the Provider functionality, hangs, and awaits shutdown signals.
cmd/provider-services/cmd/run.go:468
↓ 1 callers
Function
doSendManifest
(cmd *cobra.Command, sdlpath string)
cmd/provider-services/cmd/manifest.go:123
↓ 1 callers
Function
doServiceStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/serviceStatus.go:36
↓ 1 callers
Function
doStatus
(cmd *cobra.Command)
cmd/provider-services/cmd/status.go:46
↓ 1 callers
Method
doTeardown
(ctx context.Context)
cluster/manager.go:501
↓ 1 callers
Function
dseqFromFlags
(flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:104
↓ 1 callers
Method
dup
nolint: unused
operator/inventory/ceph.go:97
↓ 1 callers
Method
each
(f func(k mtypes.LeaseID, failure error, failedAt time.Time, count uint, extra ...string) error)
operator/common/ignore_list.go:89
↓ 1 callers
Method
emitReceivedEvents
()
manifest/manager.go:338
↓ 1 callers
Method
enable
()
operator/ip/types.go:37
↓ 1 callers
Function
encodeAuth
(username, password string)
cluster/kube/builder/service_credentials.go:105
↓ 1 callers
Method
ensureDirStructure
()
tools/certissuer/storage.go:628
↓ 1 callers
Method
enter
()
operator/ip/types.go:45
↓ 1 callers
Function
errorIsKubernetesResourceNotFound
(failure error)
operator/hostname/operator.go:281
↓ 1 callers
Function
eventsResourceMapping
eventsResourceMapping returns the policy mapping for "events" resource
cluster/kube/builder/permissions.go:154
↓ 1 callers
Method
failAllPending
(auditor string, err error)
bidengine/provider_attributes.go:215
↓ 1 callers
Function
fakeIPOperatorHandler
()
cluster/kube/operators/clients/ip/client_test.go:48
↓ 1 callers
Method
fetch
(ctx context.Context, auditor string)
bidengine/provider_attributes.go:314
↓ 1 callers
Method
fetchData
(ctx context.Context)
manifest/manager.go:246
↓ 1 callers
Function
findDeployments
( ctx context.Context, log log.Logger, client Client, )
cluster/service.go:479
↓ 1 callers
Method
fromCRD
()
pkg/apis/akash.network/v2beta2/manifest.go:239
↓ 1 callers
Function
generateLabels
(cfg Config, knode *corev1.Node, node v1.Node, sc storageClasses)
operator/inventory/node-discovery.go:814
↓ 1 callers
Function
generatePrivateKey
(file string, keyType certcrypto.KeyType)
tools/certissuer/storage.go:555
↓ 1 callers
Method
getBidTimeout
()
bidengine/order.go:151
↓ 1 callers
Function
getCertificateChain
(certRes *certificate.Resource)
tools/certissuer/storage.go:678
↓ 1 callers
Method
getCleanupRetryOpts
(ctx context.Context)
cluster/manager.go:484
↓ 1 callers
Method
getFileName
(domain string, extension string)
tools/certissuer/storage.go:444
↓ 1 callers
Method
getHostnameDeploymentConnections
(ctx context.Context)
operator/hostname/operator.go:503
↓ 1 callers
Method
getHostnameDeploymentConnectionsGateway
(ctx context.Context)
operator/hostname/operator_gateway.go:28
↓ 1 callers
Method
getHostnameDeploymentConnectionsGateway
(ctx context.Context)
cluster/kube/client_gateway.go:56
↓ 1 callers
Function
getKubernetesIP
()
integration/e2e_test.go:741
↓ 1 callers
Method
getManifestGroup
(ctx context.Context, lID mtypes.LeaseID)
operator/hostname/operator.go:665
↓ 1 callers
Function
getManifestHandler
(log log.Logger, cclient cluster.ReadClient)
gateway/rest/router.go:492
↓ 1 callers
Function
getPFXEncoder
(pfxFormat string)
tools/certissuer/storage.go:662
↓ 1 callers
Method
getPermissions
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 callers
Function
getSDKVersion
()
version/version.go:152
↓ 1 callers
Method
getStatus
(state *inventoryServiceState)
cluster/inventory.go:805
↓ 1 callers
Function
get_tenant_namespaces
()
script/provider_migrate_to_hostname_operator.py:82
↓ 1 callers
Method
handleEvent
(ev pubsub.Event)
bidengine/provider_attributes.go:196
↓ 1 callers
Function
handleHTTPError
(op *ipOperator, rw http.ResponseWriter, req *http.Request, err error, status int)
operator/ip/operator.go:436
↓ 1 callers
Function
handleIPLeaseStatusGet
(op *ipOperator, rw http.ResponseWriter, req *http.Request)
operator/ip/operator.go:514
↓ 1 callers
Method
handleLease
(ev event.LeaseWon, isNew bool)
manifest/service.go:349
↓ 1 callers
Method
handleManifest
(req manifestRequest)
manifest/manager.go:117
↓ 1 callers
Method
handleRequest
(req inventoryRequest, state *inventoryServiceState)
cluster/inventory.go:446
← previous
next →
701–800 of 2,680, ranked by callers