util

Documentation

Index

• Constants
• func CreateKubeClient(t *testing.T) *kubernetes.Clientset
• func IsPlatformSupported(t *testing.T, platforms []Platform) bool
• func IsTestNamespace(name string) bool
• func IsUserNamespace(ns string) bool
• func Kubeconfig(t *testing.T) []byte
• func KubeconfigPath(t *testing.T) string
• func PrintPodsLogs(t *testing.T, p corev1typed.PodInterface, selector *metav1.LabelSelector) error
• func TestNamespace(name string) string
• func WaitForDaemonSet(t *testing.T, client kubernetes.Interface, ns, name string, ...)
• func WaitForDeployment(t *testing.T, client kubernetes.Interface, ns, name string, ...)
• func WaitForPVCToBeBound(t *testing.T, client kubernetes.Interface, ns, name string, ...)
• func WaitForStatefulSet(t *testing.T, client kubernetes.Interface, ns, name string, replicas int, ...)
• type Platform
• type PortForwardInfo
  • func (p *PortForwardInfo) CloseChan()
  • func (p *PortForwardInfo) PortForward(t *testing.T)
  • func (p *PortForwardInfo) WaitUntilForwardingAvailable(t *testing.T)

Constants

const (
	// RetryInterval is time for test to retry.
	RetryInterval = time.Second * 5
	// Timeout is time after which tests stops and fails.
	Timeout = time.Minute * 5
	// TimeoutSlow is time after which tests stops and fails.
	TimeoutSlow = time.Minute * 9
)

const (
	// PlatformAWS is for AWS
	PlatformAWS = "aws"

	// PlatformAWSEdge is for AWS with FCL Edge.
	PlatformAWSEdge = "aws_edge"

	// PlatformPacket is for Packet
	PlatformPacket = "packet"

	// PlatformPacketARM is for Packet on ARM
	PlatformPacketARM = "packet_arm"

	// PlatformBaremetal is for Baremetal
	PlatformBaremetal = "baremetal"

	// PlatformAKS is for AKS.
	PlatformAKS = "aks"
)

const TestNamespacePrefix = "test-"

TestNamespacePrefix is testing namespace prefix.

Functions

func CreateKubeClient

func CreateKubeClient(t *testing.T) *kubernetes.Clientset

CreateKubeClient returns a kubernetes client reading the KUBECONFIG environment variable.

func IsPlatformSupported

func IsPlatformSupported(t *testing.T, platforms []Platform) bool

IsPlatformSupported takes in the test object and the list of supported platforms. The function detects the supported platform from environment variable. And if the platform is available in the supported platforms provided then this returns true otherwise false. If the supported platforms list is empty it is interpreted as all platforms are supported.

func IsTestNamespace

func IsTestNamespace(name string) bool

IsTestNamespace checks if namespace is a testing namespace or not.

func IsUserNamespace

func IsUserNamespace(ns string) bool

IsUserNamespace checks for user namespace.

func Kubeconfig

func Kubeconfig(t *testing.T) []byte

Kubeconfig returns content of kubeconfig file defined with KUBECONFIG environment variable.

func KubeconfigPath

func KubeconfigPath(t *testing.T) string

func PrintPodsLogs

func PrintPodsLogs(t *testing.T, p corev1typed.PodInterface, selector *metav1.LabelSelector) error

PrintPodsLogs print logs from all pods and containers selected by given selector.

func TestNamespace

func TestNamespace(name string) string

TestNamespace creates a test namespace.

func WaitForDaemonSet

func WaitForDaemonSet(t *testing.T, client kubernetes.Interface, ns, name string, retryInterval, timeout time.Duration)

func WaitForDeployment

func WaitForDeployment(t *testing.T, client kubernetes.Interface, ns, name string, retryInterval, timeout time.Duration)

func WaitForPVCToBeBound

func WaitForPVCToBeBound(
	t *testing.T, client kubernetes.Interface, ns, name string, retryInterval, timeout time.Duration,
)

WaitForPVCToBeBound is a helper utility function to test if given PVC reaches Bound phase in given time.

func WaitForStatefulSet

func WaitForStatefulSet(t *testing.T, client kubernetes.Interface, ns, name string, replicas int, retryInterval, timeout time.Duration)

Types

type Platform

type Platform string

Platform is a type tests will use to specify which platform they are supported on.

type PortForwardInfo

type PortForwardInfo struct {

	// TODO: Add support providing service name and the API figures out the pod to forward the
	// connection to. Port forwarding works with pods only.
	PodName   string
	Namespace string
	PodPort   int
	LocalPort int
	// contains filtered or unexported fields
}

PortForwardInfo allows user to provide information needed to forward port from a Kubernetes Pod to local machine.

func (*PortForwardInfo) CloseChan

func (p *PortForwardInfo) CloseChan()

CloseChan closes the stopChan which essentially disables port forwarding. User should call this method once they are done using port forwarding. This is generally called using `defer` immediately after `PortFoward`.

func (*PortForwardInfo) PortForward

func (p *PortForwardInfo) PortForward(t *testing.T)

PortForward initiates the port forward in an asynchronous mode. The user is responsible to stop port forwarding by calling `CloseChan` method on the object. Also user should use the helper method to wait until port forwarding is enabled by calling `WaitUntilForwardingAvailable`. So the user of the this method should always call this API in following sequence for correct functionality:

p.PortForward(t) defer p.CloseChan() p.WaitUntilForwardingAvailable(t)

func (*PortForwardInfo) WaitUntilForwardingAvailable

func (p *PortForwardInfo) WaitUntilForwardingAvailable(t *testing.T)

WaitUntilForwardingAvailable is a blocking call which waits until the port-forwarding is made available.