clusters

Documentation

Index

• Constants
• Variables
• func ParseKubeconfig(kubeconfig []byte) (*apistructs.ManageConfig, error)
• func ParseManageConfigFromCredential(credentialType string, credential apistructs.ICCredential) (*apistructs.ManageConfig, error)
• func ParseSecretes(address string, secret []byte) (*apistructs.ManageConfig, error)
• type Clusters
  • func New(db *dbclient.DBClient, bdl *bundle.Bundle) *Clusters
  • func (c *Clusters) AddClusters(req apistructs.CloudClusterRequest, userid string) (uint64, error)
  • func (c *Clusters) BatchUpgradeEdgeCluster(req apistructs.BatchUpgradeEdgeClusterRequest, userid string)
  • func (c *Clusters) ClusterInfo(ctx context.Context, orgID uint64, clusterNames []string) ([]map[string]map[string]apistructs.NameValue, error)
  • func (c *Clusters) ClusterInitRetry(orgID uint64, req *apistructs.ClusterInitRetry) error
  • func (c *Clusters) ClusterPreview(req apistructs.CloudClusterRequest) ([]apistructs.CloudResource, error)
  • func (c *Clusters) GetOrgClusterInfo(req apistructs.OrgClusterInfoRequest) (apistructs.OrgClusterInfoData, error)
  • func (c *Clusters) GetOrgInfo(req *apistructs.OrgSearchRequest) (map[uint64]apistructs.OrgDTO, error)
  • func (c *Clusters) ImportClusterWithRecord(userID string, req *apistructs.ImportCluster) error
  • func (c *Clusters) ListClusters(req apistructs.OrgClusterInfoRequest) (result []apistructs.OrgClusterInfoBasicData, err error)
  • func (c *Clusters) MonitorCloudCluster() (abort bool, err error)
  • func (c *Clusters) OfflineEdgeCluster(req apistructs.OfflineEdgeClusterRequest, userid string, orgid string) (uint64, error)
  • func (c *Clusters) RenderInitCmd(orgName, clusterName string) (string, error)
  • func (c *Clusters) RenderInitContent(orgName, clusterName string, accessKey string) (string, error)
  • func (c *Clusters) UpdateCluster(req apistructs.CMPClusterUpdateRequest, header http.Header) error
  • func (c *Clusters) UpdateClusterVersion(req []apistructs.OrgClusterInfoBasicData) error
  • func (c *Clusters) UpgradeEdgeCluster(req apistructs.UpgradeEdgeClusterRequest, userid string, orgid string) (recordID uint64, status int, precheckHint string, err error)
• type RenderDeploy

Constants

const (
	KubeconfigType = "KUBECONFIG"
	SAType         = "SERVICEACCOUNT"
	ProxyType      = "PROXY"

	ModuleClusterOps = "cluster-ops"
	ClusterAgentSA   = "cluster-agent"
	ClusterAgentCR   = "cluster-agent-cr"
	ClusterAgentCRB  = "cluster-agent-crb"
)

Variables

var ProxyDeployTemplate = `` /* 1390-byte string literal not displayed */

Functions

func ParseKubeconfig

func ParseKubeconfig(kubeconfig []byte) (*apistructs.ManageConfig, error)

ParseKubeconfig parse kubeconfig to manage config

func ParseManageConfigFromCredential

func ParseManageConfigFromCredential(credentialType string, credential apistructs.ICCredential) (*apistructs.ManageConfig, error)

func ParseSecretes

func ParseSecretes(address string, secret []byte) (*apistructs.ManageConfig, error)

Types

type Clusters

type Clusters struct {
	// contains filtered or unexported fields
}

func New

func New(db *dbclient.DBClient, bdl *bundle.Bundle) *Clusters

func (*Clusters) AddClusters

func (c *Clusters) AddClusters(req apistructs.CloudClusterRequest, userid string) (uint64, error)

func (*Clusters) BatchUpgradeEdgeCluster

func (c *Clusters) BatchUpgradeEdgeCluster(req apistructs.BatchUpgradeEdgeClusterRequest, userid string)

func (*Clusters) ClusterInfo

func (c *Clusters) ClusterInfo(ctx context.Context, orgID uint64, clusterNames []string) ([]map[string]map[string]apistructs.NameValue, error)

func (*Clusters) ClusterInitRetry

func (c *Clusters) ClusterInitRetry(orgID uint64, req *apistructs.ClusterInitRetry) error

func (*Clusters) ClusterPreview

func (c *Clusters) ClusterPreview(req apistructs.CloudClusterRequest) ([]apistructs.CloudResource, error)

func (*Clusters) GetOrgClusterInfo

func (c *Clusters) GetOrgClusterInfo(req apistructs.OrgClusterInfoRequest) (apistructs.OrgClusterInfoData, error)

func (*Clusters) GetOrgInfo

func (c *Clusters) GetOrgInfo(req *apistructs.OrgSearchRequest) (map[uint64]apistructs.OrgDTO, error)

func (*Clusters) ImportClusterWithRecord

func (c *Clusters) ImportClusterWithRecord(userID string, req *apistructs.ImportCluster) error

ImportClusterWithRecord import cluster with record

func (*Clusters) ListClusters

func (c *Clusters) ListClusters(req apistructs.OrgClusterInfoRequest) (result []apistructs.OrgClusterInfoBasicData, err error)

func (*Clusters) MonitorCloudCluster

func (c *Clusters) MonitorCloudCluster() (abort bool, err error)

func (*Clusters) OfflineEdgeCluster

func (c *Clusters) OfflineEdgeCluster(req apistructs.OfflineEdgeClusterRequest, userid string, orgid string) (uint64, error)

func (*Clusters) RenderInitCmd

func (c *Clusters) RenderInitCmd(orgName, clusterName string) (string, error)

func (*Clusters) RenderInitContent

func (c *Clusters) RenderInitContent(orgName, clusterName string, accessKey string) (string, error)

func (*Clusters) UpdateCluster

func (c *Clusters) UpdateCluster(req apistructs.CMPClusterUpdateRequest, header http.Header) error

func (*Clusters) UpdateClusterVersion

func (c *Clusters) UpdateClusterVersion(req []apistructs.OrgClusterInfoBasicData) error

func (*Clusters) UpgradeEdgeCluster

func (c *Clusters) UpgradeEdgeCluster(req apistructs.UpgradeEdgeClusterRequest, userid string, orgid string) (recordID uint64, status int, precheckHint string, err error)

status:

1 -- in processing, jump to check log
2 -- do precheck
3 -- invalid, do not support (non k8s cluster, central cluster, higher version ecluster)

type RenderDeploy

type RenderDeploy struct {
	ErdaNamespace string
	JobImage      string
	Envs          []corev1.EnvVar
}