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)
Constants ¶
This section is empty.
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 ¶
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.
Types ¶
This section is empty.