Versions in this module Expand all Collapse all v1 v1.0.2 Mar 7, 2023 Changes in this version + const KubeadmConfigTemplate + const MachineDeployment + const VCDMachineTemplate + var ControlPlaneLabel = "node-role.kubernetes.io/control-plane" + var ResourceExisted = errors.New("[REX] resource is already existed") + var ResourceNameNull = errors.New("[RNN] resource name is null") + var ResourceNotFound = errors.New("[RNF] resource is not found") + func CreateNewKubeadmConfigTemplate(ctx context.Context, client *vcdsdk.Client, clusterId string, ...) (map[string]interface{}, error) + func CreateNewMachineDeployment(ctx context.Context, client *vcdsdk.Client, clusterId string, ...) (map[string]interface{}, error) + func CreateNewVCDMachineTemplate(ctx context.Context, client *vcdsdk.Client, clusterId string, ...) (map[string]interface{}, error) + func GetCapvcdYamlFromRde(capvcdRDE swagger.DefinedEntity) (string, error) + func GetComponentMapInStatus(ctx context.Context, client *vcdsdk.Client, clusterId, componentName string) (map[string]interface{}, error) + func GetKubeconfigFromRDEId(ctx context.Context, client *vcdsdk.Client, clusterId string) (string, error) + func GetMapBySpecName(specMap map[string]interface{}, specName string, sectionName string) (map[string]interface{}, error) + func GetVCDResourceSet(ctx context.Context, client *vcdsdk.Client, clusterId, componentName string) ([]vcdsdk.VCDResource, error) + func IsRetryableError(err error) bool + type ContainerParams struct + Args []string + ContainerImage string + ContainerName string + ContainerPort int32 + type DeployParams struct + ContainerParams ContainerParams + Labels map[string]string + Name string + VolumeParams VolumeParams + type Set struct + func NewSet() *Set + func (s *Set) Add(value interface{}) + func (s *Set) Contains(value interface{}) bool + func (s *Set) Size() int + type TestClient struct + ClusterId string + ClusterName string + Cs kubernetes.Interface + VcdClient *vcdsdk.Client + func NewTestClient(params *VCDAuthParams, clusterId string) (*TestClient, error) + func (tc *TestClient) CreateDeployment(ctx context.Context, params *DeployParams, nameSpace string) (*appsv1.Deployment, error) + func (tc *TestClient) CreateLoadBalancerService(ctx context.Context, nameSpace string, serviceName string, ...) (*apiv1.Service, error) + func (tc *TestClient) CreateNameSpace(ctx context.Context, nsName string) (*apiv1.Namespace, error) + func (tc *TestClient) CreatePV(ctx context.Context, persistentVolumeName string, storageClass string, ...) (*apiv1.PersistentVolume, error) + func (tc *TestClient) CreatePVC(ctx context.Context, nameSpace string, pvcName string, storageClass string, ...) (*apiv1.PersistentVolumeClaim, error) + func (tc *TestClient) CreateStorageClass(ctx context.Context, scName string, ...) (*stov1.StorageClass, error) + func (tc *TestClient) DeleteDeployment(ctx context.Context, nameSpace string, deploymentName string) error + func (tc *TestClient) DeleteNameSpace(ctx context.Context, nameSpace string) error + func (tc *TestClient) DeletePV(ctx context.Context, pvName string) error + func (tc *TestClient) DeletePVC(ctx context.Context, nameSpace string, pvcName string) error + func (tc *TestClient) DeleteService(ctx context.Context, nameSpace string, serviceName string) error + func (tc *TestClient) DeleteStorageClass(ctx context.Context, scName string) error + func (tc *TestClient) GetConfigMap(namespace, name string) (*apiv1.ConfigMap, error) + func (tc *TestClient) GetDeployment(ctx context.Context, nameSpace string, deployName string) (*appsv1.Deployment, error) + func (tc *TestClient) GetIpamSubnetFromConfigMap(cm *apiv1.ConfigMap) (string, error) + func (tc *TestClient) GetNetworkNameFromConfigMap(cm *apiv1.ConfigMap) (string, error) + func (tc *TestClient) GetPV(ctx context.Context, pvName string) (*apiv1.PersistentVolume, error) + func (tc *TestClient) GetPVC(ctx context.Context, nameSpace string, pvcName string) (*apiv1.PersistentVolumeClaim, error) + func (tc *TestClient) GetService(ctx context.Context, nameSpace string, serviceName string) (*apiv1.Service, error) + func (tc *TestClient) GetStorageClass(ctx context.Context, scName string) (*stov1.StorageClass, error) + func (tc *TestClient) GetWorkerNodes(ctx context.Context) ([]apiv1.Node, error) + func (tc *TestClient) WaitForDeploymentReady(ctx context.Context, nameSpace string, deployName string) error + func (tc *TestClient) WaitForExtIP(namespace string, name string) (string, error) + func (tc *TestClient) WaitForPVDeleted(ctx context.Context, pvName string) (bool, error) + func (tc *TestClient) WaitForPvcReady(ctx context.Context, nameSpace string, pvcName string) error + func (tc *TestClient) WaitForWorkerNodeNotReady(ctx context.Context, workerNode *apiv1.Node) error + func (tc *TestClient) WaitForWorkerNodePhaseRunning(ctx context.Context, workerNode *apiv1.Node) error + func (tc *TestClient) WaitForWorkerNodeReady(ctx context.Context, workerNode *apiv1.Node) error + type VCDAuthParams struct + GetVdcClient bool + Host string + OrgName string + OvdcName string + RefreshToken string + UserOrg string + Username string + type VolumeParams struct + MountPath string + PvcRef string + VolumeName string