MCPcopy Create free account

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

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

⨍ Functions 2,680◇ Types & classes 661
↓ 4 callersFunctionMustGatewayConfigFromCtx
(ctx context.Context)
tools/fromctx/context.go:357
↓ 4 callersFunctionMustStartupChFromCtx
(ctx context.Context)
tools/fromctx/context.go:71
↓ 4 callersFunctionNewClient
NewClient returns new Kubernetes Client instance with provided logger, host and ns. Returns error in-case of failure configPath may be the empty strin
cluster/kube/client.go:93
↓ 4 callersFunctionNewDefaultConfig
()
cluster/config.go:32
↓ 4 callersFunctionNewIgnoreList
(config IgnoreListConfig)
operator/common/ignore_list.go:39
↓ 4 callersFunctionNewIngressToHTTPRouteMigration
()
migrations/ingress_to_httproute.go:32
↓ 4 callersFunctionNewNginxGateway
NewNginxGateway creates a new NGINX Gateway Fabric provider.
cluster/kube/gateway/nginx_gateway.go:28
↓ 4 callersFunctionNewStorage
NewStorage Creates a new AccountsStorage.
tools/certissuer/storage.go:193
↓ 4 callersFunctionOpenKubeConfig
(cfgPath string, log log.Logger)
cluster/kube/clientcommon/open_kube_config.go:19
↓ 4 callersMethodPrepareAll
()
operator/common/operator_server.go:24
↓ 4 callersFunctionRecoverLeaseIDFromLabels
TODO - move to provider/cluster/util since this is generic
cluster/kube/clientcommon/recover_lease_id_from_labels.go:19
↓ 4 callersMethodSave
Save writes the migration state to the file. Creates the directory if it doesn't exist.
migrations/state.go:55
↓ 4 callersMethodStatusV1
(context.Context)
cluster/service.go:86
↓ 4 callersFunctionValidateSettings
(settings Settings)
cluster/kube/builder/settings.go:87
↓ 4 callersFunctionaddLeaseFlags
(cmd *cobra.Command)
cmd/provider-services/cmd/helpers.go:90
↓ 4 callersMethodaffinity
()
cluster/kube/builder/workload.go:290
↓ 4 callersMethodautomountServiceAccountToken
()
cluster/kube/builder/workload.go:459
↓ 4 callersMethodleaseExists
(ctx context.Context, lid mtypes.LeaseID)
cluster/kube/client.go:1217
↓ 4 callersFunctionmakeInventoryScaffold
(t *testing.T, leaseQty uint)
cluster/inventory_test.go:285
↓ 4 callersFunctionnewDeploymentMonitor
(dm *deploymentManager)
cluster/monitor.go:48
↓ 4 callersFunctionnewPreparedResult
()
operator/common/prepared_data.go:28
↓ 4 callersFunctionqueryAppWithHostname
nolint: unparam
integration/test_helpers.go:118
↓ 4 callersMethodreplicas
()
cluster/kube/builder/workload.go:283
↓ 4 callersFunctionrequestOwner
(req *http.Request)
gateway/rest/middleware.go:59
↓ 4 callersFunctionrequestProvider
(req *http.Request)
gateway/rest/middleware.go:55
↓ 4 callersFunctionrun_kubectl
(*args, ojson = True, stdin_data = None)
script/provider_migrate_to_hostname_operator.py:48
↓ 4 callersMethodruntimeClass
()
cluster/kube/builder/workload.go:267
↓ 4 callersMethodserviceAccountName
()
cluster/kube/builder/workload.go:468
↓ 4 callersFunctiontestCertHelper
(t *testing.T, test *routerTest)
gateway/rest/router_test.go:168
↓ 4 callersMethodunreserve
(order mtypes.OrderID)
cluster/inventory.go:218
↓ 3 callersMethodArchiveDomain
(string)
tools/certissuer/storage.go:87
↓ 3 callersFunctionBuildRole
BuildRole creates a new Role builder for the given workload. It uses the default PolicyRuleRegistry which includes mappings for all supported resource
cluster/kube/builder/role.go:24
↓ 3 callersMethodCanReserveHostnames
(hostnames []string, ownerAddr sdktypes.Address)
cluster/types/v1beta3/types.go:154
↓ 3 callersMethodClusterParams
()
cluster/kube/builder/builder.go:80
↓ 3 callersMethodCreateRequest
(ctx context.Context, method, path string, body io.Reader)
cluster/util/service_discovery_agent_types.go:20
↓ 3 callersMethodDeploy
(ctx context.Context, deployment ctypes.IDeployment)
cluster/client.go:65
↓ 3 callersFunctionDetectPort
(ctx context.Context, flags *flag.FlagSet, flag string, container, portName string)
operator/common/operator_flags.go:55
↓ 3 callersMethodDiscovery
()
pkg/client/clientset/versioned/clientset.go:32
↓ 3 callersFunctionErrGroupFromCtx
(ctx context.Context)
tools/fromctx/context.go:195
↓ 3 callersMethodForwardedPortStatus
(context.Context, mtypes.LeaseID)
cluster/client.go:47
↓ 3 callersMethodFromVersion
FromVersion returns the provider version this migration applies from. Migrations will only run when upgrading from a version < FromVersion. For fresh
migrations/migrations.go:22
↓ 3 callersMethodGenerateRules
GenerateRules generates all policy rules for the given permissions
cluster/kube/builder/permissions.go:85
↓ 3 callersMethodGetAccountPublicKey
(context.Context, sdk.Address)
tools/pconfig/pconfig.go:26
↓ 3 callersMethodGetAccountPublicKey
(context.Context, sdk.Address)
types/types.go:20
↓ 3 callersMethodGetClient
(ctx context.Context, isHTTPS, secure bool)
cluster/util/service_discovery_agent_types.go:15
↓ 3 callersFunctionGetEndpointQuantityOfResourceGroup
(resources dtypes.ResourceGroup, kind rtypes.Endpoint_Kind)
cluster/util/endpoint_quantity.go:8
↓ 3 callersMethodGetIPAddressStatus
(context.Context, mtypes.OrderID)
cluster/types/v1beta3/clients/ip/ip.go:72
↓ 3 callersMethodGetIPAddressUsage
(ctx context.Context)
cluster/kube/operators/clients/metallb/client.go:53
↓ 3 callersMethodGetManifestGroup
(context.Context, mtypes.LeaseID)
cluster/client.go:53
↓ 3 callersMethodGetProtocol
()
cluster/types/v1beta3/clients/ip/ip.go:39
↓ 3 callersMethodHasAny
HasAny returns true if any permissions are defined
cluster/kube/builder/permissions.go:21
↓ 3 callersMethodHostnameService
()
cluster/service.go:97
↓ 3 callersMethodInformer
()
pkg/client/informers/externalversions/generic.go:32
↓ 3 callersMethodLess
(i, j int)
tools/certissuer/lego.go:61
↓ 3 callersFunctionMakeIPSharingKey
(lID mtypes.LeaseID, endpointName string)
cluster/util/ip_sharing_key.go:16
↓ 3 callersFunctionNewDeployment
(workload *Workload)
cluster/kube/builder/deployment.go:22
↓ 3 callersFunctionNewInfo
()
version/version.go:102
↓ 3 callersFunctionNewMemory
()
tools/pconfig/memory/memory.go:40
↓ 3 callersFunctionNewPolicyRuleRegistry
NewPolicyRuleRegistry creates a new registry with default resource mappings
cluster/kube/builder/permissions.go:67
↓ 3 callersMethodPrune
()
operator/common/ignore_list.go:23
↓ 3 callersMethodReturn
(providerStatus *rest.ProviderStatus, err error)
mocks/client/StatusClient_mock.go:94
↓ 3 callersMethodReturn
(err error)
mocks/manifest/Client_mock.go:161
↓ 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:78
↓ 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:81
↓ 3 callersMethodValidate
()
cluster/kube/builder/builder.go:215
↓ 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 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 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 callersMethodgetStatusV1
(state *inventoryServiceState)
cluster/inventory.go:838
↓ 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:429
↓ 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:444
↓ 3 callersFunctionintegrationTestOnly
skip integration-only tests. using build tags breaks tooling for compilation, etc...
integration/test_helpers.go:55
↓ 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 callersFunctionmakeGroupForInventoryTest
(sharedHTTP, nodePort, leasedIP bool)
cluster/inventory_test.go:342
↓ 3 callersFunctionmakeWatchdogTestScaffold
(t *testing.T, timeout time.Duration)
manifest/watchdog_test.go:31
↓ 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 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
← previousnext →201–300 of 2,680, ranked by callers