xind

Documentation

Index

• func GetLimits(ctx context.Context, client ssh.Client, info *edgeproto.CloudletInfo) error
• func PauseContainers(ctx context.Context, client ssh.Client, names []string) error
• func UnpauseContainers(ctx context.Context, client ssh.Client, names []string) error
• func WaitClusterReady(ctx context.Context, client ssh.Client, clusterInst *edgeproto.ClusterInst, ...) error
• type ClusterManager
• type Xind
  • func (v *Xind) ChangeAppInstDNS(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, ...) error
  • func (s *Xind) ChangeCloudletDNS(ctx context.Context, cloudlet *edgeproto.Cloudlet, oldFqdn string, ...) error
  • func (s *Xind) CreateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (reterr error)
  • func (s *Xind) CreateAppInstNoPatch(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (reterr error)
  • func (s *Xind) CreateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) (bool, error)
  • func (s *Xind) DeleteAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) error
  • func (s *Xind) DeleteCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error
  • func (s *Xind) DeleteTrustPolicyException(ctx context.Context, ...) error
  • func (s *Xind) GatherCloudletInfo(ctx context.Context, info *edgeproto.CloudletInfo) error
  • func (s *Xind) GetAppInstRuntime(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (*edgeproto.AppInstRuntime, error)
  • func (s *Xind) GetClient(ctx context.Context) (ssh.Client, error)
  • func (s *Xind) GetCloudletInfraResources(ctx context.Context) (*edgeproto.InfraResourcesSnapshot, error)
  • func (s *Xind) GetCloudletManifest(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) (*edgeproto.CloudletManifest, error)
  • func (s *Xind) GetClusterAdditionalResourceMetric(ctx context.Context, cloudlet *edgeproto.Cloudlet, resMetric *edgeproto.Metric, ...) error
  • func (s *Xind) GetClusterAdditionalResources(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) map[string]edgeproto.InfraResource
  • func (s *Xind) GetClusterInfraResources(ctx context.Context, cluster *edgeproto.ClusterInst) (*edgeproto.InfraResources, error)
  • func (s *Xind) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)
  • func (s *Xind) GetConsoleUrl(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst) (string, error)
  • func (s *Xind) GetContainerCommand(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) (string, error)
  • func (s *Xind) GetFeatures() *edgeproto.PlatformFeatures
  • func (s *Xind) GetInitHAConditionalCompatibilityVersion(ctx context.Context) string
  • func (s *Xind) GetNodePlatformClient(ctx context.Context, node *edgeproto.CloudletMgmtNode, ops ...pc.SSHClientOp) (ssh.Client, error)
  • func (s *Xind) GetRestrictedCloudletStatus(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error
  • func (s *Xind) GetRootLBClients(ctx context.Context) (map[string]platform.RootLBClient, error)
  • func (s *Xind) GetRootLBFlavor(ctx context.Context) (*edgeproto.Flavor, error)
  • func (s *Xind) GetVersionProperties(ctx context.Context) map[string]string
  • func (s *Xind) HandleFedAppInstCb(ctx context.Context, msg *edgeproto.FedAppInstEvent)
  • func (s *Xind) InitCommon(ctx context.Context, platformConfig *platform.PlatformConfig, ...) error
  • func (s *Xind) InitHAConditional(ctx context.Context, updateCallback edgeproto.CacheUpdateCallback) error
  • func (s *Xind) ListCloudletMgmtNodes(ctx context.Context, clusterInsts []edgeproto.ClusterInst, ...) ([]edgeproto.CloudletMgmtNode, error)
  • func (s *Xind) NameSanitize(name string) string
  • func (s *Xind) PerformUpgrades(ctx context.Context, caches *platform.Caches, cloudletState dme.CloudletState) error
  • func (s *Xind) SetPowerState(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, ...) error
  • func (s *Xind) UpdateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, ...) error
  • func (s *Xind) UpdateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error
  • func (s *Xind) UpdateTrustPolicy(ctx context.Context, TrustPolicy *edgeproto.TrustPolicy) error
  • func (s *Xind) UpdateTrustPolicyException(ctx context.Context, TrustPolicyException *edgeproto.TrustPolicyException, ...) error
  • func (s *Xind) VerifyVMs(ctx context.Context, vms []edgeproto.VM) error

