net

Documentation

Overview

Package net implements basic network connecitivity test on Liqo to assess E2E functionality of the network

Index

• Variables
• func CheckNodeToPortConnectivity(ctx context.Context, homeClusterClient kubernetes.Interface, ...) error
• func CheckPodConnectivity(ctx context.Context, homeConfig *restclient.Config, ...) error
• func CheckTesterPods(ctx context.Context, homeClient, foreignClient kubernetes.Interface, ...) bool
• func ConnectivityCheckNodeToPod(ctx context.Context, homeClusterClient kubernetes.Interface, clusterID string) error
• func EnsureNetTesterPods(ctx context.Context, homeClient kubernetes.Interface, homeID string) error
• func EnsureNodePort(ctx context.Context, client kubernetes.Interface, ...) (*v1.Service, error)
• func EnsureNodePortService(ctx context.Context, homeClusterClient kubernetes.Interface, clusterID string) (int, error)

Variables

var (

	// TestNamespaceName is the namespace name where the test is performed.
	TestNamespaceName = "test-connectivity"
)

Functions

func CheckNodeToPortConnectivity

func CheckNodeToPortConnectivity(ctx context.Context, homeClusterClient kubernetes.Interface, homeClusterID string, nodePortValue int) error

CheckNodeToPortConnectivity contacts the nodePortValue and returns the result.

func CheckPodConnectivity

func CheckPodConnectivity(ctx context.Context, homeConfig *restclient.Config, homeClient kubernetes.Interface) error

CheckPodConnectivity contacts the remote service by executing the command inside podRemoteUpdateCluster1.

func CheckTesterPods

func CheckTesterPods(ctx context.Context, homeClient, foreignClient kubernetes.Interface, homeClusterID string) bool

CheckTesterPods retrieves the netTest pods and returns true if all the pods are up and ready.

func ConnectivityCheckNodeToPod

func ConnectivityCheckNodeToPod(ctx context.Context, homeClusterClient kubernetes.Interface, clusterID string) error

ConnectivityCheckNodeToPod creates a NodePort Service and check its availability.

func EnsureNetTesterPods

func EnsureNetTesterPods(ctx context.Context, homeClient kubernetes.Interface, homeID string) error

EnsureNetTesterPods creates the NetTest pods and waits for them to be ready.

func EnsureNodePort

func EnsureNodePort(ctx context.Context, client kubernetes.Interface, clusterID, name, namespace string) (*v1.Service, error)

EnsureNodePort creates a Service of type NodePort for the netTest.

func EnsureNodePortService

func EnsureNodePortService(ctx context.Context, homeClusterClient kubernetes.Interface, clusterID string) (int, error)

EnsureNodePortService creates a nodePortService. It returns the port to contact to reach the service and occurred errors.