e2e

package

Go to main page

Versions in this module

v0

v0.8.0

Oct 27, 2023

v0.7.1

Oct 3, 2023

Changes in this version

+ func ClearCovFolder(nodeName, covPrefix string) error

+ func ControlPlaneNoScheduleTolerations() []corev1.Toleration

+ func CopyCovFolder(nodeName, covDir, covPrefix string) error

+ func ExportLogs(tb testing.TB, data *TestData, logsSubDir string, writeNodeLogs bool, ...)

+ func GetImageName(uri string) string

+ func TeardownFlowVisibility(tb testing.TB, data *TestData, config FlowVisibilitySetUpConfig, ...)

+ type ClickHouseFullRow struct

+ ClusterUUID string

+ DestinationClusterIP string

+ DestinationIP string

+ DestinationNodeName string

+ DestinationPodLabels string

+ DestinationPodName string

+ DestinationPodNamespace string

+ DestinationServicePort uint16

+ DestinationServicePortName string

+ DestinationTransportPort uint16

+ EgressIP string

+ EgressName string

+ EgressNetworkPolicyName string

+ EgressNetworkPolicyNamespace string

+ EgressNetworkPolicyRuleAction uint8

+ EgressNetworkPolicyRuleName string

+ EgressNetworkPolicyType uint8

+ FlowEndReason uint8

+ FlowEndSeconds time.Time

+ FlowEndSecondsFromDestinationNode time.Time

+ FlowEndSecondsFromSourceNode time.Time

+ FlowStartSeconds time.Time

+ FlowType uint8

+ IngressNetworkPolicyName string

+ IngressNetworkPolicyNamespace string

+ IngressNetworkPolicyRuleAction uint8

+ IngressNetworkPolicyRuleName string

+ IngressNetworkPolicyType uint8

+ OctetDeltaCount uint64

+ OctetTotalCount uint64

+ PacketDeltaCount uint64

+ PacketTotalCount uint64

+ ProtocolIdentifier uint8

+ ReverseOctetDeltaCount uint64

+ ReverseOctetTotalCount uint64

+ ReversePacketDeltaCount uint64

+ ReversePacketTotalCount uint64

+ ReverseThroughput uint64

+ ReverseThroughputFromDestinationNode uint64

+ ReverseThroughputFromSourceNode uint64

+ SourceIP string

+ SourceNodeName string

+ SourcePodLabels string

+ SourcePodName string

+ SourcePodNamespace string

+ SourceTransportPort uint16

+ TcpState string

+ Throughput uint64

+ ThroughputFromDestinationNode uint64

+ ThroughputFromSourceNode uint64

+ TimeInserted time.Time

+ Trusted uint8

+ func GetClickHouseOutput(t *testing.T, data *TestData, srcIP, dstIP, srcPort string, ...) []*ClickHouseFullRow

type FlowVisibilitySetUpConfig

+ func CreateFlowVisibilitySetUpConfig(...) FlowVisibilitySetUpConfig

type PodIPs

+ func ParsePodIPs(podIPStrings sets.Set[string]) (*PodIPs, error)

+ func (p PodIPs) GetIPv4() *net.IP

+ func (p PodIPs) GetIPv6() *net.IP

type TestData

+ func (data *TestData) CollectPodCIDRInfo(controlPlaneName string) error

+ func (data *TestData) GetClientSet() kubernetes.Interface

+ func (data *TestData) GetClusterName() string

+ func (data *TestData) GetControlPlaneNodeIP(label string) (string, error)

+ func (data *TestData) GetFlowAggregator() (*corev1.Pod, error)

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

+ func (data *TestData) GetPodV4NetworkCIDR() string

+ func (data *TestData) GetPodV6NetworkCIDR() string

+ func (data *TestData) KillProcesses(namespace, podName, containerName, processName string) error

+ func (data *TestData) MutateFlowAggregatorConfigMap(datbaseURL string, security bool) error

+ func (data *TestData) PodWaitForReady(timeout time.Duration, name, namespace string) error

