utils

Documentation

Index

• func CreateDeployment(ctx context.Context, tc *testingsdk.TestClient, name, namespace string, ...) (*appsv1.Deployment, error)
• func GetLBPoolNamePrefix(service *v1.Service, clusterId string) string
• func GetPortDetailsList(svc *v1.Service) []vcdsdk.PortDetails
• func GetVirtualServicePrefix(service *v1.Service, clusterId string) string
• func GetWorkerNode(ctx context.Context, tc *testingsdk.TestClient) (*v1.Node, error)
• func HasVCDResourcesForApplicationLB(ctx context.Context, testClient *testingsdk.TestClient, ...) (bool, error)
• func IsExternalIpInVCDResourceSet(ctx context.Context, tc *testingsdk.TestClient, externalIp string) (bool, error)
• func NewTestClient(host, org, userOrg, vdcName, username, token, clusterId string, ...) (*testingsdk.TestClient, error)
• func WaitForWorkerNodeNotFound(ctx context.Context, tc *testingsdk.TestClient, workerNode *v1.Node) error

Functions

func CreateDeployment

func CreateDeployment(ctx context.Context, tc *testingsdk.TestClient, name, namespace string, labels map[string]string) (*appsv1.Deployment, error)

* CreateDeployment creates a Deployment object with agnhost image which is a E2E testing image. `netexec` is a command used to run HTTP server on agnhost at certain port specified with --http-port flag. Reference: https://github.com/kubernetes/kubernetes/issues/90211

func GetLBPoolNamePrefix

func GetLBPoolNamePrefix(service *v1.Service, clusterId string) string

func GetPortDetailsList

func GetPortDetailsList(svc *v1.Service) []vcdsdk.PortDetails

func GetVirtualServicePrefix

func GetVirtualServicePrefix(service *v1.Service, clusterId string) string

func GetWorkerNode

func GetWorkerNode(ctx context.Context, tc *testingsdk.TestClient) (*v1.Node, error)

func HasVCDResourcesForApplicationLB

func HasVCDResourcesForApplicationLB(ctx context.Context, testClient *testingsdk.TestClient, gatewayMgr *vcdsdk.GatewayManager, oneArm *vcdsdk.OneArm, virtualServiceNamePrefix string,
	lbPoolNamePrefix string, portDetailsList []vcdsdk.PortDetails) (bool, error)

func IsExternalIpInVCDResourceSet

func IsExternalIpInVCDResourceSet(ctx context.Context, tc *testingsdk.TestClient, externalIp string) (bool, error)

func NewTestClient

func NewTestClient(host, org, userOrg, vdcName, username, token, clusterId string, getVdcClient bool) (*testingsdk.TestClient, error)

func WaitForWorkerNodeNotFound

func WaitForWorkerNodeNotFound(ctx context.Context, tc *testingsdk.TestClient, workerNode *v1.Node) error