Documentation ¶
Index ¶
- Constants
- Variables
- 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 CreateNewMachineDeploymentWithFailureDomain(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 swaggerClient.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 GetVappTemplates(client *vcdsdk.Client) ([]*types.QueryResultVappTemplateType, error)
- func IsRetryableError(err error) bool
- type CAPVCDEntity
- type ContainerParams
- type DeployParams
- type FullCAPVCDEntity
- type Set
- type Status
- type TaskWithResult
- type TestClient
- 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) DeleteDeployment(ctx context.Context, nameSpace string, deploymentName string) error
- func (tc *TestClient) DeleteNameSpace(ctx context.Context, nameSpace string) error
- func (tc *TestClient) DeleteService(ctx context.Context, nameSpace string, serviceName 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) GetK8sVersion() (*version.Info, error)
- func (tc *TestClient) GetNetworkNameFromConfigMap(cm *apiv1.ConfigMap) (string, error)
- func (tc *TestClient) GetNodes(ctx context.Context) ([]apiv1.Node, error)
- func (tc *TestClient) GetService(ctx context.Context, nameSpace string, serviceName string) (*apiv1.Service, error)
- func (tc *TestClient) GetWorkerNodes(ctx context.Context) ([]apiv1.Node, error)
- func (tc *TestClient) GetZoneMapFromZoneConfigMap(zoneCM *apiv1.ConfigMap) (map[string]string, 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) 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
- type VolumeParams
Constants ¶
View Source
const ( MachineDeployment = "MachineDeployment" KubeadmConfigTemplate = "KubeadmConfigTemplate" VCDMachineTemplate = "VCDMachineTemplate" )
View Source
const ( CAPVCDEntityTypeVersion120 = "1.2.0" NoOpDecryptBehaviorID = "urn:vcloud:behavior-interface:getFullEntity:cse:capvcd:1.0.0" )
Variables ¶
Functions ¶
func GetCapvcdYamlFromRde ¶
func GetCapvcdYamlFromRde(capvcdRDE swaggerClient.DefinedEntity) (string, error)
func GetComponentMapInStatus ¶
func GetComponentMapInStatus(ctx context.Context, client *vcdsdk.Client, clusterId, componentName string) (map[string]interface{}, error)
Returns status.component as map[string]interface{}, this will help us narrow down to specific fields such as nodepools, vcdresources, etc Components: vcdKe, projector, csi, cpi, capvcd
func GetKubeconfigFromRDEId ¶
func GetMapBySpecName ¶
func GetVCDResourceSet ¶
func GetVappTemplates ¶
func IsRetryableError ¶
Types ¶
type CAPVCDEntity ¶
type CAPVCDEntity struct {
Status Status `json:"status"`
}
type ContainerParams ¶
type DeployParams ¶
type DeployParams struct { Name string Labels map[string]string VolumeParams VolumeParams ContainerParams ContainerParams }
type FullCAPVCDEntity ¶
type FullCAPVCDEntity struct {
Entity CAPVCDEntity `json:"entity"`
}
type TaskWithResult ¶
type TaskWithResult struct { // NOTE: the following is the addition to the Task type in GoVCD. Represents the ResultContent within the Task object ResultContent string `xml:"Result>ResultContent,omitempty"` }
type TestClient ¶
type TestClient struct { VcdClient *vcdsdk.Client Cs kubernetes.Interface ClusterId string ClusterName string Config *restclient.Config }
func NewTestClient ¶
func NewTestClient(params *VCDAuthParams, clusterId string) (*TestClient, error)
func (*TestClient) CreateDeployment ¶
func (tc *TestClient) CreateDeployment(ctx context.Context, params *DeployParams, nameSpace string) (*appsv1.Deployment, error)
func (*TestClient) CreateLoadBalancerService ¶
func (*TestClient) CreateNameSpace ¶
func (*TestClient) DeleteDeployment ¶
func (*TestClient) DeleteNameSpace ¶
func (tc *TestClient) DeleteNameSpace(ctx context.Context, nameSpace string) error
func (*TestClient) DeleteService ¶
func (*TestClient) GetConfigMap ¶
func (tc *TestClient) GetConfigMap(namespace, name string) (*apiv1.ConfigMap, error)
func (*TestClient) GetDeployment ¶
func (tc *TestClient) GetDeployment(ctx context.Context, nameSpace string, deployName string) (*appsv1.Deployment, error)
func (*TestClient) GetIpamSubnetFromConfigMap ¶
func (tc *TestClient) GetIpamSubnetFromConfigMap(cm *apiv1.ConfigMap) (string, error)
func (*TestClient) GetK8sVersion ¶
func (tc *TestClient) GetK8sVersion() (*version.Info, error)
func (*TestClient) GetNetworkNameFromConfigMap ¶
func (tc *TestClient) GetNetworkNameFromConfigMap(cm *apiv1.ConfigMap) (string, error)
func (*TestClient) GetService ¶
func (*TestClient) GetWorkerNodes ¶
func (*TestClient) GetZoneMapFromZoneConfigMap ¶
func (tc *TestClient) GetZoneMapFromZoneConfigMap(zoneCM *apiv1.ConfigMap) (map[string]string, error)
GetZoneMapFromZoneConfigMap reads the zone config map and returns a map of zoneName -> ovdcName
func (*TestClient) WaitForDeploymentReady ¶
func (*TestClient) WaitForExtIP ¶
func (tc *TestClient) WaitForExtIP(namespace string, name string) (string, error)
func (*TestClient) WaitForWorkerNodeNotReady ¶
WaitForWorkerNodeNotReady we cannot use negate result from WaitForWorkerNodeReady() Set different RetryTimeInterval and avoid timeout error
func (*TestClient) WaitForWorkerNodePhaseRunning ¶
func (*TestClient) WaitForWorkerNodeReady ¶
type VCDAuthParams ¶
type VolumeParams ¶
Click to show internal directories.
Click to hide internal directories.