e2e

package
Version: v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2021 License: Apache-2.0 Imports: 49 Imported by: 0

README

Running the Antrea end-to-end tests

Creating the test Kubernetes cluster

The tests must be run on an actual Kubernetes cluster. At the moment, we require the cluster to be created using Vagrant and the provided Vagrantfile, which you can do by following the instructions below.

Creating the test Kubernetes cluster with Vagrant

We use Vagrant to provision two Virtual Machines (one Kubernetes control-plane Node and one worker Node). The required software is installed on each machine with Ansible. By default the Vagrantfile uses VirtualBox but you should be able to edit the file to use your favorite Vagrant provider.

Dependencies

We require the following to be installed on your host machine:

  • vagrant (>= 2.0.0)
  • ansible (>= 2.4.0)
  • virtualbox (See supported versions here).
Ubuntu 18.04 (or later)

You can install all dependencies with sudo apt install vagrant ansible virtualbox.

Mac OS

You can install all the dependencies with brew:

  • brew install --cask virtualbox
  • brew install --cask vagrant
  • brew install ansible

If an action is required on your part, brew will let you know in its log messages.

Managing the cluster

Use the following Bash scripts to manage the Kubernetes Nodes with Vagrant:

  • ./infra/vagrant/provision.sh: create the required VMs and provision them
  • ./infra/vagrant/push_antrea.sh: load Antrea Docker image to each Node, along with the Antrea deployment YAML
  • ./infra/vagrant/suspend.sh: suspend all Node VMs
  • ./infra/vagrant/resume.sh: resume all Node VMs
  • ./infra/vagrant/destroy.sh: destoy all Node VMs, you will need to run provision.sh again to create a new cluster

Note that ./infra/vagrant/provision.sh can take a while to complete but it only needs to be run once.

IPv6 cluster

To test Antrea IPv6 support, an IPv6-only cluster can be created, by provisioning a private IPv6 network to connect Kubernetes Nodes, instead of a private IPv4 network. You simply need to invoke ./infra/vagrant/provision.sh with --ip-family v6. This option can be used even if the host machine does not support IPv6 itself. Note however that the Nodes do not have public IPv6 connectivity; they can still connect to the Internet using IPv4, which means that Docker images can be pulled without issue. Similarly, Pods (which only support IPv6) cannot connect to the Internet. To avoid issues when running Kubernetes conformance tests, we configure a proxy on the control-plane Node for all DNS traffic. While CoreDNS will reply to cluster local DNS queries directly, all other queries will be forwarded to the proxy over IPv6, and the proxy will then forward them to the default resolver for the Node (this time over IPv4). This means that all DNS queries from the Pods should succeed, even though the returned public IP addresses (IPv4 and / or IPv6) are not accessible.

You may need more recent versions of the dependencies (virtualbox, vagrant, ansible) than the ones listed above when creating an IPv6 cluster. The following versions were tested successfully:

  • vagrant 2.2.14
  • ansible 2.9.18
  • virtualbox 5.2
Debugging

