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 New 

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

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 (c *Clusters) ClusterPreview(req apistructs.CloudClusterRequest) ([]apistructs.CloudResource, error)

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 (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) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.