+ func (data *TestData) SetClusterName(name string)

v0.7.0

Jul 25, 2023

Changes in this version

+ func ApplyNewVersion(t *testing.T, data *TestData, ...)

+ type FlowVisibilitySetUpConfig struct

v0.6.0

May 23, 2023

Changes in this version

+ func TheiaManagerRestart(t *testing.T, data *TestData, jobName1 string, job string) error

+ func VerifyJobCleaned(t *testing.T, data *TestData, jobName string, tablename string, prefixlen int) error

v0.5.0

Mar 22, 2023

Changes in this version

+ func DeleteJob(t *testing.T, data *TestData, cmd string) (stdout string, err error)

+ func GetJobStatus(t *testing.T, data *TestData, cmd string) (stdout string, err error)

+ func ListJobs(t *testing.T, data *TestData, cmd string) (stdout string, err error)

+ func RetrieveJobResult(t *testing.T, data *TestData, cmd string) (stdout string, err error)

+ func RunJob(t *testing.T, data *TestData, jobcmd string) (stdout string, jobName string, err error)

+ func SetupClickHouseConnection(clientset kubernetes.Interface, kubeconfig string) (connect *sql.DB, portForward *portforwarder.PortForwarder, err error)

v0.4.0

Dec 23, 2022

v0.3.0

Oct 21, 2022

v0.2.0

Aug 18, 2022

Changes in this version

+ type FlowVisibiltiySetUpConfig struct

type TestData

+ func (data *TestData) GetPodLogs(namespace, name string, podLogOpts *corev1.PodLogOptions) (string, error)

v0.2.0-alpha.0

Jul 8, 2022

v0.1.0

Jun 16, 2022

Changes in this version

+ func IsDirEmpty(name string) (bool, error)

+ type ClusterInfo struct

+ type ClusterNode struct

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

+ type PodIPs struct

+ func (p PodIPs) String() string

+ type TestData struct

+ func (data *TestData) CleanACNPs() error

+ func (data *TestData) CleanCGs() error

+ func (data *TestData) Cleanup(namespaces []string)

+ func (data *TestData) CreateClient(kubeconfigPath string) error

+ func (data *TestData) CreateNamespace(namespace string, mutateFunc func(*corev1.Namespace)) error

+ func (data *TestData) CreateOrUpdateANP(anp *crdv1alpha1.NetworkPolicy) (*crdv1alpha1.NetworkPolicy, error)

+ func (data *TestData) CreatePodOnNodeInNamespace(name, ns string, nodeName, ctrName string, image string, command []string, ...) error

+ func (data *TestData) CreateService(serviceName, namespace string, port, targetPort int32, ...) (*corev1.Service, error)

+ func (data *TestData) CreateServiceWithAnnotations(serviceName, namespace string, port, targetPort int32, ...) (*corev1.Service, error)

+ func (data *TestData) DeleteACNP(name string) error

+ func (data *TestData) DeleteANP(ns, name string) error

+ func (data *TestData) DeleteNamespace(namespace string, timeout time.Duration) error

+ func (data *TestData) DeletePod(namespace, name string) error

+ func (data *TestData) DeleteV1Alpha2CG(name string) error

+ func (data *TestData) DeleteV1Alpha3CG(name string) error

+ func (data *TestData) GetService(namespace, name string) (*corev1.Service, error)

+ func (data *TestData) InitProvider(providerName, providerConfigPath string) error

+ func (data *TestData) PodWaitFor(timeout time.Duration, name, namespace string, condition PodCondition) (*corev1.Pod, error)

+ func (data *TestData) RunCommandFromPod(podNamespace string, podName string, containerName string, cmd []string) (stdout string, stderr string, err error)

+ func (data *TestData) RunCommandOnNode(nodeName string, cmd string) (code int, stdout string, stderr string, err error)

+ func (data *TestData) WaitNetworkPolicyRealize(nodeName string, table *openflow.Table, policyRules int) error

+ type TestOptions struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL