Versions in this module Expand all Collapse all v1 v1.2.5 Sep 23, 2024 Changes in this version + const NoKubeconfig + const WorkingDir + func NewPlatform() platform.Platform + type K8sOperator struct + CommonPf infracommon.CommonPlatform + Type string + func (k *K8sOperator) GetCloudletInfraResourcesInfo(ctx context.Context) ([]edgeproto.InfraResource, error) + func (k *K8sOperator) GetClusterAdditionalResourceMetric(ctx context.Context, cloudlet *edgeproto.Cloudlet, resMetric *edgeproto.Metric, ...) error + func (k *K8sOperator) GetClusterAdditionalResources(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) map[string]edgeproto.InfraResource + func (s *K8sOperator) ActiveChanged(ctx context.Context, platformActive bool) error + func (s *K8sOperator) ChangeCloudletDNS(ctx context.Context, cloudlet *edgeproto.Cloudlet, oldFqdn string, ...) error + func (s *K8sOperator) ChangeClusterInstDNS(ctx context.Context, clusterInst *edgeproto.ClusterInst, oldFqdn string, ...) error + func (s *K8sOperator) CreateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) error + func (s *K8sOperator) CreateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) (bool, error) + func (s *K8sOperator) CreateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error + func (s *K8sOperator) DeleteAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) error + func (s *K8sOperator) DeleteCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error + func (s *K8sOperator) DeleteClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error + func (s *K8sOperator) DeleteTrustPolicyException(ctx context.Context, ...) error + func (s *K8sOperator) GatherCloudletInfo(ctx context.Context, info *edgeproto.CloudletInfo) error + func (s *K8sOperator) GetAppInstRuntime(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (*edgeproto.AppInstRuntime, error) + func (s *K8sOperator) GetCloudletInfraResources(ctx context.Context) (*edgeproto.InfraResourcesSnapshot, error) + func (s *K8sOperator) GetCloudletManifest(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) (*edgeproto.CloudletManifest, error) + func (s *K8sOperator) GetClusterInfraResources(ctx context.Context, cluster *edgeproto.ClusterInst) (*edgeproto.InfraResources, error) + func (s *K8sOperator) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error) + func (s *K8sOperator) GetConsoleUrl(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst) (string, error) + func (s *K8sOperator) GetContainerCommand(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (string, error) + func (s *K8sOperator) GetFeatures() *edgeproto.PlatformFeatures + func (s *K8sOperator) GetInitHAConditionalCompatibilityVersion(ctx context.Context) string + func (s *K8sOperator) GetNodePlatformClient(ctx context.Context, node *edgeproto.CloudletMgmtNode, ops ...pc.SSHClientOp) (ssh.Client, error) + func (s *K8sOperator) GetRestrictedCloudletStatus(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error + func (s *K8sOperator) GetRootLBClients(ctx context.Context) (map[string]platform.RootLBClient, error) + func (s *K8sOperator) GetRootLBFlavor(ctx context.Context) (*edgeproto.Flavor, error) + func (s *K8sOperator) HandleFedAppInstCb(ctx context.Context, msg *edgeproto.FedAppInstEvent) + func (s *K8sOperator) InitCommon(ctx context.Context, platformConfig *platform.PlatformConfig, ...) error + func (s *K8sOperator) InitHAConditional(ctx context.Context, updateCallback edgeproto.CacheUpdateCallback) error + func (s *K8sOperator) ListCloudletMgmtNodes(ctx context.Context, clusterInsts []edgeproto.ClusterInst, ...) ([]edgeproto.CloudletMgmtNode, error) + func (s *K8sOperator) NameSanitize(name string) string + func (s *K8sOperator) PerformUpgrades(ctx context.Context, caches *platform.Caches, cloudletState dme.CloudletState) error + func (s *K8sOperator) SetPowerState(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, ...) error + func (s *K8sOperator) SetupKconf(ctx context.Context, clusterInst *edgeproto.ClusterInst) error + func (s *K8sOperator) UpdateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) error + func (s *K8sOperator) UpdateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error + func (s *K8sOperator) UpdateClusterInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) error + func (s *K8sOperator) UpdateTrustPolicy(ctx context.Context, TrustPolicy *edgeproto.TrustPolicy) error + func (s *K8sOperator) UpdateTrustPolicyException(ctx context.Context, TrustPolicyException *edgeproto.TrustPolicyException, ...) error + func (s *K8sOperator) VerifyVMs(ctx context.Context, vms []edgeproto.VM) error + func (v *K8sOperator) ChangeAppInstDNS(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, ...) error
Go to main page