Functions

func GetLimits

func GetLimits(ctx context.Context, client ssh.Client, info *edgeproto.CloudletInfo) error

GetLimits gets CPU, Memory from the local machine

func PauseContainers

func PauseContainers(ctx context.Context, client ssh.Client, names []string) error

func UnpauseContainers

func UnpauseContainers(ctx context.Context, client ssh.Client, names []string) error

func WaitClusterReady

func WaitClusterReady(ctx context.Context, client ssh.Client, clusterInst *edgeproto.ClusterInst, timeout time.Duration) error

Types

type ClusterManager

type ClusterManager interface {
	GetMasterIp(ctx context.Context, names *k8smgmt.KubeNames) (string, error)
	GetDockerNetworkName(ctx context.Context, names *k8smgmt.KubeNames) (string, error)
}

type Xind

type Xind struct {
	Caches *platform.Caches

	PlatformType string
	// contains filtered or unexported fields
}

Common code for DIND and KIND

func (*Xind) ChangeAppInstDNS

func (v *Xind) ChangeAppInstDNS(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, OldURI string, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) ChangeCloudletDNS

func (s *Xind) ChangeCloudletDNS(ctx context.Context, cloudlet *edgeproto.Cloudlet, oldFqdn string, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) CreateAppInst

func (s *Xind) CreateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst, flavor *edgeproto.Flavor, updateSender edgeproto.AppInstInfoSender) (reterr error)

func (*Xind) CreateAppInstNoPatch

func (s *Xind) CreateAppInstNoPatch(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst, flavor *edgeproto.Flavor, updateSender edgeproto.AppInstInfoSender) (reterr error)

func (*Xind) CreateCloudlet

func (s *Xind) CreateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, pfInitConfig *platform.PlatformInitConfig, flavor *edgeproto.Flavor, caches *platform.Caches, updateCallback edgeproto.CacheUpdateCallback) (bool, error)

func (*Xind) DeleteAppInst

func (s *Xind) DeleteAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) DeleteCloudlet

func (s *Xind) DeleteCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, pfInitConfig *platform.PlatformInitConfig, caches *platform.Caches, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) DeleteTrustPolicyException

func (s *Xind) DeleteTrustPolicyException(ctx context.Context, TrustPolicyExceptionKey *edgeproto.TrustPolicyExceptionKey, clusterKey *edgeproto.ClusterKey) error

func (*Xind) GatherCloudletInfo

func (s *Xind) GatherCloudletInfo(ctx context.Context, info *edgeproto.CloudletInfo) error

func (*Xind) GetAppInstRuntime

func (s *Xind) GetAppInstRuntime(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst) (*edgeproto.AppInstRuntime, error)

func (*Xind) GetClient

func (s *Xind) GetClient(ctx context.Context) (ssh.Client, error)

func (*Xind) GetCloudletInfraResources

func (s *Xind) GetCloudletInfraResources(ctx context.Context) (*edgeproto.InfraResourcesSnapshot, error)

func (*Xind) GetCloudletManifest

func (s *Xind) GetCloudletManifest(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, pfInitConfig *platform.PlatformInitConfig, accessApi platform.AccessApi, flavor *edgeproto.Flavor, caches *platform.Caches) (*edgeproto.CloudletManifest, error)

func (*Xind) GetClusterAdditionalResourceMetric

func (s *Xind) GetClusterAdditionalResourceMetric(ctx context.Context, cloudlet *edgeproto.Cloudlet, resMetric *edgeproto.Metric, resources []edgeproto.VMResource) error

