Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const ClusterAgentCR + const ClusterAgentCRB + const ClusterAgentSA + const ErdaOrgLabel + const KubeconfigType + const ModuleClusterOps + const ProxyType + const SAType + var ProxyDeployTemplate = ... + func ParseKubeconfig(kubeconfig []byte) (*clusterpb.ManageConfig, error) + func ParseManageConfigFromCredential(credentialType string, credential apistructs.ICCredential) (*clusterpb.ManageConfig, error) + func ParseSecretes(address string, secret []byte) (*clusterpb.ManageConfig, error) + type Clusters struct + func New(db *dbclient.DBClient, bdl *bundle.Bundle, c tokenpb.TokenServiceServer, ...) *Clusters + func (c *Clusters) AddClusters(ctx context.Context, req apistructs.CloudClusterRequest, userid string) (uint64, error) + func (c *Clusters) BatchOfflineEdgeCluster(ctx context.Context, req apistructs.BatchOfflineEdgeClusterRequest, ...) error + func (c *Clusters) BatchUpgradeEdgeCluster(ctx context.Context, req apistructs.BatchUpgradeEdgeClusterRequest, ...) + func (c *Clusters) CheckCluster(ctx context.Context, clusterName string) error + 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) DeleteAccessKey(clusterName string) error + func (c *Clusters) GetAccessKey(clusterName string) (*tokenpb.QueryTokensResponse, error) + func (c *Clusters) GetOrCreateAccessKey(ctx context.Context, clusterName string) (*tokenpb.Token, error) + func (c *Clusters) GetOrCreateAccessKeyWithRecord(ctx context.Context, clusterName, userID, orgID string) (*tokenpb.Token, error) + func (c *Clusters) GetOrgClusterInfo(ctx context.Context, req apistructs.OrgClusterInfoRequest) (apistructs.OrgClusterInfoData, error) + func (c *Clusters) GetOrgInfo(req *orgpb.ListOrgRequest) (map[uint64]*orgpb.Org, error) + func (c *Clusters) ImportClusterWithRecord(ctx context.Context, userID string, req *apistructs.ImportCluster) error + func (c *Clusters) ListClusters(ctx context.Context, req apistructs.OrgClusterInfoRequest) (result []apistructs.OrgClusterInfoBasicData, err error) + func (c *Clusters) MonitorCloudCluster() (abort bool, err error) + func (c *Clusters) OfflineEdgeCluster(ctx context.Context, req apistructs.OfflineEdgeClusterRequest, userid string, ...) (recordID uint64, preCheckHint string, err error) + func (c *Clusters) RenderInitCmd(orgName, clusterName string) (string, error) + func (c *Clusters) RenderInitContent(ctx context.Context, orgName, clusterName string, accessKey string) (string, error) + func (c *Clusters) ResetAccessKey(ctx context.Context, clusterName string) (*tokenpb.Token, error) + func (c *Clusters) ResetAccessKeyWithClientSet(ctx context.Context, clusterName string, cs kubernetes.Interface) (*tokenpb.Token, error) + func (c *Clusters) ResetAccessKeyWithRecord(ctx context.Context, clusterName, userID, orgID string) (*tokenpb.Token, error) + func (c *Clusters) UpdateCluster(ctx context.Context, req apistructs.CMPClusterUpdateRequest, ...) error + func (c *Clusters) UpdateClusterVersion(req []apistructs.OrgClusterInfoBasicData) error + func (c *Clusters) UpgradeEdgeCluster(ctx context.Context, req apistructs.UpgradeEdgeClusterRequest, userid string, ...) (recordID uint64, status int, precheckHint string, err error) + type RenderDeploy struct + Envs []corev1.EnvVar + ErdaNamespace string + JobImage string + type ResultType = map[string]map[string]apistructs.NameValue
Go to main page