transport

Documentation

Index

• func ConnectToPortFromPod(client *testclient.ClientSet, ...) (string, string, error)
• func GetAndEnsureRunningClient(client *testclient.ClientSet, podName, namespace string, ...) (*corev1.Pod, func(), error)
• func GetAndEnsureRunningTransportServer(client *testclient.ClientSet, podName, namespace string, ...) (*corev1.Pod, func(), error)
• func StartServerForProtocol(client *testclient.ClientSet, ...) chan string

Functions

func ConnectToPortFromPod

func ConnectToPortFromPod(client *testclient.ClientSet, proto ingressnodefwv1alpha1.IngressNodeFirewallRuleProtocolType, v6 bool,
	sourcePod *corev1.Pod, sourceIP, destinationIP, destinationPort string) (string, string, error)

func GetAndEnsureRunningClient

func GetAndEnsureRunningClient(client *testclient.ClientSet, podName, namespace string, label, affinity, antiAffinity map[string]string,
	retryInterval, timeout time.Duration) (*corev1.Pod, func(), error)

func GetAndEnsureRunningTransportServer

func GetAndEnsureRunningTransportServer(client *testclient.ClientSet, podName, namespace string, labels, affinity, antiAffinity map[string]string,
	retryInterval, timeout time.Duration) (*corev1.Pod, func(), error)

func StartServerForProtocol

func StartServerForProtocol(client *testclient.ClientSet, protocol ingressnodefwv1alpha1.IngressNodeFirewallRuleProtocolType,
	pod *corev1.Pod, port string) chan string