MCPcopy Create free account

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

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

↓ 3 callersMethodReturn
(manifestStatus *rest.ManifestStatus, err error)
mocks/manifest/StatusClient_mock.go:94
↓ 3 callersMethodReturn
(reservation v1beta3.Reservation, err error)
mocks/cluster/Cluster_mock.go:99
↓ 3 callersMethodSendEvent
(*eventsv1.Event)
cluster/types/v1beta3/types.go:213
↓ 3 callersMethodSetClusterParams
(interface{})
cluster/types/v1beta3/reservation.go:12
↓ 3 callersFunctionSetKubeConfigToCmd
(c *cobra.Command)
cluster/kube/clientcommon/open_kube_config.go:50
↓ 3 callersMethodSetResourceVersion
(string)
cluster/kube/builder/builder.go:122
↓ 3 callersMethodSnapshot
()
cluster/types/v1beta3/types.go:205
↓ 3 callersMethodWithGPU
WithGPU sets the GPU field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "Wit
pkg/client/applyconfiguration/akash.network/v2beta2/resources.go:60
↓ 3 callersMethodWithGSeq
WithGSeq sets the GSeq 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/leaseid.go:56
↓ 3 callersMethodWithLeaseID
WithLeaseID sets the LeaseID field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chain
pkg/client/applyconfiguration/akash.network/v2beta2/manifestspec.go:37
↓ 3 callersMethodWithOSeq
WithOSeq sets the OSeq 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/leaseid.go:64
↓ 3 callersFunctionWithSNP
()
cluster/types/v1beta3/types.go:120
↓ 3 callersFunctionWithTDX
()
cluster/types/v1beta3/types.go:124
↓ 3 callersFunctionaddCmdFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:59
↓ 3 callersFunctionaddServiceFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:98
↓ 3 callersFunctioncleanupStaleRBACResources
cleanupStaleRBACResources removes ServiceAccounts, Roles, and RoleBindings that belong to services that no longer have permissions in the current mani
cluster/kube/cleanup.go:82
↓ 3 callersFunctioncleanupStaleResources
(ctx context.Context, kc kubernetes.Interface, lid mtypes.LeaseID, group *mani.Group, servicesWithPermissions
cluster/kube/cleanup.go:17
↓ 3 callersFunctionclusterErrorToHTTP
(err error)
gateway/rest/cluster_errors.go:13
↓ 3 callersFunctiondecNearly
(t *testing.T, v sdkmath.LegacyDec, expected int64)
bidengine/pricing_test.go:231
↓ 3 callersFunctiondefaultGroupSpecCPUMem
()
bidengine/pricing_test.go:63
↓ 3 callersFunctiondpQuery
dpQuery sends one typed read request to the per-node psutil API connector and waits for the response, honoring the caller's context, the discovery lif
operator/inventory/node-discovery.go:99
↓ 3 callersFunctiongenerateTestFiles
(t *testing.T, dir, domain string)
tools/certissuer/storage_test.go:142
↓ 3 callersFunctiongetStateKey
(leaseID mtypes.LeaseID, sharingKey string, externalPort uint32)
operator/ip/operator.go:284
↓ 3 callersMethodgetWorkloadPermissions
getWorkloadPermissions extracts all permission types from the service params and returns them as a WorkloadPermissions struct. NOTE: Currently only Re
cluster/kube/builder/workload.go:643
↓ 3 callersMethodhasPermissions
hasPermissions returns true if any permissions are defined for this workload. This checks all permission types (read, write, delete).
cluster/kube/builder/workload.go:658
↓ 3 callersFunctionintegrationTestOnly
skip integration-only tests. using build tags breaks tooling for compilation, etc...
integration/test_helpers.go:55
↓ 3 callersFunctionjsonLogValue
(value interface{})
operator/inventory/diagnostics.go:50
↓ 3 callersFunctionkubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
operator/ip/operator.go:916
↓ 3 callersFunctionleasesForDeployment
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet, cl aclient.QueryClient)
cmd/provider-services/cmd/helpers.go:156
↓ 3 callersFunctionlogValues
(values []interface{})
operator/inventory/node-discovery_test.go:64
↓ 3 callersFunctionmakeGroupForInventoryTest
(sharedHTTP, nodePort, leasedIP bool)
cluster/inventory_test.go:365
↓ 3 callersFunctionmakeWatchdogTestScaffold
(t *testing.T, timeout time.Duration)
manifest/watchdog_test.go:35
↓ 3 callersFunctionmakeWatchdogTestScaffoldFull
(t *testing.T, timeout, broadcastTimeout time.Duration, blockUntilRelease <-chan struct{})
manifest/watchdog_test.go:43
↓ 3 callersFunctionmockManifestGroupsForRouterTest
(rt *routerTest, leaseID mtypes.LeaseID)
gateway/rest/router_test.go:567
↓ 3 callersMethodnewRequest
(ctx context.Context, method string, path string, body io.Reader)
cluster/kube/operators/clients/ip/client.go:84
↓ 3 callersFunctionproviderFromFlags
(flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:143
↓ 3 callersFunctionqueryWithBody
(val []byte)
integration/test_helpers.go:45
↓ 3 callersFunctionsanitizedDomain
sanitizedDomain Make sure no funny chars are in the cert names (like wildcards ;)).
tools/certissuer/storage.go:653
↓ 3 callersMethodstop
()
manifest/manager.go:97
↓ 3 callersMethodstopMonitor
()
cluster/manager.go:265
↓ 3 callersFunctionsubStorageAllocatedResource
( log logr.Logger, driver string, class string, persistentVolume string, persistentVolumeID string, allo
operator/inventory/diagnostics.go:59
↓ 3 callersFunctionupdateNodeInfo
(knode *corev1.Node, node *v1.Node, interconnectPatterns []string)
operator/inventory/node-discovery.go:843
↓ 3 callersFunctionwebsocketCloseCodeFrom
(err error)
gateway/rest/router.go:72
↓ 2 callersFunctionAccountQuerierFromCtx
(ctx context.Context)
tools/fromctx/context.go:283
↓ 2 callersFunctionAddIgnoreListFlags
(cmd *cobra.Command)
operator/common/ignore_list_config.go:31
↓ 2 callersFunctionAddOperatorFlags
(cmd *cobra.Command)
operator/common/operator_flags.go:26
↓ 2 callersFunctionAllHostnamesOfManifestGroup
(mgroup manitypes.Group)
manifest/parse.go:13
↓ 2 callersFunctionAuthProcess
(ctx context.Context, peerCerts []*x509.Certificate, token string)
gateway/utils/utils.go:90
↓ 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 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:112
↓ 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 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 callersMethodGetQuote
GetQuote collects a hardware-signed attestation report with the given report_data (typically the tenant's nonce, or a hash binding the nonce to additi
sidecar/attestation/tee/tee.go:43
↓ 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:188
↓ 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:318
↓ 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 callersMethodListenAndServeTLS
ListenAndServeTLS starts the webhook HTTPS server.
cluster/kube/webhook/webhook.go:69
↓ 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:34
↓ 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 callersFunctionNewManifest
NewManifest creates new manifest with provided details. Returns error in case of failure.
pkg/apis/akash.network/v2beta2/manifest.go:174
↓ 2 callersFunctionNewRemotePodCommandExecutor
(restcfg *rest.Config, clientset kubernetes.Interface)
operator/inventory/types.go:181
↓ 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
← previousnext →301–400 of 2,942, ranked by callers