Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/akash-network/provider
/ functions
Functions
2,992 in github.com/akash-network/provider
⨍
Functions
2,992
◇
Types & classes
704
↓ 3 callers
Method
Informer
()
pkg/client/informers/externalversions/generic.go:32
↓ 3 callers
Method
Less
(i, j int)
tools/certissuer/lego.go:61
↓ 3 callers
Function
MakeIPSharingKey
(lID mtypes.LeaseID, endpointName string)
cluster/util/ip_sharing_key.go:16
↓ 3 callers
Function
ManifestSubmitErrorToHTTP
ManifestSubmitErrorToHTTP maps manifest submit errors to HttpError for gateway responses.
manifest/gateway.go:13
↓ 3 callers
Function
NewInfo
()
version/version.go:102
↓ 3 callers
Function
NewMemory
()
tools/pconfig/memory/memory.go:40
↓ 3 callers
Function
NewPolicyRuleRegistry
NewPolicyRuleRegistry creates a new registry with default resource mappings
cluster/kube/builder/permissions.go:67
↓ 3 callers
Method
Prune
()
operator/common/ignore_list.go:23
↓ 3 callers
Method
Return
(providerStatus *rest.ProviderStatus, err error)
mocks/client/StatusClient_mock.go:94
↓ 3 callers
Method
Return
(err error)
mocks/manifest/Client_mock.go:161
↓ 3 callers
Method
Return
(manifestStatus *rest.ManifestStatus, err error)
mocks/manifest/StatusClient_mock.go:94
↓ 3 callers
Method
Return
(reservation v1beta3.Reservation, err error)
mocks/cluster/Cluster_mock.go:99
↓ 3 callers
Method
SendEvent
(*eventsv1.Event)
cluster/types/v1beta3/types.go:213
↓ 3 callers
Method
SetClusterParams
(interface{})
cluster/types/v1beta3/reservation.go:12
↓ 3 callers
Function
SetKubeConfigToCmd
(c *cobra.Command)
cluster/kube/clientcommon/open_kube_config.go:50
↓ 3 callers
Method
Snapshot
()
cluster/types/v1beta3/types.go:205
↓ 3 callers
Method
WithGPU
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 callers
Method
WithGSeq
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 callers
Method
WithLeaseID
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 callers
Method
WithOSeq
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 callers
Function
WithSNP
()
cluster/types/v1beta3/types.go:120
↓ 3 callers
Function
WithTDX
()
cluster/types/v1beta3/types.go:124
↓ 3 callers
Function
addCmdFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:59
↓ 3 callers
Function
addServiceFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:98
↓ 3 callers
Function
cleanupStaleRBACResources
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 callers
Function
cleanupStaleResources
(ctx context.Context, kc kubernetes.Interface, lid mtypes.LeaseID, group *mani.Group, servicesWithPermissions
cluster/kube/cleanup.go:17
↓ 3 callers
Function
clusterErrorToHTTP
(err error)
gateway/rest/cluster_errors.go:13
↓ 3 callers
Function
decNearly
(t *testing.T, v sdkmath.LegacyDec, expected int64)
bidengine/pricing_test.go:231
↓ 3 callers
Function
defaultGroupSpecCPUMem
()
bidengine/pricing_test.go:63
↓ 3 callers
Function
dpQuery
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:111
↓ 3 callers
Function
generateTestFiles
(t *testing.T, dir, domain string)
tools/certissuer/storage_test.go:142
↓ 3 callers
Function
getStateKey
(leaseID mtypes.LeaseID, sharingKey string, externalPort uint32)
operator/ip/operator.go:284
↓ 3 callers
Method
getWorkloadPermissions
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:672
↓ 3 callers
Method
hasPermissions
hasPermissions returns true if any permissions are defined for this workload. This checks all permission types (read, write, delete).
cluster/kube/builder/workload.go:687
↓ 3 callers
Function
integrationTestOnly
skip integration-only tests. using build tags breaks tooling for compilation, etc...
integration/test_helpers.go:55
↓ 3 callers
Function
jsonLogValue
(value interface{})
operator/inventory/diagnostics.go:50
↓ 3 callers
Function
kubeSelectorForLease
(dst *strings.Builder, lID mtypes.LeaseID)
operator/ip/operator.go:916
↓ 3 callers
Function
leasesForDeployment
(ctx context.Context, cctx sdkclient.Context, flags *pflag.FlagSet, cl aclient.QueryClient)
cmd/provider-services/cmd/helpers.go:156
↓ 3 callers
Function
logValues
(values []interface{})
operator/inventory/node-discovery_test.go:64
↓ 3 callers
Function
makeGroupForInventoryTest
(sharedHTTP, nodePort, leasedIP bool)
cluster/inventory_test.go:365
↓ 3 callers
Function
makeWatchdogTestScaffold
(t *testing.T, timeout time.Duration)
manifest/watchdog_test.go:35
↓ 3 callers
Function
makeWatchdogTestScaffoldFull
(t *testing.T, timeout, broadcastTimeout time.Duration, blockUntilRelease <-chan struct{})
manifest/watchdog_test.go:43
↓ 3 callers
Function
mockManifestGroupsForRouterTest
(rt *routerTest, leaseID mtypes.LeaseID)
gateway/rest/router_test.go:567
↓ 3 callers
Function
newFakeDC
()
cluster/kube/gateway/httproute_test.go:25
↓ 3 callers
Method
newRequest
(ctx context.Context, method string, path string, body io.Reader)
cluster/kube/operators/clients/ip/client.go:84
↓ 3 callers
Function
providerFromFlags
(flags *pflag.FlagSet)
cmd/provider-services/cmd/helpers.go:143
↓ 3 callers
Function
queryWithBody
(val []byte)
integration/test_helpers.go:45
↓ 3 callers
Function
routeConfig
()
cluster/kube/gateway/httproute_test.go:70
↓ 3 callers
Function
routeDirective
()
cluster/kube/gateway/httproute_test.go:60
↓ 3 callers
Function
sanitizedDomain
sanitizedDomain Make sure no funny chars are in the cert names (like wildcards ;)).
tools/certissuer/storage.go:653
↓ 3 callers
Function
sparamsInterconnect
sparamsInterconnect pulls the per-service interconnect scheduler params off a nullable SchedulerParams chain. Returns nil when the service has no inte
cluster/kube/builder/workload.go:662
↓ 3 callers
Method
stop
()
manifest/manager.go:97
↓ 3 callers
Method
stopMonitor
()
cluster/manager.go:265
↓ 3 callers
Function
subStorageAllocatedResource
( log logr.Logger, driver string, class string, persistentVolume string, persistentVolumeID string, allo
operator/inventory/diagnostics.go:59
↓ 3 callers
Function
testDirective
()
cluster/kube/gateway/nginx_gateway_test.go:15
↓ 3 callers
Function
updateNodeInfo
(knode *corev1.Node, node *v1.Node, interconnectPatterns []string)
operator/inventory/node-discovery.go:867
↓ 3 callers
Function
websocketCloseCodeFrom
(err error)
gateway/rest/router.go:72
↓ 2 callers
Function
AccountQuerierFromCtx
(ctx context.Context)
tools/fromctx/context.go:283
↓ 2 callers
Function
AddIgnoreListFlags
(cmd *cobra.Command)
operator/common/ignore_list_config.go:31
↓ 2 callers
Function
AddOperatorFlags
(cmd *cobra.Command)
operator/common/operator_flags.go:26
↓ 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:90
↓ 2 callers
Function
BuildRoleBinding
BuildRoleBinding creates a new RoleBinding builder for the given workload.
cluster/kube/builder/rolebinding.go:29
↓ 2 callers
Method
BuildRouteExtensions
BuildRouteExtensions returns auxiliary CRD objects to apply alongside the HTTPRoute (e.g. an NGF SnippetsFilter). They are applied owner-referenced to
cluster/kube/gateway/gateway.go:39
↓ 2 callers
Function
BuildServiceAccount
(workload *Workload)
cluster/kube/builder/serviceaccount.go:20
↓ 2 callers
Function
BuildStatefulSet
(workload *Workload)
cluster/kube/builder/statefulset.go:22
↓ 2 callers
Method
Close
()
tools/certissuer/lego.go:36
↓ 2 callers
Function
ClusterDeploymentFromDeployment
(d ctypes.IDeployment)
cluster/kube/builder/builder.go:146
↓ 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
Method
Create
()
cluster/kube/builder/deployment.go:12
↓ 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:279
↓ 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:112
↓ 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
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
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
Method
GetQuote
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 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:188
↓ 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:318
↓ 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
← previous
next →
301–400 of 2,992, ranked by callers