You can SSH into any of the Node VMs using vagrant ssh [Node name] (must be run from the infra/vagrant directory. The control-plane Node is named k8s-node-control-plane and the worker Nodes are named k8s-node-worker-<N> (for a single worker Node, the name is k8s-node-worker-1. kubectl is installed on all the Nodes.

The kubeconfig file for the cluster can also be found locally on your machine at ./infra/vagrant/playbook/kube/config. If you install kubectl locally and set the KUBECONFIG environment variable to the absolute path of this kubeconfig file, you can run commands against your test cluster created with Vagrant. For example:

cd <directory containing this README file>
export KUBECONFIG=`pwd`/infra/vagrant/playbook/kube/config
kubectl cluster-info

Running the tests

Make sure that your cluster was provisioned and that the Antrea build artifacts were pushed to all the Nodes. You can then run the tests from the top-level directory with go test -v -timeout=30m antrea.io/antrea/test/e2e (the -v enables verbose output).

If you are running the test for the first time and are using the scripts we provide under infra/vagrant to provision your Kubernetes cluster, you will therefore need the following steps:

  1. ./infra/vagrant/provision.sh
  2. make
  3. ./infra/vagrant/push_antrea.sh
  4. go test -v -timeout=30m antrea.io/antrea/test/e2e

If you need to test an updated version of Antrea, just run ./infra/vagrant/push_antrea.sh and then run the tests again.

By default, if a test case fails, we write some useful debug information to a temporary directory on disk. This information includes the detailed description (obtained with kubectl describe) and the logs (obtained with kubectl logs) of each Antrea Pod at the time the test case exited. When running the tests in verbose mode (i.e. with -v), the test logs will tell you the location of that temporary directory. You may also choose your own directory using --logs-export-dir. For example:

mkdir antrea-test-logs
go test -count=1 -v -run=TestDeletePod antrea.io/antrea/test/e2e --logs-export-dir `pwd`/antrea-test-logs

If the user provides a log directory which was used for a previous run, existing contents (subdirectories for each test case) will be overridden. By default the description and logs for Antrea Pods are only written to disk if a test fails. You can choose to dump this information unconditionally with --logs-export-on-success.

Testing the Prometheus Integration

The Prometheus integration tests can be run as part of the e2e tests when enabled explicitly.

  • To load Antrea into the cluster with Prometheus enabled, use: ./infra/vagrant/push_antrea.sh --prometheus
  • To run the Prometheus tests within the e2e suite, use: go test -v antrea.io/antrea/test/e2e --prometheus

Running the e2e tests on a Kind cluster

The simplest way is to run the following command:

./ci/kind/test-e2e-kind.sh [options]

It will set up a two worker Node Kind cluster to run the e2e tests, and destroy the cluster after the tests stop (succeed or fail). kubectl needs to be present in your PATH to set up the test cluster. For more information on the usage of this script and the options, run:

./ci/kind/test-e2e-kind.sh --help

You can also run the e2e tests with an existing Kind cluster. Refer to this document for instructions on how to create a Kind cluster and use Antrea as the CNI. You need at least one control-plane Node and one worker Node. Before running the Go e2e tests, you will also need to copy the Antrea manifest to the control-plane Docker container:

./hack/generate-manifest.sh --kind | docker exec -i kind-control-plane dd of=/root/antrea.yml
go test -v antrea.io/antrea/test/e2e -provider=kind

generate-manifest.sh supports generating the Antrea manifest with different Antrea configurations. Run ./hack/generate-manifest.sh --help to see the supported config options.

As part of code development, if you want to run the tests with local changes, then make the code changes on the local repo and build the image. You can load the new image into the kind cluster using the command below:

kind load docker-image projects.registry.vmware.com/antrea/antrea-ubuntu:latest --name <kind_cluster_name>

Running the performance test

To run all benchmarks, without the standard e2e tests:

go test -v -timeout=30m -run=XXX -bench=. \
    antrea.io/antrea/test/e2e \
    --performance.http.concurrency=16

The above command uses -run=XXX to deselect all Test* tests and uses -bench=. to select all Benchmark* tests. Since performance tests take a while to complete, you need to extend the timeout duration -timeout from the default 10m to a longer one like 30m.

If you would like to run the performance tests in a different scale, you could run:

go test -v -timeout=30m -run=XXX -bench=BenchmarkCustomize \
    antrea.io/antrea/test/e2e \
    --performance.http.requests=5000 \
    --performance.http.policy_rules=1000 \
    --performance.http.concurrency=16

All flags of performance tests includes:

  • performance.http.concurrency (int): Number of allowed concurrent http requests (default 1)
  • performance.http.requests (int): Total Number of http requests
  • performance.http.policy_rules (int): Number of CIDRs in the network policy
  • performance.realize.timeout (duration): Timeout of the realization of network policies (default 5m0s)

Documentation

Index

Constants

This section is empty.

Variables

View Source
var AntreaConfigMap *corev1.ConfigMap

Functions

func GetAgentFeatures added in v1.3.0

func GetAgentFeatures() (featuregate.FeatureGate, error)

func GetControllerFeatures added in v1.3.0

func GetControllerFeatures() (featuregate.FeatureGate, error)

func IsDirEmpty

func IsDirEmpty(name string) (bool, error)

IsDirEmpty checks whether a directory is empty or not.

func RunCommandOnNode

func RunCommandOnNode(nodeName string, cmd string) (code int, stdout string, stderr string, err error)

RunCommandOnNode is a convenience wrapper around the Provider interface RunCommandOnNode method.

Types

type ClusterInfo

type ClusterInfo struct {
	// contains filtered or unexported fields
}

type ClusterNode

type ClusterNode struct {
	// contains filtered or unexported fields
}

type Connectivity

type Connectivity struct {
	From         Pod
	To           Pod
	Connectivity PodConnectivityMark
}

type ConnectivityTable

type ConnectivityTable struct {
	Items []string

	Values map[string]map[string]PodConnectivityMark
	// contains filtered or unexported fields
}

func NewConnectivityTable

func NewConnectivityTable(items []string, defaultValue *PodConnectivityMark) *ConnectivityTable

func (*ConnectivityTable) Compare

func (ct *ConnectivityTable) Compare(other *ConnectivityTable) *TruthTable

func (*ConnectivityTable) Get

func (*ConnectivityTable) PrettyPrint

func (ct *ConnectivityTable) PrettyPrint(indent string) string

func (*ConnectivityTable) Set

func (ct *ConnectivityTable) Set(from string, to string, value PodConnectivityMark)

func (*ConnectivityTable) SetAllFrom

func (ct *ConnectivityTable) SetAllFrom(from string, value PodConnectivityMark)

func (*ConnectivityTable) SetAllTo

func (ct *ConnectivityTable) SetAllTo(to string, value PodConnectivityMark)

type CustomPod

type CustomPod struct {
	Pod    Pod
	Labels map[string]string
}

type KubernetesUtils

type KubernetesUtils struct {
	*TestData
	// contains filtered or unexported fields
}

func NewKubernetesUtils

func NewKubernetesUtils(data *TestData) (*KubernetesUtils, error)

func (*KubernetesUtils) Bootstrap

func (k *KubernetesUtils) Bootstrap(namespaces, pods []string) (*map[string][]string, error)

func (*KubernetesUtils) BuildService

func (k *KubernetesUtils) BuildService(svcName, svcNS string, port, targetPort int, selector map[string]string, serviceType *v1.ServiceType) *v1.Service

BuildService is a convenience function for building a corev1.Service spec.

func (*KubernetesUtils) CleanACNPs

func (k *KubernetesUtils) CleanACNPs() error

CleanACNPs is a convenience function for deleting all Antrea ClusterNetworkPolicies in the cluster.

func (*KubernetesUtils) CleanANPs

func (k *KubernetesUtils) CleanANPs(namespaces []string) error

CleanANPs is a convenience function for deleting all Antrea NetworkPolicies in provided namespaces.

func (*KubernetesUtils) CleanCGs

func (k *KubernetesUtils) CleanCGs() error

CleanCGs is a convenience function for deleting all ClusterGroups in the cluster.

func (*KubernetesUtils) CleanLegacyACNPs

func (k *KubernetesUtils) CleanLegacyACNPs() error

CleanLegacyACNPs is a convenience function for deleting all Antrea ClusterNetworkPolicies in the cluster.

func (*KubernetesUtils) CleanLegacyANPs

func (k *KubernetesUtils) CleanLegacyANPs(namespaces []string) error

CleanLegacyANPs is a convenience function for deleting all Antrea NetworkPolicies in provided namespaces.

func (*KubernetesUtils) CleanLegacyCGs

func (k *KubernetesUtils) CleanLegacyCGs() error

CleanCGs is a convenience function for deleting all ClusterGroups in the cluster.

func (*KubernetesUtils) CleanNetworkPolicies

func (k *KubernetesUtils) CleanNetworkPolicies(namespaces []string) error

CleanNetworkPolicies is a convenience function for deleting NetworkPolicies in the provided namespaces.

func (*KubernetesUtils) CleanServices

func (k *KubernetesUtils) CleanServices(namespaces []string) error

CleanServices is a convenience function for deleting Services in the cluster.

func (*KubernetesUtils) Cleanup

func (k *KubernetesUtils) Cleanup(namespaces []string)

func (*KubernetesUtils) CreateCG

func (k *KubernetesUtils) CreateCG(name string, pSelector, nSelector *metav1.LabelSelector, ipBlocks []crdv1alpha1.IPBlock) (*crdv1alpha3.ClusterGroup, error)

CreateCG is a convenience function for creating an Antrea ClusterGroup by name and selector.

func (*KubernetesUtils) CreateLegacyCG

func (k *KubernetesUtils) CreateLegacyCG(name string, pSelector, nSelector *metav1.LabelSelector, ipBlock *crdv1alpha1.IPBlock) (*legacycorev1a2.ClusterGroup, error)

CreateLegacyCG is a convenience function for creating a legacy Antrea ClusterGroup by name and selector.

func (*KubernetesUtils) CreateNewLegacyTier

func (k *KubernetesUtils) CreateNewLegacyTier(name string, tierPriority int32) (*legacysecv1alpha1.Tier, error)

CreateLegacyTier is a convenience function for creating a legacy Antrea Policy Tier by name and priority.

func (*KubernetesUtils) CreateNewTier

func (k *KubernetesUtils) CreateNewTier(name string, tierPriority int32) (*crdv1alpha1.Tier, error)

CreateTier is a convenience function for creating an Antrea Policy Tier by name and priority.

func (*KubernetesUtils) CreateOrUpdateACNP

CreateOrUpdateACNP is a convenience function for updating/creating AntreaClusterNetworkPolicies.

func (*KubernetesUtils) CreateOrUpdateANP

CreateOrUpdateANP is a convenience function for updating/creating Antrea NetworkPolicies.

func (*KubernetesUtils) CreateOrUpdateDeployment

func (k *KubernetesUtils) CreateOrUpdateDeployment(ns, deploymentName string, replicas int32, labels map[string]string) (*appsv1.Deployment, error)

CreateOrUpdateDeployment is a convenience function for idempotent setup of deployments

func (*KubernetesUtils) CreateOrUpdateLegacyACNP

CreateOrUpdateLegacyACNP is a convenience function for updating/creating AntreaClusterNetworkPolicies.

func (*KubernetesUtils) CreateOrUpdateLegacyANP

CreateOrUpdateANP is a convenience function for updating/creating Antrea NetworkPolicies.

func (*KubernetesUtils) CreateOrUpdateLegacyCG

func (k *KubernetesUtils) CreateOrUpdateLegacyCG(cg *legacycorev1a2.ClusterGroup) (*legacycorev1a2.ClusterGroup, error)

CreateOrUpdateLegacyCG is a convenience function for idempotent setup of legacy ClusterGroups

func (*KubernetesUtils) CreateOrUpdateNamespace

func (k *KubernetesUtils) CreateOrUpdateNamespace(n string, labels map[string]string) (*v1.Namespace, error)

CreateOrUpdateNamespace is a convenience function for idempotent setup of Namespaces

func (*KubernetesUtils) CreateOrUpdateNetworkPolicy

func (k *KubernetesUtils) CreateOrUpdateNetworkPolicy(netpol *v1net.NetworkPolicy) (*v1net.NetworkPolicy, error)

CreateOrUpdateNetworkPolicy is a convenience function for updating/creating netpols. Updating is important since some tests update a network policy to confirm that mutation works with a CNI.

func (*KubernetesUtils) CreateOrUpdateService

func (k *KubernetesUtils) CreateOrUpdateService(svc *v1.Service) (*v1.Service, error)

CreateOrUpdateService is a convenience function for updating/creating Services.

func (*KubernetesUtils) CreateOrUpdateV1Alpha2CG

func (k *KubernetesUtils) CreateOrUpdateV1Alpha2CG(cg *crdv1alpha2.ClusterGroup) (*crdv1alpha2.ClusterGroup, error)

CreateOrUpdateV1Alpha2CG is a convenience function for idempotent setup of crd/v1alpha2 ClusterGroups

func (*KubernetesUtils) CreateOrUpdateV1Alpha3CG

func (k *KubernetesUtils) CreateOrUpdateV1Alpha3CG(cg *crdv1alpha3.ClusterGroup) (*crdv1alpha3.ClusterGroup, error)

CreateOrUpdateV1Alpha3CG is a convenience function for idempotent setup of crd/v1alpha3 ClusterGroups

func (*KubernetesUtils) DeleteACNP

func (k *KubernetesUtils) DeleteACNP(name string) error

DeleteACNP is a convenience function for deleting ACNP by name.

func (*KubernetesUtils) DeleteANP

func (k *KubernetesUtils) DeleteANP(ns, name string) error

DeleteANP is a convenience function for deleting ANP by name and Namespace.

func (*KubernetesUtils) DeleteLegacyACNP

func (k *KubernetesUtils) DeleteLegacyACNP(name string) error

DeleteLegacyACNP is a convenience function for deleting ACNP by name.

func (*KubernetesUtils) DeleteLegacyANP

func (k *KubernetesUtils) DeleteLegacyANP(ns, name string) error

DeleteLegacyANP is a convenience function for deleting ANP by name and Namespace.

func (*KubernetesUtils) DeleteLegacyCG

func (k *KubernetesUtils) DeleteLegacyCG(name string) error

DeleteLegacyCG is a convenience function for deleting legacy ClusterGroup by name.

func (*KubernetesUtils) DeleteLegacyTier

func (k *KubernetesUtils) DeleteLegacyTier(name string) error

DeleteLegacyTier is a convenience function for deleting a legacy Antrea Policy Tier with specific name.

func (*KubernetesUtils) DeleteNetworkPolicy

func (k *KubernetesUtils) DeleteNetworkPolicy(ns, name string) error

DeleteNetworkPolicy is a convenience function for deleting NetworkPolicy by name and Namespace.

func (*KubernetesUtils) DeleteService

func (k *KubernetesUtils) DeleteService(ns, name string) error

DeleteService is a convenience function for deleting a Service by Namespace and name.

func (*KubernetesUtils) DeleteTier

func (k *KubernetesUtils) DeleteTier(name string) error

DeleteTier is a convenience function for deleting an Antrea Policy Tier with specific name.

func (*KubernetesUtils) DeleteV1Alpha2CG

func (k *KubernetesUtils) DeleteV1Alpha2CG(name string) error

DeleteV1Alpha2CG is a convenience function for deleting crd/v1alpha2 ClusterGroup by name.

func (*KubernetesUtils) DeleteV1Alpha3CG

func (k *KubernetesUtils) DeleteV1Alpha3CG(name string) error

DeleteV1Alpha3CG is a convenience function for deleting core/v1alpha3 ClusterGroup by name.

func (*KubernetesUtils) GetACNP

GetACNP is a convenience function for getting AntreaClusterNetworkPolicies.

func (*KubernetesUtils) GetANP

func (k *KubernetesUtils) GetANP(namespace, name string) (*crdv1alpha1.NetworkPolicy, error)

GetANP is a convenience function for getting AntreaNetworkPolicies.

func (*KubernetesUtils) GetCG

GetCG is a convenience function for getting ClusterGroups

func (*KubernetesUtils) GetNetworkPolicy

func (k *KubernetesUtils) GetNetworkPolicy(namespace, name string) (*v1net.NetworkPolicy, error)

GetNetworkPolicy is a convenience function for getting k8s NetworkPolicies.

func (*KubernetesUtils) GetPodByLabel

func (k *KubernetesUtils) GetPodByLabel(ns string, name string) (*v1.Pod, error)

GetPodByLabel returns a Pod with the matching Namespace and "pod" label.

func (*KubernetesUtils) GetPodsByLabel

func (k *KubernetesUtils) GetPodsByLabel(ns string, key string, val string) ([]v1.Pod, error)

GetPodsByLabel returns an array of all Pods in the given Namespace having a k/v label pair.

func (*KubernetesUtils) GetService

func (k *KubernetesUtils) GetService(namespace, name string) (*v1.Service, error)

GetService is a convenience function for getting Service

func (*KubernetesUtils) GetTier

func (k *KubernetesUtils) GetTier(name string) (*crdv1alpha1.Tier, error)

GetTier is a convenience function for getting Tier.

func (*KubernetesUtils) GetV1Alpha2CG

func (k *KubernetesUtils) GetV1Alpha2CG(cgName string) (*crdv1alpha2.ClusterGroup, error)

func (*KubernetesUtils) GetV1Alpha3CG

func (k *KubernetesUtils) GetV1Alpha3CG(cgName string) (*crdv1alpha3.ClusterGroup, error)

func (*KubernetesUtils) LegacyCleanup

func (k *KubernetesUtils) LegacyCleanup(namespaces []string)

func (*KubernetesUtils) Probe

func (k *KubernetesUtils) Probe(ns1, pod1, ns2, pod2 string, port int32, protocol v1.Protocol) (PodConnectivityMark, error)

Probe execs into a Pod and checks its connectivity to another Pod. Of course it assumes that the target Pod is serving on the input port, and also that agnhost is installed. The connectivity from source Pod to all IPs of the target Pod should be consistent. Otherwise, Error PodConnectivityMark will be returned.

func (*KubernetesUtils) ProbeEgress added in v1.3.0

func (k *KubernetesUtils) ProbeEgress(ns, pod, dstAddr string, port int32, protocol v1.Protocol) (PodConnectivityMark, error)

Probe execs into a Pod and checks its connectivity to an arbirary destination address.

func (*KubernetesUtils) UpdateLegacyTier

func (k *KubernetesUtils) UpdateLegacyTier(tier *legacysecv1alpha1.Tier) (*legacysecv1alpha1.Tier, error)

UpdateLegacyTier is a convenience function for updating a legacy Antrea Policy Tier.

func (*KubernetesUtils) UpdateTier

func (k *KubernetesUtils) UpdateTier(tier *crdv1alpha1.Tier) (*crdv1alpha1.Tier, error)

UpdateTier is a convenience function for updating an Antrea Policy Tier.

func (*KubernetesUtils) Validate

func (k *KubernetesUtils) Validate(allPods []Pod, reachability *Reachability, ports []int32, protocol v1.Protocol)

Validate checks the connectivity between all Pods in both directions with a list of ports and a protocol. The connectivity from a Pod to another Pod should be consistent across all provided ports. Otherwise, this connectivity will be treated as Error.

type Pod

type Pod string

func NewPod

func NewPod(namespace string, podName string) Pod

func (Pod) Namespace

func (pod Pod) Namespace() string

func (Pod) PodName

func (pod Pod) PodName() string

func (Pod) String

func (pod Pod) String() string

type PodCondition

type PodCondition func(*corev1.Pod) (bool, error)

type PodConnectivityMark

type PodConnectivityMark string
const (
	Connected PodConnectivityMark = "Con"
	Unknown   PodConnectivityMark = "Unk"
	Error     PodConnectivityMark = "Err"
	Dropped   PodConnectivityMark = "Drp"
	Rejected  PodConnectivityMark = "Rej"
)

type PodIPs

type PodIPs struct {
	// contains filtered or unexported fields
}

func (PodIPs) String

func (p PodIPs) String() string

type Reachability

type Reachability struct {
	Expected        *ConnectivityTable
	Observed        *ConnectivityTable
	Pods            []Pod
	PodsByNamespace map[string][]Pod
}

func NewReachability

func NewReachability(pods []Pod, defaultExpectation PodConnectivityMark) *Reachability

func (*Reachability) Expect

func (r *Reachability) Expect(pod1 Pod, pod2 Pod, connectivity PodConnectivityMark)

func (*Reachability) ExpectAllEgress

func (r *Reachability) ExpectAllEgress(pod Pod, connectivity PodConnectivityMark)

ExpectAllEgress defines that any traffic going out of the pod will be allowed/dropped/rejected

func (*Reachability) ExpectAllIngress

func (r *Reachability) ExpectAllIngress(pod Pod, connectivity PodConnectivityMark)

ExpectAllIngress defines that any traffic going into the pod will be allowed/dropped/rejected

func (*Reachability) ExpectAllSelfNamespace

func (r *Reachability) ExpectAllSelfNamespace(connectivity PodConnectivityMark)

func (*Reachability) ExpectConn

func (r *Reachability) ExpectConn(spec *Connectivity)

ExpectConn is an experimental way to describe connectivity with named fields

func (*Reachability) ExpectEgressToNamespace

func (r *Reachability) ExpectEgressToNamespace(pod Pod, namespace string, connectivity PodConnectivityMark)

func (*Reachability) ExpectIngressFromNamespace

func (r *Reachability) ExpectIngressFromNamespace(pod Pod, namespace string, connectivity PodConnectivityMark)

func (*Reachability) ExpectSelf

func (r *Reachability) ExpectSelf(allPods []Pod, connectivity PodConnectivityMark)

func (*Reachability) ExpectSelfNamespace

func (r *Reachability) ExpectSelfNamespace(namespace string, connectivity PodConnectivityMark)

func (*Reachability) Observe

func (r *Reachability) Observe(pod1 Pod, pod2 Pod, connectivity PodConnectivityMark)

func (*Reachability) PrintSummary

func (r *Reachability) PrintSummary(printExpected bool, printObserved bool, printComparison bool)

func (*Reachability) Summary

func (r *Reachability) Summary() (trueObs int, falseObs int, comparison *TruthTable)

type TestData

type TestData struct {
	// contains filtered or unexported fields
}

TestData stores the state required for each test case.

func (*TestData) GetAntreaConfigMap

func (data *TestData) GetAntreaConfigMap(antreaNamespace string) (*corev1.ConfigMap, error)

func (*TestData) GetEncapMode

func (data *TestData) GetEncapMode() (config.TrafficEncapModeType, error)

func (*TestData) GetFlowAggregatorConfigMap

func (data *TestData) GetFlowAggregatorConfigMap() (*corev1.ConfigMap, error)

func (*TestData) GetGatewayInterfaceName

func (data *TestData) GetGatewayInterfaceName(antreaNamespace string) (string, error)

type TestOptions

type TestOptions struct {
	// contains filtered or unexported fields
}

type TruthTable

type TruthTable struct {
	Items []string

	Values map[string]map[string]bool
	// contains filtered or unexported fields
}

func (*TruthTable) IsComplete

func (tt *TruthTable) IsComplete() bool

IsComplete returns true if there's a value set for every single pair of items, otherwise it returns false.

func (*TruthTable) PrettyPrint

func (tt *TruthTable) PrettyPrint(indent string) string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL