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
↓ 2 callers
Function
AllHostnamesOfManifestGroup
(mgroup manitypes.Group)
manifest/parse.go:13
↓ 2 callers
Function
AuthProcess
(ctx context.Context, peerCerts []*x509.Certificate, token string)
gateway/utils/utils.go:89
↓ 2 callers
Method
BuildHTTPRouteSpec
BuildHTTPRouteSpec builds the HTTPRoute spec with implementation-specific features. This includes standard Gateway API features (hostnames, routes, ba
cluster/kube/gateway/gateway.go:26
↓ 2 callers
Function
BuildManifest
(log log.Logger, settings Settings, ns string, deployment IClusterDeployment)
cluster/kube/builder/manifest.go:25
↓ 2 callers
Function
BuildRoleBinding
BuildRoleBinding creates a new RoleBinding builder for the given workload.
cluster/kube/builder/rolebinding.go:29
↓ 2 callers
Function
BuildServiceAccount
(workload *Workload)
cluster/kube/builder/serviceaccount.go:20
↓ 2 callers
Method
Close
()
tools/certissuer/lego.go:36
↓ 2 callers
Method
Cluster
()
service.go:41
↓ 2 callers
Method
ClusterParams
()
cluster/types/v1beta3/deployment.go:12
↓ 2 callers
Function
ClusterStateFromCtx
(ctx context.Context)
operator/inventory/util.go:58
↓ 2 callers
Function
Cmd
()
operator/hostname/cmd.go:18
↓ 2 callers
Function
Cmd
()
operator/ip/cmd.go:25
↓ 2 callers
Method
Create
(ctx context.Context, manifest *akashnetworkv2beta2.Manifest, opts v1.CreateOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:41
↓ 2 callers
Function
CreateOrUpdateHTTPRoute
CreateOrUpdateHTTPRoute creates or updates an HTTPRoute for a hostname directive. It uses the provided Provider to build annotations and the HTTPRoute
cluster/kube/gateway/httproute.go:52
↓ 2 callers
Method
CreatedAtBlockHeight
()
session/session.go:16
↓ 2 callers
Method
DeclareHostname
DeclareHostname Declare that a given deployment should be connected to a given hostname
cluster/client.go:85
↓ 2 callers
Method
DeclareIP
(ctx context.Context, lID mtypes.LeaseID, serviceName string, port uint32, externalPort uint32, proto mani.Ser
cluster/client.go:94
↓ 2 callers
Method
DelAccount
(context.Context, sdk.Address)
tools/pconfig/pconfig.go:33
↓ 2 callers
Method
DelAccountCertificate
(context.Context, sdk.Address, *big.Int)
tools/pconfig/pconfig.go:35
↓ 2 callers
Function
DeleteHTTPRoute
DeleteHTTPRoute removes an HTTPRoute by hostname. If allowMissing is true, NotFound errors are ignored.
cluster/kube/gateway/httproute.go:112
↓ 2 callers
Method
Description
Description returns a human-readable description of what this migration does.
migrations/migrations.go:16
↓ 2 callers
Method
ExistsOrWildcard
(model string)
cluster/types/v1beta3/clients/inventory/metrics.go:26
↓ 2 callers
Method
FilterOutStorageClasses
(available []string)
operator/inventory/config.go:88
↓ 2 callers
Method
FindActiveLease
(ctx context.Context, owner sdktypes.Address, dseq uint64, gseq uint32)
cluster/service.go:87
↓ 2 callers
Function
Get
Get returns a migration by name, or nil if not found.
migrations/registry.go:57
↓ 2 callers
Method
GetAddress
()
gateway/rest/integration_test.go:52
↓ 2 callers
Method
GetAllCertificates
(context.Context)
tools/pconfig/pconfig.go:28
↓ 2 callers
Method
GetCode
()
operator/ip/types/error_response.go:26
↓ 2 callers
Function
GetEndpointQuantityOfResourceUnits
(r rtypes.Resources, kind rtypes.Endpoint_Kind)
cluster/util/endpoint_quantity.go:25
↓ 2 callers
Method
GetEventType
()
cluster/types/v1beta3/clients/ip/ip.go:30
↓ 2 callers
Method
GetNamespace
GetNamespace retrieves the value of the Namespace field in the declarative configuration.
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:230
↓ 2 callers
Function
GetOperatorConfigFromViper
()
operator/common/operator_config.go:18
↓ 2 callers
Function
GetProvider
GetProvider retrieves a Gateway provider from the default registry. This is the primary entry point for obtaining Gateway providers.
cluster/kube/gateway/registry.go:55
↓ 2 callers
Function
IgnoreListConfigFromViper
()
operator/common/ignore_list_config.go:23
↓ 2 callers
Function
InformKubeObjects
(ctx context.Context, pub pubsub.Publisher, informer cache.SharedIndexInformer, topic string)
operator/inventory/types.go:186
↓ 2 callers
Method
Inventories
Inventories returns a InventoryInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:28
↓ 2 callers
Method
InventoryRequests
InventoryRequests returns a InventoryRequestInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:30
↓ 2 callers
Method
IsAnyNegative
()
bidengine/pricing.go:59
↓ 2 callers
Method
IsNodeExcluded
(name string)
operator/inventory/config.go:283
↓ 2 callers
Method
LeaseEvents
(context.Context, mtypes.LeaseID, string, bool)
cluster/client.go:48
↓ 2 callers
Method
LeaseLogs
(context.Context, mtypes.LeaseID, string, bool, *int64)
cluster/client.go:49
↓ 2 callers
Method
LeaseStatus
LeaseStatus provides a mock function for the type Client
mocks/cluster/Client_mock.go:1064
↓ 2 callers
Function
ListHTTPRouteConnections
ListHTTPRouteConnections lists all Akash-managed HTTPRoutes and returns them as LeaseIDConnection objects.
cluster/kube/gateway/httproute.go:133
↓ 2 callers
Function
ManifestSubmitErrorToHTTP
ManifestSubmitErrorToHTTP maps manifest submit errors to HttpError for gateway responses.
manifest/gateway.go:13
↓ 2 callers
Method
Manifests
Manifests returns a ManifestInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:32
↓ 2 callers
Function
NewBBolt
(path string)
tools/pconfig/bbolt/bbolt.go:49
↓ 2 callers
Function
NewDefaultConfig
()
config.go:33
↓ 2 callers
Function
NewFilteredInventoryInformer
NewFilteredInventoryInformer constructs a new informer for Inventory type. Always prefer using an informer factory to get a shared informer instead of
pkg/client/informers/externalversions/akash.network/v2beta2/inventory.go:57
↓ 2 callers
Function
NewFilteredInventoryRequestInformer
NewFilteredInventoryRequestInformer constructs a new informer for InventoryRequest type. Always prefer using an informer factory to get a shared infor
pkg/client/informers/externalversions/akash.network/v2beta2/inventoryrequest.go:57
↓ 2 callers
Function
NewFilteredManifestInformer
NewFilteredManifestInformer constructs a new informer for Manifest type. Always prefer using an informer factory to get a shared informer instead of g
pkg/client/informers/externalversions/akash.network/v2beta2/manifest.go:58
↓ 2 callers
Function
NewFilteredProviderHostInformer
NewFilteredProviderHostInformer constructs a new informer for ProviderHost type. Always prefer using an informer factory to get a shared informer inst
pkg/client/informers/externalversions/akash.network/v2beta2/providerhost.go:58
↓ 2 callers
Function
NewFilteredProviderLeasedIPInformer
NewFilteredProviderLeasedIPInformer constructs a new informer for ProviderLeasedIP type. Always prefer using an informer factory to get a shared infor
pkg/client/informers/externalversions/akash.network/v2beta2/providerleasedip.go:58
↓ 2 callers
Function
NewRemotePodCommandExecutor
(restcfg *rest.Config, clientset kubernetes.Interface)
operator/inventory/types.go:179
↓ 2 callers
Function
NewService
NewService creates new service instance and returns error in case of failure
bidengine/service.go:57
↓ 2 callers
Function
NewServiceCredentials
(workload *Workload, credentials *mani.ImageCredentials)
cluster/kube/builder/service_credentials.go:25
↓ 2 callers
Function
NewSharedInformerFactoryWithOptions
NewSharedInformerFactoryWithOptions constructs a new instance of a SharedInformerFactory with additional options.
pkg/client/informers/externalversions/factory.go:106
↓ 2 callers
Function
OpenLogger
()
operator/common/logger.go:11
↓ 2 callers
Function
OperatorsCmd
()
operator/cmd.go:27
↓ 2 callers
Function
ParseIngressMode
ParseIngressMode parses a string into an IngressMode, returning an error if the value is invalid.
cluster/kube/builder/settings.go:22
↓ 2 callers
Function
ParseStorageAttributes
(attrs attrtypes.Attributes)
cluster/types/v1beta3/clients/inventory/metrics.go:118
↓ 2 callers
Method
Patch
(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...stri
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:48
↓ 2 callers
Function
PersistentConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:269
↓ 2 callers
Method
Prepare
(pd PreparedResult)
operator/common/ignore_list.go:21
↓ 2 callers
Method
ProviderHosts
ProviderHosts returns a ProviderHostInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:34
↓ 2 callers
Method
PurgeIPPassthrough
(ctx context.Context, directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:57
↓ 2 callers
Method
Register
Register adds a new resource policy mapping to the registry
cluster/kube/builder/permissions.go:80
↓ 2 callers
Method
ReleaseHostnames
(leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:153
↓ 2 callers
Method
ServiceStatus
ServiceStatus provides a mock function for the type Client
mocks/cluster/Client_mock.go:1577
↓ 2 callers
Method
SetAllocatedResources
(dtypes.ResourceUnits)
cluster/types/v1beta3/reservation.go:10
↓ 2 callers
Method
Size
()
operator/common/ignore_list.go:16
↓ 2 callers
Method
String
()
version/version.go:141
↓ 2 callers
Method
TeardownLease
(context.Context, mtypes.LeaseID)
cluster/client.go:66
↓ 2 callers
Method
ToAkash
()
pkg/apis/akash.network/v2beta2/types.go:170
↓ 2 callers
Method
Unwrap
()
utils/httperror/httperror.go:37
↓ 2 callers
Function
accumEndpointsOfResources
(r rtypes.Resources, kind rtypes.Endpoint_Kind, accum map[uint32]struct{})
cluster/util/endpoint_quantity.go:17
↓ 2 callers
Function
addManifestFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:83
↓ 2 callers
Function
appEnv
appEnv asserts that there is an addressable docker container for KinD
integration/test_helpers.go:168
↓ 2 callers
Method
bidTimeoutEnabled
()
bidengine/order.go:147
↓ 2 callers
Method
buildHTTPRoute
( name string, labels map[string]string, ingressAnnotations map[string]string, gatewayName string, gatewa
migrations/ingress_to_httproute.go:144
↓ 2 callers
Function
buildIPDirective
(ev cip.ResourceEvent)
operator/ip/operator.go:273
↓ 2 callers
Method
buildPolicyRules
buildPolicyRules generates Kubernetes RBAC policy rules based on the workload permissions. It uses the PolicyRuleRegistry to map resource types (logs,
cluster/kube/builder/role.go:50
↓ 2 callers
Function
canReserveHostnamesImpl
(store map[string]hostnameID, hostnames []string, ownerAddr sdktypes.Address, chErr chan<- error)
cluster/hostname.go:204
↓ 2 callers
Method
clearFetched
()
manifest/manager.go:134
↓ 2 callers
Method
closeDeployments
()
integration/e2e_test.go:626
↓ 2 callers
Method
convertAnnotations
(ingressAnnotations map[string]string)
migrations/ingress_to_httproute.go:212
↓ 2 callers
Function
countReservedIPs
(state *inventoryServiceState)
cluster/inventory.go:411
↓ 2 callers
Function
createIPPassthroughResourceName
(directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:327
↓ 2 callers
Function
determineStatePath
(cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:112
↓ 2 callers
Method
doEscrowCheck
(ctx context.Context, lid mtypes.LeaseID, scheduledWithdraw bool)
balance_checker.go:122
↓ 2 callers
Method
done
()
cluster/monitor.go:69
↓ 2 callers
Method
dup
()
cluster/types/v1beta3/clients/inventory/inventory.go:268
↓ 2 callers
Method
dup
()
cluster/kube/operators/clients/inventory/inventory.go:29
↓ 2 callers
Method
encodeSecret
()
cluster/kube/builder/service_credentials.go:89
↓ 2 callers
Method
ensureManager
(did dtypes.DeploymentID)
manifest/service.go:364
↓ 2 callers
Method
exit
()
operator/ip/types.go:55
↓ 2 callers
Function
extractRemoteError
(response *http.Response)
cluster/kube/operators/clients/ip/client.go:155
↓ 2 callers
Function
fakeProviderHost
(hostname string, leaseID mtypes.LeaseID, serviceName string, externalPort uint32)
cluster/kube/client_test.go:45
↓ 2 callers
Method
fetchAttributes
()
bidengine/provider_attributes.go:181
↓ 2 callers
Method
fillAllRequests
(response error)
manifest/manager.go:326
↓ 2 callers
Method
getAnnotationInt
(annotations map[string]string, key string, defaultValue int)
migrations/ingress_to_httproute.go:252
← previous
next →
301–400 of 2,680, ranked by callers