clusters

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 6, 2022 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

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

	ModuleClusterOps = "cluster-ops"
	ClusterAgentSA   = "cluster-agent"
	ClusterAgentCR   = "cluster-agent-cr"
	ClusterAgentCRB  = "cluster-agent-crb"
	ErdaOrgLabel     = "dice/org-%s"
)

Variables

View Source
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 (*Clusters) AddClusters

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

func (*Clusters) BatchOfflineEdgeCluster added in v1.5.0

func (c *Clusters) BatchOfflineEdgeCluster(req apistructs.BatchOfflineEdgeClusterRequest, userid string) error

func (*Clusters) BatchUpgradeEdgeCluster

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

func (*Clusters) CheckCluster added in v1.4.0

func (c *Clusters) CheckCluster(clusterName string) error

CheckCluster check cluster

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 (*Clusters) DeleteAccessKey added in v1.4.0

func (c *Clusters) DeleteAccessKey(clusterName string) error

DeleteAccessKey Delete access key

func (*Clusters) GetAccessKey added in v1.4.0

func (c *Clusters) GetAccessKey(clusterName string) (*credentialpb.QueryAccessKeysResponse, error)

GetAccessKey get access key with cluster name.

func (*Clusters) GetOrCreateAccessKey added in v1.4.0

func (c *Clusters) GetOrCreateAccessKey(clusterName string) (*credentialpb.AccessKeysItem, error)

GetOrCreateAccessKey get or create access key

func (*Clusters) GetOrCreateAccessKeyWithRecord added in v1.4.0

func (c *Clusters) GetOrCreateAccessKeyWithRecord(clusterName, userID, orgID string) (*credentialpb.AccessKeysItem, error)

GetOrCreateAccessKeyWithRecord get or create access key with record

func (*Clusters) GetOrgClusterInfo

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 (*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) ResetAccessKey added in v1.4.0

func (c *Clusters) ResetAccessKey(clusterName string) (*credentialpb.AccessKeysItem, error)

ResetAccessKey reset access key

func (*Clusters) ResetAccessKeyWithClientSet added in v1.4.0

func (c *Clusters) ResetAccessKeyWithClientSet(clusterName string, cs *kubernetes.Clientset) (*credentialpb.AccessKeysItem, error)

ResetAccessKeyWithClientSet reset access key with specified clientSet

func (*Clusters) ResetAccessKeyWithRecord added in v1.4.0

func (c *Clusters) ResetAccessKeyWithRecord(clusterName, userID, orgID string) (*credentialpb.AccessKeysItem, error)

ResetAccessKeyWithRecord reset ak with record

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
}

type ResultType added in v1.3.0

type ResultType = map[string]map[string]apistructs.NameValue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL