MCPcopy Create free account

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

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

↓ 2 callersFunctionAllHostnamesOfManifestGroup
(mgroup manitypes.Group)
manifest/parse.go:13
↓ 2 callersFunctionAuthProcess
(ctx context.Context, peerCerts []*x509.Certificate, token string)
gateway/utils/utils.go:89
↓ 2 callersMethodBuildHTTPRouteSpec
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 callersFunctionBuildManifest
(log log.Logger, settings Settings, ns string, deployment IClusterDeployment)
cluster/kube/builder/manifest.go:25
↓ 2 callersFunctionBuildRoleBinding
BuildRoleBinding creates a new RoleBinding builder for the given workload.
cluster/kube/builder/rolebinding.go:29
↓ 2 callersFunctionBuildServiceAccount
(workload *Workload)
cluster/kube/builder/serviceaccount.go:20
↓ 2 callersMethodClose
()
tools/certissuer/lego.go:36
↓ 2 callersMethodCluster
()
service.go:41
↓ 2 callersMethodClusterParams
()
cluster/types/v1beta3/deployment.go:12
↓ 2 callersFunctionClusterStateFromCtx
(ctx context.Context)
operator/inventory/util.go:58
↓ 2 callersFunctionCmd
()
operator/hostname/cmd.go:18
↓ 2 callersFunctionCmd
()
operator/ip/cmd.go:25
↓ 2 callersMethodCreate
(ctx context.Context, manifest *akashnetworkv2beta2.Manifest, opts v1.CreateOptions)
pkg/client/clientset/versioned/typed/akash.network/v2beta2/manifest.go:41
↓ 2 callersFunctionCreateOrUpdateHTTPRoute
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 callersMethodCreatedAtBlockHeight
()
session/session.go:16
↓ 2 callersMethodDeclareHostname
DeclareHostname Declare that a given deployment should be connected to a given hostname
cluster/client.go:85
↓ 2 callersMethodDeclareIP
(ctx context.Context, lID mtypes.LeaseID, serviceName string, port uint32, externalPort uint32, proto mani.Ser
cluster/client.go:94
↓ 2 callersMethodDelAccount
(context.Context, sdk.Address)
tools/pconfig/pconfig.go:33
↓ 2 callersMethodDelAccountCertificate
(context.Context, sdk.Address, *big.Int)
tools/pconfig/pconfig.go:35
↓ 2 callersFunctionDeleteHTTPRoute
DeleteHTTPRoute removes an HTTPRoute by hostname. If allowMissing is true, NotFound errors are ignored.
cluster/kube/gateway/httproute.go:112
↓ 2 callersMethodDescription
Description returns a human-readable description of what this migration does.
migrations/migrations.go:16
↓ 2 callersMethodExistsOrWildcard
(model string)
cluster/types/v1beta3/clients/inventory/metrics.go:26
↓ 2 callersMethodFilterOutStorageClasses
(available []string)
operator/inventory/config.go:88
↓ 2 callersMethodFindActiveLease
(ctx context.Context, owner sdktypes.Address, dseq uint64, gseq uint32)
cluster/service.go:87
↓ 2 callersFunctionGet
Get returns a migration by name, or nil if not found.
migrations/registry.go:57
↓ 2 callersMethodGetAddress
()
gateway/rest/integration_test.go:52
↓ 2 callersMethodGetAllCertificates
(context.Context)
tools/pconfig/pconfig.go:28
↓ 2 callersMethodGetCode
()
operator/ip/types/error_response.go:26
↓ 2 callersFunctionGetEndpointQuantityOfResourceUnits
(r rtypes.Resources, kind rtypes.Endpoint_Kind)
cluster/util/endpoint_quantity.go:25
↓ 2 callersMethodGetEventType
()
cluster/types/v1beta3/clients/ip/ip.go:30
↓ 2 callersMethodGetNamespace
GetNamespace retrieves the value of the Namespace field in the declarative configuration.
pkg/client/applyconfiguration/akash.network/v2beta2/manifest.go:230
↓ 2 callersFunctionGetOperatorConfigFromViper
()
operator/common/operator_config.go:18
↓ 2 callersFunctionGetProvider
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 callersFunctionIgnoreListConfigFromViper
()
operator/common/ignore_list_config.go:23
↓ 2 callersFunctionInformKubeObjects
(ctx context.Context, pub pubsub.Publisher, informer cache.SharedIndexInformer, topic string)
operator/inventory/types.go:186
↓ 2 callersMethodInventories
Inventories returns a InventoryInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:28
↓ 2 callersMethodInventoryRequests
InventoryRequests returns a InventoryRequestInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:30
↓ 2 callersMethodIsAnyNegative
()
bidengine/pricing.go:59
↓ 2 callersMethodIsNodeExcluded
(name string)
operator/inventory/config.go:283
↓ 2 callersMethodLeaseEvents
(context.Context, mtypes.LeaseID, string, bool)
cluster/client.go:48
↓ 2 callersMethodLeaseLogs
(context.Context, mtypes.LeaseID, string, bool, *int64)
cluster/client.go:49
↓ 2 callersMethodLeaseStatus
LeaseStatus provides a mock function for the type Client
mocks/cluster/Client_mock.go:1064
↓ 2 callersFunctionListHTTPRouteConnections
ListHTTPRouteConnections lists all Akash-managed HTTPRoutes and returns them as LeaseIDConnection objects.
cluster/kube/gateway/httproute.go:133
↓ 2 callersFunctionManifestSubmitErrorToHTTP
ManifestSubmitErrorToHTTP maps manifest submit errors to HttpError for gateway responses.
manifest/gateway.go:13
↓ 2 callersMethodManifests
Manifests returns a ManifestInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:32
↓ 2 callersFunctionNewBBolt
(path string)
tools/pconfig/bbolt/bbolt.go:49
↓ 2 callersFunctionNewDefaultConfig
()
config.go:33
↓ 2 callersFunctionNewFilteredInventoryInformer
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 callersFunctionNewFilteredInventoryRequestInformer
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 callersFunctionNewFilteredManifestInformer
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 callersFunctionNewFilteredProviderHostInformer
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 callersFunctionNewFilteredProviderLeasedIPInformer
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 callersFunctionNewRemotePodCommandExecutor
(restcfg *rest.Config, clientset kubernetes.Interface)
operator/inventory/types.go:179
↓ 2 callersFunctionNewService
NewService creates new service instance and returns error in case of failure
bidengine/service.go:57
↓ 2 callersFunctionNewServiceCredentials
(workload *Workload, credentials *mani.ImageCredentials)
cluster/kube/builder/service_credentials.go:25
↓ 2 callersFunctionNewSharedInformerFactoryWithOptions
NewSharedInformerFactoryWithOptions constructs a new instance of a SharedInformerFactory with additional options.
pkg/client/informers/externalversions/factory.go:106
↓ 2 callersFunctionOpenLogger
()
operator/common/logger.go:11
↓ 2 callersFunctionOperatorsCmd
()
operator/cmd.go:27
↓ 2 callersFunctionParseIngressMode
ParseIngressMode parses a string into an IngressMode, returning an error if the value is invalid.
cluster/kube/builder/settings.go:22
↓ 2 callersFunctionParseStorageAttributes
(attrs attrtypes.Attributes)
cluster/types/v1beta3/clients/inventory/metrics.go:118
↓ 2 callersMethodPatch
(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 callersFunctionPersistentConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:269
↓ 2 callersMethodPrepare
(pd PreparedResult)
operator/common/ignore_list.go:21
↓ 2 callersMethodProviderHosts
ProviderHosts returns a ProviderHostInformer.
pkg/client/informers/externalversions/akash.network/v2beta2/interface.go:34
↓ 2 callersMethodPurgeIPPassthrough
(ctx context.Context, directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:57
↓ 2 callersMethodRegister
Register adds a new resource policy mapping to the registry
cluster/kube/builder/permissions.go:80
↓ 2 callersMethodReleaseHostnames
(leaseID mtypes.LeaseID)
cluster/types/v1beta3/types.go:153
↓ 2 callersMethodServiceStatus
ServiceStatus provides a mock function for the type Client
mocks/cluster/Client_mock.go:1577
↓ 2 callersMethodSetAllocatedResources
(dtypes.ResourceUnits)
cluster/types/v1beta3/reservation.go:10
↓ 2 callersMethodSize
()
operator/common/ignore_list.go:16
↓ 2 callersMethodString
()
version/version.go:141
↓ 2 callersMethodTeardownLease
(context.Context, mtypes.LeaseID)
cluster/client.go:66
↓ 2 callersMethodToAkash
()
pkg/apis/akash.network/v2beta2/types.go:170
↓ 2 callersMethodUnwrap
()
utils/httperror/httperror.go:37
↓ 2 callersFunctionaccumEndpointsOfResources
(r rtypes.Resources, kind rtypes.Endpoint_Kind, accum map[uint32]struct{})
cluster/util/endpoint_quantity.go:17
↓ 2 callersFunctionaddManifestFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:83
↓ 2 callersFunctionappEnv
appEnv asserts that there is an addressable docker container for KinD
integration/test_helpers.go:168
↓ 2 callersMethodbidTimeoutEnabled
()
bidengine/order.go:147
↓ 2 callersMethodbuildHTTPRoute
( name string, labels map[string]string, ingressAnnotations map[string]string, gatewayName string, gatewa
migrations/ingress_to_httproute.go:144
↓ 2 callersFunctionbuildIPDirective
(ev cip.ResourceEvent)
operator/ip/operator.go:273
↓ 2 callersMethodbuildPolicyRules
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 callersFunctioncanReserveHostnamesImpl
(store map[string]hostnameID, hostnames []string, ownerAddr sdktypes.Address, chErr chan<- error)
cluster/hostname.go:204
↓ 2 callersMethodclearFetched
()
manifest/manager.go:134
↓ 2 callersMethodcloseDeployments
()
integration/e2e_test.go:626
↓ 2 callersMethodconvertAnnotations
(ingressAnnotations map[string]string)
migrations/ingress_to_httproute.go:212
↓ 2 callersFunctioncountReservedIPs
(state *inventoryServiceState)
cluster/inventory.go:411
↓ 2 callersFunctioncreateIPPassthroughResourceName
(directive cip.ClusterIPPassthroughDirective)
cluster/kube/operators/clients/metallb/client.go:327
↓ 2 callersFunctiondetermineStatePath
(cmd *cobra.Command)
cmd/provider-services/cmd/migrate_run.go:112
↓ 2 callersMethoddoEscrowCheck
(ctx context.Context, lid mtypes.LeaseID, scheduledWithdraw bool)
balance_checker.go:122
↓ 2 callersMethoddone
()
cluster/monitor.go:69
↓ 2 callersMethoddup
()
cluster/types/v1beta3/clients/inventory/inventory.go:268
↓ 2 callersMethoddup
()
cluster/kube/operators/clients/inventory/inventory.go:29
↓ 2 callersMethodencodeSecret
()
cluster/kube/builder/service_credentials.go:89
↓ 2 callersMethodensureManager
(did dtypes.DeploymentID)
manifest/service.go:364
↓ 2 callersMethodexit
()
operator/ip/types.go:55
↓ 2 callersFunctionextractRemoteError
(response *http.Response)
cluster/kube/operators/clients/ip/client.go:155
↓ 2 callersFunctionfakeProviderHost
(hostname string, leaseID mtypes.LeaseID, serviceName string, externalPort uint32)
cluster/kube/client_test.go:45
↓ 2 callersMethodfetchAttributes
()
bidengine/provider_attributes.go:181
↓ 2 callersMethodfillAllRequests
(response error)
manifest/manager.go:326
↓ 2 callersMethodgetAnnotationInt
(annotations map[string]string, key string, defaultValue int)
migrations/ingress_to_httproute.go:252
← previousnext →301–400 of 2,680, ranked by callers