func (*Xind) GetClusterAdditionalResources

func (s *Xind) GetClusterAdditionalResources(ctx context.Context, cloudlet *edgeproto.Cloudlet, vmResources []edgeproto.VMResource, infraResMap map[string]edgeproto.InfraResource) map[string]edgeproto.InfraResource

func (*Xind) GetClusterInfraResources

func (s *Xind) GetClusterInfraResources(ctx context.Context, cluster *edgeproto.ClusterInst) (*edgeproto.InfraResources, error)

func (*Xind) GetClusterPlatformClient

func (s *Xind) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)

func (*Xind) GetConsoleUrl

func (s *Xind) GetConsoleUrl(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst) (string, error)

func (*Xind) GetContainerCommand

func (s *Xind) GetContainerCommand(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst, req *edgeproto.ExecRequest) (string, error)

func (*Xind) GetFeatures

func (s *Xind) GetFeatures() *edgeproto.PlatformFeatures

func (*Xind) GetInitHAConditionalCompatibilityVersion

func (s *Xind) GetInitHAConditionalCompatibilityVersion(ctx context.Context) string

func (*Xind) GetNodePlatformClient

func (s *Xind) GetNodePlatformClient(ctx context.Context, node *edgeproto.CloudletMgmtNode, ops ...pc.SSHClientOp) (ssh.Client, error)

func (*Xind) GetRestrictedCloudletStatus

func (s *Xind) GetRestrictedCloudletStatus(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, accessApi platform.AccessApi, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) GetRootLBClients

func (s *Xind) GetRootLBClients(ctx context.Context) (map[string]platform.RootLBClient, error)

func (*Xind) GetRootLBFlavor

func (s *Xind) GetRootLBFlavor(ctx context.Context) (*edgeproto.Flavor, error)

func (*Xind) GetVersionProperties

func (s *Xind) GetVersionProperties(ctx context.Context) map[string]string

func (*Xind) HandleFedAppInstCb

func (s *Xind) HandleFedAppInstCb(ctx context.Context, msg *edgeproto.FedAppInstEvent)

func (*Xind) InitCommon

func (s *Xind) InitCommon(ctx context.Context, platformConfig *platform.PlatformConfig, caches *platform.Caches, clusterManager ClusterManager, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) InitHAConditional

func (s *Xind) InitHAConditional(ctx context.Context, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) ListCloudletMgmtNodes

func (s *Xind) ListCloudletMgmtNodes(ctx context.Context, clusterInsts []edgeproto.ClusterInst, vmAppInsts []edgeproto.AppInst) ([]edgeproto.CloudletMgmtNode, error)

func (*Xind) NameSanitize

func (s *Xind) NameSanitize(name string) string

func (*Xind) PerformUpgrades

func (s *Xind) PerformUpgrades(ctx context.Context, caches *platform.Caches, cloudletState dme.CloudletState) error

func (*Xind) SetPowerState

func (s *Xind) SetPowerState(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) UpdateAppInst

func (s *Xind) UpdateAppInst(ctx context.Context, clusterInst *edgeproto.ClusterInst, app *edgeproto.App, appInst *edgeproto.AppInst, flavor *edgeproto.Flavor, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) UpdateCloudlet

func (s *Xind) UpdateCloudlet(ctx context.Context, cloudlet *edgeproto.Cloudlet, updateCallback edgeproto.CacheUpdateCallback) error

func (*Xind) UpdateTrustPolicy

func (s *Xind) UpdateTrustPolicy(ctx context.Context, TrustPolicy *edgeproto.TrustPolicy) error

func (*Xind) UpdateTrustPolicyException

func (s *Xind) UpdateTrustPolicyException(ctx context.Context, TrustPolicyException *edgeproto.TrustPolicyException, clusterKey *edgeproto.ClusterKey) error

func (*Xind) VerifyVMs

func (s *Xind) VerifyVMs(ctx context.Context, vms []edgeproto.VM) error