framework

package
v1.12.13 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IPv4 = "ipv4"
	IPv6 = "ipv6"
	Dual = "dual"
)
View Source 
const (
	PauseImage   = "kubeovn/pause:3.2"
	BusyBoxImage = "busybox:stable"
	AgnhostImage = "kubeovn/agnhost:2.43"
)
View Source 
const (
	KubeOvnNamespace = "kube-system"
	DaemonSetOvsOvn  = "ovs-ovn"
)

Variables

This section is empty.

Functions

func ConformanceIt added in v1.11.0 

func ConformanceIt(text string, body interface{}) bool

ConformanceIt is wrapper function for ginkgo It. Adds "[Conformance]" tag and makes static analysis easier.

func CorruptiveIt added in v1.12.1 

func CorruptiveIt(text string, body interface{}) bool

func Describe added in v1.11.0 

func Describe(text string, body func()) bool

func ExecCommandInContainer added in v1.12.0 

func ExecCommandInContainer(f *Framework, namespace, pod, container string, cmd ...string) (string, string, error)

ExecCommandInContainer executes a command in the specified container.

func ExecShellInContainer added in v1.12.0 

func ExecShellInContainer(f *Framework, namespace, pod, container, cmd string) (string, string, error)

ExecShellInContainer executes the specified command on the pod's container.

func ExecShellInPod added in v1.12.0 

func ExecShellInPod(ctx context.Context, f *Framework, namespace, pod, cmd string) (string, string, error)

ExecShellInPod executes the specified command on the pod.

func ExpectConsistOf added in v1.11.0 

func ExpectConsistOf(actual, extra interface{}, explain ...interface{})

ExpectConsistOf expects actual contains precisely the extra elements. The ordering of the elements does not matter.

func ExpectContainElement added in v1.11.0 

func ExpectContainElement(actual, extra interface{}, explain ...interface{})

ExpectContainElement expects actual contains the extra elements.

func ExpectContainSubstring added in v1.12.0 

func ExpectContainSubstring(actual, substr string, explain ...interface{})

ExpectContainSubstring expects actual contains the passed-in substring.

func ExpectEmpty added in v1.11.0 

func ExpectEmpty(actual interface{}, explain ...interface{})

ExpectEmpty expects actual is empty

func ExpectEqual added in v1.11.0 

func ExpectEqual(actual, extra interface{}, explain ...interface{})

ExpectEqual expects the specified two are the same, otherwise an exception raises

func ExpectError added in v1.11.0 

func ExpectError(err error, explain ...interface{})

ExpectError expects an error happens, otherwise an exception raises

func ExpectFalse added in v1.11.0 

func ExpectFalse(actual interface{}, explain ...interface{})

ExpectFalse expects actual is false

func ExpectHaveKey added in v1.11.0 

func ExpectHaveKey(actual, key interface{}, explain ...interface{})

ExpectHaveKey expects the actual map has the key in the keyset

func ExpectHaveKeyWithValue added in v1.11.0 

func ExpectHaveKeyWithValue(actual, key, value interface{}, explain ...interface{})

ExpectHaveKeyWithValue expects the actual map has the passed in key/value pair.

func ExpectHaveLen added in v1.11.0 

func ExpectHaveLen(actual interface{}, count int, explain ...interface{})

ExpectHaveLen expects actual has the passed-in length

func ExpectIPInCIDR added in v1.11.0 

func ExpectIPInCIDR(ip, cidr string)

ExpectIPInCIDR expects that the given IP address in within the CIDR.

func ExpectMAC added in v1.11.0 

func ExpectMAC(s string)

ExpectMAC expects that the given string is a MAC address.

func ExpectNil added in v1.11.0 

func ExpectNil(actual interface{}, explain ...interface{})

ExpectNil expects actual is nil

func ExpectNoError added in v1.11.0 

func ExpectNoError(err error, explain ...interface{})

ExpectNoError checks if "err" is set, and if so, fails assertion while logging the error.

func ExpectNoErrorWithOffset added in v1.11.0 

func ExpectNoErrorWithOffset(offset int, err error, explain ...interface{})

ExpectNoErrorWithOffset checks if "err" is set, and if so, fails assertion while logging the error at "offset" levels above its caller (for example, for call chain f -> g -> ExpectNoErrorWithOffset(1, ...) error would be logged for "f").

func ExpectNotContainElement added in v1.11.0 

func ExpectNotContainElement(actual, extra interface{}, explain ...interface{})

ExpectNotContainElement expects actual does not contain the extra elements.

func ExpectNotContainSubstring added in v1.12.0 

func ExpectNotContainSubstring(actual, substr string, explain ...interface{})

ExpectNotContainSubstring expects actual does not contain the passed-in substring.

func ExpectNotEmpty added in v1.11.0 

func ExpectNotEmpty(actual interface{}, explain ...interface{})

ExpectNotEmpty expects actual is not empty

func ExpectNotEqual added in v1.11.0 

func ExpectNotEqual(actual, extra interface{}, explain ...interface{})

ExpectNotEqual expects the specified two are not the same, otherwise an exception raises

func ExpectNotHaveKey added in v1.11.0 

func ExpectNotHaveKey(actual, key interface{}, explain ...interface{})

ExpectNotHaveKey expects the actual map does not have the key in the keyset

func ExpectNotNil added in v1.11.0 

func ExpectNotNil(actual interface{}, explain ...interface{})

ExpectNotNil expects actual is not nil

func ExpectNotZero added in v1.11.0 

func ExpectNotZero(actual interface{}, explain ...interface{})

ExpectNotZero expects actual is not nil nor the zero value for its type.

func ExpectTrue added in v1.11.0 

func ExpectTrue(actual interface{}, explain ...interface{})

ExpectTrue expects actual is true

func ExpectUUID added in v1.11.0 

func ExpectUUID(s string)

ExpectUUID expects that the given string is a UUID.

func ExpectZero added in v1.11.0 

func ExpectZero(actual interface{}, explain ...interface{})

ExpectZero expects actual is the zero value for its type or actual is nil.

func Fail added in v1.11.0 

func Fail(msg string, callerSkip ...int)

Fail is a replacement for ginkgo.Fail which logs the problem as it occurs together with a stack trace and then calls ginkgowrapper.Fail.

func Failf added in v1.11.0 

func Failf(format string, args ...interface{})

Failf logs the fail info, including a stack trace starts with its direct caller (for example, for call chain f -> g -> Failf("foo", ...) error would be logged for "g").

func GetKubeOvnImage added in v1.11.0 

func GetKubeOvnImage(cs clientset.Interface) string

func IsIPPoolConditionSetAsExpected added in v1.12.0 

func IsIPPoolConditionSetAsExpected(ippool *apiv1.IPPool, conditionType apiv1.ConditionType, wantTrue bool) bool

IsIPPoolConditionSetAsExpected returns a wantTrue value if the ippool has a match to the conditionType, otherwise returns an opposite value of the wantTrue with detailed logging.

func IsProviderNetworkConditionSetAsExpected added in v1.11.0 

func IsProviderNetworkConditionSetAsExpected(pn *apiv1.ProviderNetwork, node string, conditionType apiv1.ConditionType, wantTrue bool) bool

IsProviderNetworkConditionSetAsExpected returns a wantTrue value if the subnet has a match to the conditionType, otherwise returns an opposite value of the wantTrue with detailed logging.

func IsQoSPolicyConditionSetAsExpected added in v1.12.0 

func IsQoSPolicyConditionSetAsExpected(qosPolicy *apiv1.QoSPolicy, conditionType apiv1.ConditionType, wantTrue bool) bool

IsQoSPolicyConditionSetAsExpected returns a wantTrue value if the qosPolicy has a match to the conditionType, otherwise returns an opposite value of the wantTrue with detailed logging.

func IsSubnetConditionSetAsExpected added in v1.11.0 

func IsSubnetConditionSetAsExpected(subnet *apiv1.Subnet, conditionType apiv1.ConditionType, wantTrue bool) bool

IsSubnetConditionSetAsExpected returns a wantTrue value if the subnet has a match to the conditionType, otherwise returns an opposite value of the wantTrue with detailed logging.

func KubectlExec added in v1.11.0 

func KubectlExec(namespace, pod string, cmd ...string) (stdout, stderr []byte, err error)

func Logf added in v1.11.0 

func Logf(format string, args ...interface{})

Logf logs the info.

func MakeDeployment added in v1.12.0 

func MakeDeployment(name string, replicas int32, podLabels, podAnnotations map[string]string, containerName, image string, strategyType appsv1.DeploymentStrategyType) *appsv1.Deployment

func MakeEndpoints added in v1.12.0 

func MakeEndpoints(name string, annotations map[string]string, subset []corev1.EndpointSubset) *corev1.Endpoints

func MakeIP added in v1.12.1 

func MakeIP(name, ns, subnet string) *apiv1.IP

func MakeIPPool added in v1.12.0 

func MakeIPPool(name, subnet string, ips, namespaces []string) *apiv1.IPPool

func MakeIptablesDnatRule added in v1.12.0 

func MakeIptablesDnatRule(name, eip, externalPort, protocol, internalIP, internalPort string) *apiv1.IptablesDnatRule

func MakeIptablesEIP added in v1.12.0 

func MakeIptablesEIP(name, v4ip, v6ip, mac, natGwDp, externalSubnet, qosPolicyName string) *apiv1.IptablesEIP

func MakeIptablesFIPRule added in v1.12.0 

func MakeIptablesFIPRule(name, eip, internalIP string) *apiv1.IptablesFIPRule

func MakeIptablesSnatRule added in v1.12.0 

func MakeIptablesSnatRule(name, eip, internalCIDR string) *apiv1.IptablesSnatRule

func MakeNetworkAttachmentDefinition added in v1.12.0 

func MakeNetworkAttachmentDefinition(name, namespace, conf string) *apiv1.NetworkAttachmentDefinition

func MakeOvnDnatRule added in v1.12.0 

func MakeOvnDnatRule(name, ovnEip, ipType, ipName, vpc, v4Ip, internalPort, externalPort, protocol string) *apiv1.OvnDnatRule

func MakeOvnEip added in v1.12.0 

func MakeOvnEip(name, subnet, v4ip, v6ip, mac, usage string) *apiv1.OvnEip

func MakeOvnFip added in v1.12.0 

func MakeOvnFip(name, ovnEip, ipType, ipName, vpc, v4Ip string) *apiv1.OvnFip

func MakeOvnSnatRule added in v1.12.0 

func MakeOvnSnatRule(name, ovnEip, vpcSubnet, ipName, vpc, v4IpCidr string) *apiv1.OvnSnatRule

func MakePod added in v1.11.0 

func MakePod(ns, name string, labels, annotations map[string]string, image string, command, args []string) *corev1.Pod

func MakeProviderNetwork added in v1.11.0 

func MakeProviderNetwork(name string, exchangeLinkName bool, defaultInterface string, customInterfaces map[string][]string, excludeNodes []string) *apiv1.ProviderNetwork

func MakeQoSPolicy added in v1.12.0 

func MakeQoSPolicy(name string, shared bool, qosType apiv1.QoSPolicyBindingType, rules apiv1.QoSPolicyBandwidthLimitRules) *apiv1.QoSPolicy

func MakeService added in v1.11.0 

func MakeService(name string, svcType corev1.ServiceType, annotations, selector map[string]string, ports []corev1.ServicePort, affinity corev1.ServiceAffinity) *corev1.Service

func MakeStatefulSet added in v1.12.0 

func MakeStatefulSet(name, svcName string, replicas int32, labels map[string]string, image string) *appsv1.StatefulSet

func MakeSubnet added in v1.11.0 

func MakeSubnet(name, vlan, cidr, gateway, vpc, provider string, excludeIPs, gatewayNodes, namespaces []string) *apiv1.Subnet

func MakeSwitchLBRule added in v1.12.0 

func MakeSwitchLBRule(name, namespace, vip string, sessionAffinity corev1.ServiceAffinity, annotations map[string]string, slector, endpoints []string, ports []apiv1.SlrPort) *apiv1.SwitchLBRule

func MakeVip added in v1.12.0 

func MakeVip(namespaceName, name, subnet, v4ip, v6ip, vipType string) *apiv1.Vip

func MakeVlan added in v1.11.0 

func MakeVlan(name, provider string, id int) *apiv1.Vlan

func MakeVpc added in v1.12.0 

func MakeVpc(name, gatewayV4 string, enableExternal, enableBfd bool, namespaces []string) *kubeovnv1.Vpc

func MakeVpcNatGateway added in v1.12.0 

func MakeVpcNatGateway(name, vpc, subnet, lanIP, externalSubnet, qosPolicyName string) *apiv1.VpcNatGateway

func NextIP added in v1.12.0 

func NextIP(ip string) string

func OrderedDescribe added in v1.11.0 

func OrderedDescribe(text string, body func()) bool

func PrevIP added in v1.12.0 

func PrevIP(ip string) string

func PrunedStack added in v1.11.0 

func PrunedStack(skip int) []byte

PrunedStack is a wrapper around debug.Stack() that removes information about the current goroutine and optionally skips some of the initial stack entries. With skip == 0, the returned stack will start with the caller of PruneStack. From the remaining entries it automatically filters out useless ones like entries coming from Ginkgo.

This is a modified copy of PruneStack in https://github.com/onsi/ginkgo/v2/blob/f90f37d87fa6b1dd9625e2b1e83c23ffae3de228/internal/codelocation/code_location.go#L25:

func RandomCIDR added in v1.11.0 

func RandomCIDR(family string) string

func RandomExcludeIPs added in v1.11.0 

func RandomExcludeIPs(cidr string, count int) []string

ipv4/ipv6 only

func RandomIPPool added in v1.11.0 

func RandomIPPool(cidr string, count int) []string

func RandomIPs added in v1.12.0 

func RandomIPs(cidr, sep string, count int) string

func RandomSuffix added in v1.11.0 

func RandomSuffix() string

RandomSuffix provides a random sequence to append to resources.

func SerialDescribe added in v1.11.3 

func SerialDescribe(text string, body func()) bool

func WaitUntil added in v1.12.0 

func WaitUntil(_, timeout time.Duration, cond func(context.Context) (bool, error), condDesc string)

WaitUntil waits the condition to be met

Types

type DaemonSetClient added in v1.12.0 

type DaemonSetClient struct {
	v1apps.DaemonSetInterface
	// contains filtered or unexported fields
}

func (*DaemonSetClient) Get added in v1.12.0 

func (c *DaemonSetClient) Get(name string) *appsv1.DaemonSet

func (*DaemonSetClient) GetPodOnNode added in v1.12.0 

func (c *DaemonSetClient) GetPodOnNode(ds *appsv1.DaemonSet, node string) (*corev1.Pod, error)

func (*DaemonSetClient) GetPods added in v1.12.0 

func (c *DaemonSetClient) GetPods(ds *appsv1.DaemonSet) (*corev1.PodList, error)

func (*DaemonSetClient) Patch added in v1.12.0 

func (c *DaemonSetClient) Patch(daemonset *appsv1.DaemonSet) *appsv1.DaemonSet

func (*DaemonSetClient) PatchSync added in v1.12.0 

func (c *DaemonSetClient) PatchSync(modifiedDaemonset *appsv1.DaemonSet) *appsv1.DaemonSet

func (*DaemonSetClient) RolloutStatus added in v1.12.0 

func (c *DaemonSetClient) RolloutStatus(name string) *appsv1.DaemonSet

type DeploymentClient added in v1.12.0 

type DeploymentClient struct {
	v1apps.DeploymentInterface
	// contains filtered or unexported fields
}

func (*DeploymentClient) Create added in v1.12.0 

func (c *DeploymentClient) Create(deploy *appsv1.Deployment) *appsv1.Deployment

Create creates a new deployment according to the framework specifications

func (*DeploymentClient) CreateSync added in v1.12.0 

func (c *DeploymentClient) CreateSync(deploy *appsv1.Deployment) *appsv1.Deployment

CreateSync creates a new deployment according to the framework specifications, and waits for it to complete.

func (*DeploymentClient) Delete added in v1.12.0 

func (c *DeploymentClient) Delete(name string)

Delete deletes a deployment if the deployment exists

func (*DeploymentClient) DeleteSync added in v1.12.0 

func (c *DeploymentClient) DeleteSync(name string)

DeleteSync deletes the deployment and waits for the deployment to disappear for `timeout`. If the deployment doesn't disappear before the timeout, it will fail the test.

func (*DeploymentClient) Get added in v1.12.0 

func (c *DeploymentClient) Get(name string) *appsv1.Deployment

func (*DeploymentClient) GetAllPods added in v1.12.1 

func (c *DeploymentClient) GetAllPods(deploy *appsv1.Deployment) (*corev1.PodList, error)

func (*DeploymentClient) GetPods added in v1.12.0 

func (c *DeploymentClient) GetPods(deploy *appsv1.Deployment) (*corev1.PodList, error)

func (*DeploymentClient) Patch added in v1.12.0 

func (c *DeploymentClient) Patch(original, modified *appsv1.Deployment) *appsv1.Deployment

func (*DeploymentClient) PatchSync added in v1.12.0 

func (c *DeploymentClient) PatchSync(original, modified *appsv1.Deployment) *appsv1.Deployment

func (*DeploymentClient) Restart added in v1.12.0 

func (c *DeploymentClient) Restart(deploy *appsv1.Deployment) *appsv1.Deployment

Restart restarts the deployment as kubectl does

func (*DeploymentClient) RestartSync added in v1.12.0 

func (c *DeploymentClient) RestartSync(deploy *appsv1.Deployment) *appsv1.Deployment

RestartSync restarts the deployment and wait it to be ready

func (*DeploymentClient) RolloutStatus added in v1.12.0 

func (c *DeploymentClient) RolloutStatus(name string) *appsv1.Deployment

func (*DeploymentClient) SetScale added in v1.12.1 

func (c *DeploymentClient) SetScale(deployment string, replicas int32)

func (*DeploymentClient) WaitToComplete added in v1.12.0 

func (c *DeploymentClient) WaitToComplete(deploy *appsv1.Deployment) error

func (*DeploymentClient) WaitToDisappear added in v1.12.0 

func (c *DeploymentClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified deployment to disappear.

type EndpointsClient added in v1.12.0 

type EndpointsClient struct {
	v1core.EndpointsInterface
	// contains filtered or unexported fields
}

EndpointsClient is a struct for endpoint client.

func (*EndpointsClient) Create added in v1.12.0 

func (c *EndpointsClient) Create(endpoints *corev1.Endpoints) *corev1.Endpoints

Create creates a new endpoints according to the framework specifications

func (*EndpointsClient) CreateSync added in v1.12.0 

func (c *EndpointsClient) CreateSync(endpoints *corev1.Endpoints, cond func(s *corev1.Endpoints) (bool, error), condDesc string) *corev1.Endpoints

CreateSync creates a new endpoints according to the framework specifications, and waits for it to be updated.

func (*EndpointsClient) Delete added in v1.12.0 

func (c *EndpointsClient) Delete(name string)

Delete deletes a endpoints if the endpoints exists

func (*EndpointsClient) DeleteSync added in v1.12.0 

func (c *EndpointsClient) DeleteSync(name string)

DeleteSync deletes the endpoints and waits for the endpoints to disappear for `timeout`. If the endpoints doesn't disappear before the timeout, it will fail the test.

func (*EndpointsClient) Get added in v1.12.0 

func (c *EndpointsClient) Get(name string) *corev1.Endpoints

func (*EndpointsClient) Patch added in v1.12.0 

func (c *EndpointsClient) Patch(original, modified *corev1.Endpoints) *corev1.Endpoints

Patch patches the endpoints

func (*EndpointsClient) PatchSync added in v1.12.0 

func (c *EndpointsClient) PatchSync(original, modified *corev1.Endpoints, cond func(s *corev1.Endpoints) (bool, error), condDesc string) *corev1.Endpoints

PatchSync patches the endpoints and waits the endpoints to meet the condition

func (*EndpointsClient) WaitToDisappear added in v1.12.0 

func (c *EndpointsClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified endpoints to disappear.

func (*EndpointsClient) WaitUntil added in v1.12.0 

func (c *EndpointsClient) WaitUntil(name string, cond func(s *corev1.Endpoints) (bool, error), condDesc string, _, timeout time.Duration) *corev1.Endpoints

WaitUntil waits the given timeout duration for the specified condition to be met.

type EventClient added in v1.11.0 

type EventClient struct {
	typedcorev1.EventInterface
	// contains filtered or unexported fields
}

func (*EventClient) WaitToHaveEvent added in v1.11.0 

func (c *EventClient) WaitToHaveEvent(kind, name, eventType, reason, sourceComponent, sourceHost string) []corev1.Event

WaitToHaveEvent waits the provided resource to have the specified event(s)

type Framework 

type Framework struct {
	KubeContext string
	*framework.Framework
	KubeOVNClientSet kubeovncs.Interface
	AttachNetClient  attachnetclientset.Interface
	// master/release-1.10/...
	ClusterVersion string
	// 999.999 for master
	ClusterVersionMajor uint
	ClusterVersionMinor uint
	// ipv4/ipv6/dual
	ClusterIPFamily string
	// overlay/underlay/underlay-hairpin
	ClusterNetworkMode string
}

func NewDefaultFramework added in v1.11.0 

func NewDefaultFramework(baseName string) *Framework

func NewFrameworkWithContext added in v1.11.0 

func NewFrameworkWithContext(baseName, kubeContext string) *Framework

func (*Framework) BeforeEach added in v1.11.0 

func (f *Framework) BeforeEach()

BeforeEach gets a kube-ovn client

func (*Framework) DaemonSetClient added in v1.12.0 

func (f *Framework) DaemonSetClient() *DaemonSetClient

func (*Framework) DaemonSetClientNS added in v1.12.0 

func (f *Framework) DaemonSetClientNS(namespace string) *DaemonSetClient

func (*Framework) DeploymentClient added in v1.12.0 

func (f *Framework) DeploymentClient() *DeploymentClient

func (*Framework) DeploymentClientNS added in v1.12.0 

func (f *Framework) DeploymentClientNS(namespace string) *DeploymentClient

func (*Framework) EndpointClient added in v1.12.0 

func (f *Framework) EndpointClient() *EndpointsClient

func (*Framework) EndpointsClientNS added in v1.12.0 

func (f *Framework) EndpointsClientNS(namespace string) *EndpointsClient

func (*Framework) EventClient added in v1.11.0 

func (f *Framework) EventClient() *EventClient

func (*Framework) EventClientNS added in v1.12.0 

func (f *Framework) EventClientNS(namespace string) *EventClient

func (*Framework) HasIPv4 added in v1.12.0 

func (f *Framework) HasIPv4() bool

func (*Framework) HasIPv6 added in v1.12.0 

func (f *Framework) HasIPv6() bool

func (*Framework) IPClient added in v1.12.1 

func (f *Framework) IPClient() *IPClient

func (*Framework) IPPoolClient added in v1.12.0 

func (f *Framework) IPPoolClient() *IPPoolClient

func (*Framework) IptablesDnatClient added in v1.12.0 

func (f *Framework) IptablesDnatClient() *IptablesDnatClient

func (*Framework) IptablesEIPClient added in v1.12.0 

func (f *Framework) IptablesEIPClient() *IptablesEIPClient

func (*Framework) IptablesFIPClient added in v1.12.0 

func (f *Framework) IptablesFIPClient() *IptablesFIPClient

func (*Framework) IptablesSnatClient added in v1.12.0 

func (f *Framework) IptablesSnatClient() *IptablesSnatClient

func (*Framework) IsDual added in v1.12.0 

func (f *Framework) IsDual() bool

func (*Framework) IsIPv4 added in v1.12.0 

func (f *Framework) IsIPv4() bool

func (*Framework) IsIPv6 added in v1.12.0 

func (f *Framework) IsIPv6() bool

func (*Framework) NamespaceClient added in v1.12.0 

func (f *Framework) NamespaceClient() *NamespaceClient

func (*Framework) NetworkAttachmentDefinitionClient added in v1.12.0 

func (f *Framework) NetworkAttachmentDefinitionClient(namespace string) *NetworkAttachmentDefinitionClient

func (*Framework) NetworkPolicyClient added in v1.12.0 

func (f *Framework) NetworkPolicyClient() *NetworkPolicyClient

func (*Framework) NetworkPolicyClientNS added in v1.12.0 

func (f *Framework) NetworkPolicyClientNS(namespace string) *NetworkPolicyClient

func (*Framework) OvnDnatRuleClient added in v1.12.0 

func (f *Framework) OvnDnatRuleClient() *OvnDnatRuleClient

func (*Framework) OvnEipClient added in v1.12.0 

func (f *Framework) OvnEipClient() *OvnEipClient

func (*Framework) OvnFipClient added in v1.12.0 

func (f *Framework) OvnFipClient() *OvnFipClient

func (*Framework) OvnSnatRuleClient added in v1.12.0 

func (f *Framework) OvnSnatRuleClient() *OvnSnatRuleClient

func (*Framework) PodClient added in v1.11.0 

func (f *Framework) PodClient() *PodClient

func (*Framework) PodClientNS added in v1.12.0 

func (f *Framework) PodClientNS(namespace string) *PodClient

func (*Framework) ProviderNetworkClient added in v1.11.0 

func (f *Framework) ProviderNetworkClient() *ProviderNetworkClient

func (*Framework) QoSPolicyClient added in v1.12.0 

func (f *Framework) QoSPolicyClient() *QoSPolicyClient

func (*Framework) ServiceClient added in v1.11.0 

func (f *Framework) ServiceClient() *ServiceClient

func (*Framework) ServiceClientNS added in v1.12.0 

func (f *Framework) ServiceClientNS(namespace string) *ServiceClient

func (*Framework) SkipVersionPriorTo added in v1.11.0 

func (f *Framework) SkipVersionPriorTo(major, minor uint, reason string)

func (*Framework) StatefulSetClient added in v1.12.0 

func (f *Framework) StatefulSetClient() *StatefulSetClient

func (*Framework) StatefulSetClientNS added in v1.12.0 

func (f *Framework) StatefulSetClientNS(namespace string) *StatefulSetClient

func (*Framework) SubnetClient added in v1.11.0 

func (f *Framework) SubnetClient() *SubnetClient

func (*Framework) SwitchLBRuleClient added in v1.12.0 

func (f *Framework) SwitchLBRuleClient() *SwitchLBRuleClient

func (*Framework) SwitchLBRuleClientNS added in v1.12.0 

func (f *Framework) SwitchLBRuleClientNS(namespace string) *SwitchLBRuleClient

func (*Framework) VersionPriorTo added in v1.12.0 

func (f *Framework) VersionPriorTo(major, minor uint) bool

func (*Framework) VipClient added in v1.12.0 

func (f *Framework) VipClient() *VipClient

func (*Framework) VlanClient added in v1.11.0 

func (f *Framework) VlanClient() *VlanClient

func (*Framework) VpcClient added in v1.12.0 

func (f *Framework) VpcClient() *VpcClient

func (*Framework) VpcNatGatewayClient added in v1.12.0 

func (f *Framework) VpcNatGatewayClient() *VpcNatGatewayClient

type IPClient added in v1.12.1 

type IPClient struct {
	v1.IPInterface
	// contains filtered or unexported fields
}

IPClient is a struct for IP client.

func (*IPClient) Create added in v1.12.1 

func (c *IPClient) Create(iP *apiv1.IP) *apiv1.IP

Create creates a new IP according to the framework specifications

func (*IPClient) CreateSync added in v1.12.1 

func (c *IPClient) CreateSync(iP *apiv1.IP) *apiv1.IP

CreateSync creates a new IP according to the framework specifications, and waits for it to be ready.

func (*IPClient) Delete added in v1.12.1 

func (c *IPClient) Delete(name string)

Delete deletes a IP if the IP exists

func (*IPClient) DeleteSync added in v1.12.1 

func (c *IPClient) DeleteSync(name string)

DeleteSync deletes the IP and waits for the IP to disappear for `timeout`. If the IP doesn't disappear before the timeout, it will fail the test.

func (*IPClient) Get added in v1.12.1 

func (c *IPClient) Get(name string) *apiv1.IP

func (*IPClient) Patch added in v1.12.1 

func (c *IPClient) Patch(original, modified *apiv1.IP, timeout time.Duration) *apiv1.IP

Patch patches the IP

func (*IPClient) WaitToBeReady added in v1.12.1 

func (c *IPClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the IP is ready within timeout.

func (*IPClient) WaitToDisappear added in v1.12.1 

func (c *IPClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified IP to disappear.

type IPPoolClient added in v1.12.0 

type IPPoolClient struct {
	v1.IPPoolInterface
	// contains filtered or unexported fields
}

IPPoolClient is a struct for ippool client.

func (*IPPoolClient) Create added in v1.12.0 

func (c *IPPoolClient) Create(ippool *apiv1.IPPool) *apiv1.IPPool

Create creates a new ippool according to the framework specifications

func (*IPPoolClient) CreateSync added in v1.12.0 

func (c *IPPoolClient) CreateSync(ippool *apiv1.IPPool) *apiv1.IPPool

CreateSync creates a new ippool according to the framework specifications, and waits for it to be ready.

func (*IPPoolClient) Delete added in v1.12.0 

func (c *IPPoolClient) Delete(name string)

Delete deletes a ippool if the ippool exists

func (*IPPoolClient) DeleteSync added in v1.12.0 

func (c *IPPoolClient) DeleteSync(name string)

DeleteSync deletes the ippool and waits for the ippool to disappear for `timeout`. If the ippool doesn't disappear before the timeout, it will fail the test.

func (*IPPoolClient) Get added in v1.12.0 

func (c *IPPoolClient) Get(name string) *apiv1.IPPool

func (*IPPoolClient) Patch added in v1.12.0 

func (c *IPPoolClient) Patch(original, modified *apiv1.IPPool, timeout time.Duration) *apiv1.IPPool

Patch patches the ippool

func (*IPPoolClient) PatchSync added in v1.12.0 

func (c *IPPoolClient) PatchSync(original, modified *apiv1.IPPool) *apiv1.IPPool

PatchSync patches the ippool and waits for the ippool to be ready for `timeout`. If the ippool doesn't become ready before the timeout, it will fail the test.

func (*IPPoolClient) Update added in v1.12.0 

func (c *IPPoolClient) Update(ippool *apiv1.IPPool, options metav1.UpdateOptions, timeout time.Duration) *apiv1.IPPool

Update updates the ippool

func (*IPPoolClient) UpdateSync added in v1.12.0 

func (c *IPPoolClient) UpdateSync(ippool *apiv1.IPPool, options metav1.UpdateOptions, timeout time.Duration) *apiv1.IPPool

UpdateSync updates the ippool and waits for the ippool to be ready for `timeout`. If the ippool doesn't become ready before the timeout, it will fail the test.

func (*IPPoolClient) WaitConditionToBe added in v1.12.0 

func (c *IPPoolClient) WaitConditionToBe(name string, conditionType apiv1.ConditionType, wantTrue bool, timeout time.Duration) bool

WaitConditionToBe returns whether ippool "name's" condition state matches wantTrue within timeout. If wantTrue is true, it will ensure the ippool condition status is ConditionTrue; if it's false, it ensures the ippool condition is in any state other than ConditionTrue (e.g. not true or unknown).

func (*IPPoolClient) WaitToBeReady added in v1.12.0 

func (c *IPPoolClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ippool is ready within timeout.

func (*IPPoolClient) WaitToBeUpdated added in v1.12.0 

func (c *IPPoolClient) WaitToBeUpdated(ippool *apiv1.IPPool, timeout time.Duration) bool

WaitToBeUpdated returns whether the ippool is updated within timeout.

func (*IPPoolClient) WaitToDisappear added in v1.12.0 

func (c *IPPoolClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified ippool to disappear.

func (*IPPoolClient) WaitUntil added in v1.12.0 

func (c *IPPoolClient) WaitUntil(name string, cond func(s *apiv1.IPPool) (bool, error), condDesc string, interval, timeout time.Duration) *apiv1.IPPool

WaitUntil waits the given timeout duration for the specified condition to be met.

type IptablesDnatClient added in v1.12.0 

type IptablesDnatClient struct {
	v1.IptablesDnatRuleInterface
	// contains filtered or unexported fields
}

IptablesDnatClient is a struct for iptables dnat client.

func (*IptablesDnatClient) Create added in v1.12.0 

func (c *IptablesDnatClient) Create(dnat *apiv1.IptablesDnatRule) *apiv1.IptablesDnatRule

Create creates a new iptables dnat according to the framework specifications

func (*IptablesDnatClient) CreateSync added in v1.12.0 

func (c *IptablesDnatClient) CreateSync(dnat *apiv1.IptablesDnatRule) *apiv1.IptablesDnatRule

CreateSync creates a new iptables dnat according to the framework specifications, and waits for it to be ready.

func (*IptablesDnatClient) Delete added in v1.12.0 

func (c *IptablesDnatClient) Delete(name string)

Delete deletes a iptables dnat if the iptables dnat exists

func (*IptablesDnatClient) DeleteSync added in v1.12.0 

func (c *IptablesDnatClient) DeleteSync(name string)

DeleteSync deletes the iptables dnat and waits for the iptables dnat to disappear for `timeout`. If the iptables dnat doesn't disappear before the timeout, it will fail the test.

func (*IptablesDnatClient) Get added in v1.12.0 

func (c *IptablesDnatClient) Get(name string) *apiv1.IptablesDnatRule

func (*IptablesDnatClient) Patch added in v1.12.0 

func (c *IptablesDnatClient) Patch(original, modified *apiv1.IptablesDnatRule) *apiv1.IptablesDnatRule

Patch patches the iptables dnat

func (*IptablesDnatClient) PatchSync added in v1.12.0 

func (c *IptablesDnatClient) PatchSync(original, modified *apiv1.IptablesDnatRule, _ []string, timeout time.Duration) *apiv1.IptablesDnatRule

PatchSync patches the iptables dnat and waits for the iptables dnat to be ready for `timeout`. If the iptables dnat doesn't become ready before the timeout, it will fail the test.

func (*IptablesDnatClient) WaitToBeReady added in v1.12.0 

func (c *IptablesDnatClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the iptables dnat is ready within timeout.

func (*IptablesDnatClient) WaitToBeUpdated added in v1.12.0 

func (c *IptablesDnatClient) WaitToBeUpdated(dnat *apiv1.IptablesDnatRule, timeout time.Duration) bool

WaitToBeUpdated returns whether the iptables dnat is updated within timeout.

func (*IptablesDnatClient) WaitToDisappear added in v1.12.0 

func (c *IptablesDnatClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified iptables DNAT rule to disappear.

type IptablesEIPClient added in v1.12.0 

type IptablesEIPClient struct {
	v1.IptablesEIPInterface
	// contains filtered or unexported fields
}

IptablesEIPClient is a struct for iptables eip client.

func (*IptablesEIPClient) Create added in v1.12.0 

func (c *IptablesEIPClient) Create(eip *apiv1.IptablesEIP) *apiv1.IptablesEIP

Create creates a new iptables eip according to the framework specifications

func (*IptablesEIPClient) CreateSync added in v1.12.0 

func (c *IptablesEIPClient) CreateSync(eip *apiv1.IptablesEIP) *apiv1.IptablesEIP

CreateSync creates a new iptables eip according to the framework specifications, and waits for it to be ready.

func (*IptablesEIPClient) Delete added in v1.12.0 

func (c *IptablesEIPClient) Delete(name string)

Delete deletes a iptables eip if the iptables eip exists

func (*IptablesEIPClient) DeleteSync added in v1.12.0 

func (c *IptablesEIPClient) DeleteSync(name string)

DeleteSync deletes the iptables eip and waits for the iptables eip to disappear for `timeout`. If the iptables eip doesn't disappear before the timeout, it will fail the test.

func (*IptablesEIPClient) Get added in v1.12.0 

func (c *IptablesEIPClient) Get(name string) *apiv1.IptablesEIP

func (*IptablesEIPClient) Patch added in v1.12.0 

func (c *IptablesEIPClient) Patch(original, modified *apiv1.IptablesEIP) *apiv1.IptablesEIP

Patch patches the iptables eip

func (*IptablesEIPClient) PatchQoSPolicySync added in v1.12.0 

func (c *IptablesEIPClient) PatchQoSPolicySync(eipName, qosPolicyName string) *apiv1.IptablesEIP

PatchQoS patches the vpc nat gw and waits for the qos to be ready for `timeout`. If the qos doesn't become ready before the timeout, it will fail the test.

func (*IptablesEIPClient) PatchSync added in v1.12.0 

func (c *IptablesEIPClient) PatchSync(original, modified *apiv1.IptablesEIP, _ []string, timeout time.Duration) *apiv1.IptablesEIP

PatchSync patches the iptables eip and waits for the iptables eip to be ready for `timeout`. If the iptables eip doesn't become ready before the timeout, it will fail the test.

func (*IptablesEIPClient) WaitToBeReady added in v1.12.0 

func (c *IptablesEIPClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the iptables eip is ready within timeout.

func (*IptablesEIPClient) WaitToBeUpdated added in v1.12.0 

func (c *IptablesEIPClient) WaitToBeUpdated(eip *apiv1.IptablesEIP, timeout time.Duration) bool

WaitToBeUpdated returns whether the iptables eip is updated within timeout.

func (*IptablesEIPClient) WaitToDisappear added in v1.12.0 

func (c *IptablesEIPClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified iptables eip to disappear.

func (*IptablesEIPClient) WaitToQoSReady added in v1.12.0 

func (c *IptablesEIPClient) WaitToQoSReady(name string) bool

WaitToQoSReady returns whether the qos is ready within timeout.

type IptablesFIPClient added in v1.12.0 

type IptablesFIPClient struct {
	v1.IptablesFIPRuleInterface
	// contains filtered or unexported fields
}

IptablesFIPClient is a struct for iptables fip client.

func (*IptablesFIPClient) Create added in v1.12.0 

func (c *IptablesFIPClient) Create(fip *apiv1.IptablesFIPRule) *apiv1.IptablesFIPRule

Create creates a new iptables fip according to the framework specifications

func (*IptablesFIPClient) CreateSync added in v1.12.0 

func (c *IptablesFIPClient) CreateSync(fip *apiv1.IptablesFIPRule) *apiv1.IptablesFIPRule

CreateSync creates a new iptables fip according to the framework specifications, and waits for it to be ready.

func (*IptablesFIPClient) Delete added in v1.12.0 

func (c *IptablesFIPClient) Delete(name string)

Delete deletes a iptables fip if the iptables fip exists

func (*IptablesFIPClient) DeleteSync added in v1.12.0 

func (c *IptablesFIPClient) DeleteSync(name string)

DeleteSync deletes the iptables fip and waits for the iptables fip to disappear for `timeout`. If the iptables fip doesn't disappear before the timeout, it will fail the test.

func (*IptablesFIPClient) Get added in v1.12.0 

func (c *IptablesFIPClient) Get(name string) *apiv1.IptablesFIPRule

func (*IptablesFIPClient) Patch added in v1.12.0 

func (c *IptablesFIPClient) Patch(original, modified *apiv1.IptablesFIPRule) *apiv1.IptablesFIPRule

Patch patches the iptables fip

func (*IptablesFIPClient) PatchSync added in v1.12.0 

func (c *IptablesFIPClient) PatchSync(original, modified *apiv1.IptablesFIPRule, _ []string, timeout time.Duration) *apiv1.IptablesFIPRule

PatchSync patches the iptables fip and waits for the iptables fip to be ready for `timeout`. If the iptables fip doesn't become ready before the timeout, it will fail the test.

func (*IptablesFIPClient) WaitToBeReady added in v1.12.0 

func (c *IptablesFIPClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the iptables fip is ready within timeout.

func (*IptablesFIPClient) WaitToBeUpdated added in v1.12.0 

func (c *IptablesFIPClient) WaitToBeUpdated(fip *apiv1.IptablesFIPRule, timeout time.Duration) bool

WaitToBeUpdated returns whether the iptables fip is updated within timeout.

func (*IptablesFIPClient) WaitToDisappear added in v1.12.0 

func (c *IptablesFIPClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified iptables FIP rule to disappear.

type IptablesSnatClient added in v1.12.0 

type IptablesSnatClient struct {
	v1.IptablesSnatRuleInterface
	// contains filtered or unexported fields
}

IptablesSnatClient is a struct for iptables snat client.

func (*IptablesSnatClient) Create added in v1.12.0 

func (c *IptablesSnatClient) Create(snat *apiv1.IptablesSnatRule) *apiv1.IptablesSnatRule

Create creates a new iptables snat according to the framework specifications

func (*IptablesSnatClient) CreateSync added in v1.12.0 

func (c *IptablesSnatClient) CreateSync(snat *apiv1.IptablesSnatRule) *apiv1.IptablesSnatRule

CreateSync creates a new iptables snat according to the framework specifications, and waits for it to be ready.

func (*IptablesSnatClient) Delete added in v1.12.0 

func (c *IptablesSnatClient) Delete(name string)

Delete deletes a iptables snat if the iptables snat exists

func (*IptablesSnatClient) DeleteSync added in v1.12.0 

func (c *IptablesSnatClient) DeleteSync(name string)

DeleteSync deletes the iptables snat and waits for the iptables snat to disappear for `timeout`. If the iptables snat doesn't disappear before the timeout, it will fail the test.

func (*IptablesSnatClient) Get added in v1.12.0 

func (c *IptablesSnatClient) Get(name string) *apiv1.IptablesSnatRule

func (*IptablesSnatClient) Patch added in v1.12.0 

func (c *IptablesSnatClient) Patch(original, modified *apiv1.IptablesSnatRule) *apiv1.IptablesSnatRule

Patch patches the iptables snat

func (*IptablesSnatClient) PatchSync added in v1.12.0 

func (c *IptablesSnatClient) PatchSync(original, modified *apiv1.IptablesSnatRule, _ []string, timeout time.Duration) *apiv1.IptablesSnatRule

PatchSync patches the iptables snat and waits for the iptables snat to be ready for `timeout`. If the iptables snat doesn't become ready before the timeout, it will fail the test.

func (*IptablesSnatClient) WaitToBeReady added in v1.12.0 

func (c *IptablesSnatClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the iptables snat is ready within timeout.

func (*IptablesSnatClient) WaitToBeUpdated added in v1.12.0 

func (c *IptablesSnatClient) WaitToBeUpdated(snat *apiv1.IptablesSnatRule, timeout time.Duration) bool

WaitToBeUpdated returns whether the iptables snat is updated within timeout.

func (*IptablesSnatClient) WaitToDisappear added in v1.12.0 

func (c *IptablesSnatClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified iptables SNAT rule to disappear.

type NamespaceClient added in v1.12.0 

type NamespaceClient struct {
	v1core.NamespaceInterface
	// contains filtered or unexported fields
}

NamespaceClient is a struct for namespace client.

func (*NamespaceClient) Create added in v1.12.0 

func (c *NamespaceClient) Create(ns *corev1.Namespace) *corev1.Namespace

Create creates a new namespace according to the framework specifications

func (*NamespaceClient) Delete added in v1.12.0 

func (c *NamespaceClient) Delete(name string)

Delete deletes a namespace if the namespace exists

func (*NamespaceClient) DeleteSync added in v1.12.0 

func (c *NamespaceClient) DeleteSync(name string)

DeleteSync deletes the namespace and waits for the namespace to disappear for `timeout`. If the namespace doesn't disappear before the timeout, it will fail the test.

func (*NamespaceClient) Get added in v1.12.0 

func (c *NamespaceClient) Get(name string) *corev1.Namespace

func (*NamespaceClient) Patch added in v1.12.0 

func (c *NamespaceClient) Patch(original, modified *corev1.Namespace) *corev1.Namespace

func (*NamespaceClient) WaitToDisappear added in v1.12.0 

func (c *NamespaceClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified namespace to disappear.

type NetworkAttachmentDefinitionClient added in v1.12.0 

type NetworkAttachmentDefinitionClient struct {
	v1.NetworkAttachmentDefinitionInterface
	// contains filtered or unexported fields
}

NetworkAttachmentDefinitionClient is a struct for nad client.

func (*NetworkAttachmentDefinitionClient) Create added in v1.12.0 

func (c *NetworkAttachmentDefinitionClient) Create(nad *apiv1.NetworkAttachmentDefinition) *apiv1.NetworkAttachmentDefinition

Create creates a new nad according to the framework specifications

func (*NetworkAttachmentDefinitionClient) Delete added in v1.12.0 

func (c *NetworkAttachmentDefinitionClient) Delete(name string)

Delete deletes a nad if the nad exists

func (*NetworkAttachmentDefinitionClient) Get added in v1.12.0 

func (c *NetworkAttachmentDefinitionClient) Get(name string) *apiv1.NetworkAttachmentDefinition

type NetworkPolicyClient added in v1.12.0 

type NetworkPolicyClient struct {
	v1net.NetworkPolicyInterface
	// contains filtered or unexported fields
}

NetworkPolicyClient is a struct for network policy client.

func (*NetworkPolicyClient) Create added in v1.12.0 

func (c *NetworkPolicyClient) Create(netpol *netv1.NetworkPolicy) *netv1.NetworkPolicy

Create creates a new network policy according to the framework specifications

func (*NetworkPolicyClient) Delete added in v1.12.0 

func (c *NetworkPolicyClient) Delete(name string)

Delete deletes a network policy if the network policy exists

func (*NetworkPolicyClient) DeleteSync added in v1.12.0 

func (c *NetworkPolicyClient) DeleteSync(name string)

DeleteSync deletes the network policy and waits for the network policy to disappear for `timeout`. If the network policy doesn't disappear before the timeout, it will fail the test.

func (*NetworkPolicyClient) Get added in v1.12.0 

func (c *NetworkPolicyClient) Get(name string) *netv1.NetworkPolicy

func (*NetworkPolicyClient) WaitToDisappear added in v1.12.0 

func (c *NetworkPolicyClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified network policy to disappear.

type OvnDnatRuleClient added in v1.12.0 

type OvnDnatRuleClient struct {
	v1.OvnDnatRuleInterface
	// contains filtered or unexported fields
}

OvnDnatRuleClient is a struct for ovn dnat client.

func (*OvnDnatRuleClient) Create added in v1.12.0 

func (c *OvnDnatRuleClient) Create(dnat *apiv1.OvnDnatRule) *apiv1.OvnDnatRule

Create creates a new ovn dnat according to the framework specifications

func (*OvnDnatRuleClient) CreateSync added in v1.12.0 

func (c *OvnDnatRuleClient) CreateSync(dnat *apiv1.OvnDnatRule) *apiv1.OvnDnatRule

CreateSync creates a new ovn dnat according to the framework specifications, and waits for it to be ready.

func (*OvnDnatRuleClient) Delete added in v1.12.0 

func (c *OvnDnatRuleClient) Delete(name string)

Delete deletes a ovn dnat if the ovn dnat exists

func (*OvnDnatRuleClient) DeleteSync added in v1.12.0 

func (c *OvnDnatRuleClient) DeleteSync(name string)

DeleteSync deletes the ovn dnat and waits for the ovn dnat to disappear for `timeout`. If the ovn dnat doesn't disappear before the timeout, it will fail the test.

func (*OvnDnatRuleClient) Get added in v1.12.0 

func (c *OvnDnatRuleClient) Get(name string) *apiv1.OvnDnatRule

func (*OvnDnatRuleClient) Patch added in v1.12.0 

func (c *OvnDnatRuleClient) Patch(original, modified *apiv1.OvnDnatRule) *apiv1.OvnDnatRule

Patch patches the ovn dnat

func (*OvnDnatRuleClient) PatchSync added in v1.12.0 

func (c *OvnDnatRuleClient) PatchSync(original, modified *apiv1.OvnDnatRule, _ []string, timeout time.Duration) *apiv1.OvnDnatRule

PatchSync patches the ovn dnat and waits for the ovn dnat to be ready for `timeout`. If the ovn dnat doesn't become ready before the timeout, it will fail the test.

func (*OvnDnatRuleClient) WaitToBeReady added in v1.12.0 

func (c *OvnDnatRuleClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ovn dnat is ready within timeout.

func (*OvnDnatRuleClient) WaitToBeUpdated added in v1.12.0 

func (c *OvnDnatRuleClient) WaitToBeUpdated(dnat *apiv1.OvnDnatRule, timeout time.Duration) bool

WaitToBeUpdated returns whether the ovn dnat is updated within timeout.

func (*OvnDnatRuleClient) WaitToDisappear added in v1.12.0 

func (c *OvnDnatRuleClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified ovn dnat to disappear.

type OvnEipClient added in v1.12.0 

type OvnEipClient struct {
	v1.OvnEipInterface
	// contains filtered or unexported fields
}

OvnEipClient is a struct for ovn eip client.

func (*OvnEipClient) Create added in v1.12.0 

func (c *OvnEipClient) Create(eip *apiv1.OvnEip) *apiv1.OvnEip

Create creates a new ovn eip according to the framework specifications

func (*OvnEipClient) CreateSync added in v1.12.0 

func (c *OvnEipClient) CreateSync(eip *apiv1.OvnEip) *apiv1.OvnEip

CreateSync creates a new ovn eip according to the framework specifications, and waits for it to be ready.

func (*OvnEipClient) Delete added in v1.12.0 

func (c *OvnEipClient) Delete(name string)

Delete deletes a ovn eip if the ovn eip exists

func (*OvnEipClient) DeleteSync added in v1.12.0 

func (c *OvnEipClient) DeleteSync(name string)

DeleteSync deletes the ovn eip and waits for the ovn eip to disappear for `timeout`. If the ovn eip doesn't disappear before the timeout, it will fail the test.

func (*OvnEipClient) Get added in v1.12.0 

func (c *OvnEipClient) Get(name string) *apiv1.OvnEip

func (*OvnEipClient) Patch added in v1.12.0 

func (c *OvnEipClient) Patch(original, modified *apiv1.OvnEip) *apiv1.OvnEip

Patch patches the ovn eip

func (*OvnEipClient) PatchSync added in v1.12.0 

func (c *OvnEipClient) PatchSync(original, modified *apiv1.OvnEip, _ []string, timeout time.Duration) *apiv1.OvnEip

PatchSync patches the ovn eip and waits for the ovn eip to be ready for `timeout`. If the ovn eip doesn't become ready before the timeout, it will fail the test.

func (*OvnEipClient) WaitToBeReady added in v1.12.0 

func (c *OvnEipClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ovn eip is ready within timeout.

func (*OvnEipClient) WaitToBeUpdated added in v1.12.0 

func (c *OvnEipClient) WaitToBeUpdated(eip *apiv1.OvnEip, timeout time.Duration) bool

WaitToBeUpdated returns whether the ovn eip is updated within timeout.

func (*OvnEipClient) WaitToDisappear added in v1.12.0 

func (c *OvnEipClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified OVN EIP to disappear.

type OvnFipClient added in v1.12.0 

type OvnFipClient struct {
	v1.OvnFipInterface
	// contains filtered or unexported fields
}

OvnFipClient is a struct for ovn fip client.

func (*OvnFipClient) Create added in v1.12.0 

func (c *OvnFipClient) Create(fip *apiv1.OvnFip) *apiv1.OvnFip

Create creates a new ovn fip according to the framework specifications

func (*OvnFipClient) CreateSync added in v1.12.0 

func (c *OvnFipClient) CreateSync(fip *apiv1.OvnFip) *apiv1.OvnFip

CreateSync creates a new ovn fip according to the framework specifications, and waits for it to be ready.

func (*OvnFipClient) Delete added in v1.12.0 

func (c *OvnFipClient) Delete(name string)

Delete deletes a ovn fip if the ovn fip exists

func (*OvnFipClient) DeleteSync added in v1.12.0 

func (c *OvnFipClient) DeleteSync(name string)

DeleteSync deletes the ovn fip and waits for the ovn fip to disappear for `timeout`. If the ovn fip doesn't disappear before the timeout, it will fail the test.

func (*OvnFipClient) Get added in v1.12.0 

func (c *OvnFipClient) Get(name string) *apiv1.OvnFip

func (*OvnFipClient) Patch added in v1.12.0 

func (c *OvnFipClient) Patch(original, modified *apiv1.OvnFip) *apiv1.OvnFip

Patch patches the ovn fip

func (*OvnFipClient) PatchSync added in v1.12.0 

func (c *OvnFipClient) PatchSync(original, modified *apiv1.OvnFip, _ []string, timeout time.Duration) *apiv1.OvnFip

PatchSync patches the ovn fip and waits for the ovn fip to be ready for `timeout`. If the ovn fip doesn't become ready before the timeout, it will fail the test.

func (*OvnFipClient) WaitToBeReady added in v1.12.0 

func (c *OvnFipClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ovn fip is ready within timeout.

func (*OvnFipClient) WaitToBeUpdated added in v1.12.0 

func (c *OvnFipClient) WaitToBeUpdated(fip *apiv1.OvnFip, timeout time.Duration) bool

WaitToBeUpdated returns whether the ovn fip is updated within timeout.

func (*OvnFipClient) WaitToDisappear added in v1.12.0 

func (c *OvnFipClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified ovn fip to disappear.

type OvnSnatRuleClient added in v1.12.0 

type OvnSnatRuleClient struct {
	v1.OvnSnatRuleInterface
	// contains filtered or unexported fields
}

OvnSnatRuleClient is a struct for ovn snat client.

func (*OvnSnatRuleClient) Create added in v1.12.0 

func (c *OvnSnatRuleClient) Create(snat *apiv1.OvnSnatRule) *apiv1.OvnSnatRule

Create creates a new ovn snat according to the framework specifications

func (*OvnSnatRuleClient) CreateSync added in v1.12.0 

func (c *OvnSnatRuleClient) CreateSync(snat *apiv1.OvnSnatRule) *apiv1.OvnSnatRule

CreateSync creates a new ovn snat according to the framework specifications, and waits for it to be ready.

func (*OvnSnatRuleClient) Delete added in v1.12.0 

func (c *OvnSnatRuleClient) Delete(name string)

Delete deletes a ovn snat if the ovn snat exists

func (*OvnSnatRuleClient) DeleteSync added in v1.12.0 

func (c *OvnSnatRuleClient) DeleteSync(name string)

DeleteSync deletes the ovn snat and waits for the ovn snat to disappear for `timeout`. If the ovn snat doesn't disappear before the timeout, it will fail the test.

func (*OvnSnatRuleClient) Get added in v1.12.0 

func (c *OvnSnatRuleClient) Get(name string) *apiv1.OvnSnatRule

func (*OvnSnatRuleClient) Patch added in v1.12.0 

func (c *OvnSnatRuleClient) Patch(original, modified *apiv1.OvnSnatRule) *apiv1.OvnSnatRule

Patch patches the ovn snat

func (*OvnSnatRuleClient) PatchSync added in v1.12.0 

func (c *OvnSnatRuleClient) PatchSync(original, modified *apiv1.OvnSnatRule, _ []string, timeout time.Duration) *apiv1.OvnSnatRule

PatchSync patches the ovn snat and waits for the ovn snat to be ready for `timeout`. If the ovn snat doesn't become ready before the timeout, it will fail the test.

func (*OvnSnatRuleClient) WaitToBeReady added in v1.12.0 

func (c *OvnSnatRuleClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ovn snat is ready within timeout.

func (*OvnSnatRuleClient) WaitToBeUpdated added in v1.12.0 

func (c *OvnSnatRuleClient) WaitToBeUpdated(snat *apiv1.OvnSnatRule, timeout time.Duration) bool

WaitToBeUpdated returns whether the ovn snat is updated within timeout.

func (*OvnSnatRuleClient) WaitToDisappear added in v1.12.0 

func (c *OvnSnatRuleClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified OVN SNAT rule to disappear.

type PodClient added in v1.11.0 

type PodClient struct {
	*e2epod.PodClient
	// contains filtered or unexported fields
}

func (*PodClient) Create added in v1.12.0 

func (c *PodClient) Create(pod *corev1.Pod) *corev1.Pod

func (*PodClient) CreateSync added in v1.12.0 

func (c *PodClient) CreateSync(pod *corev1.Pod) *corev1.Pod

func (*PodClient) Delete added in v1.12.0 

func (c *PodClient) Delete(name string) error

func (*PodClient) DeleteSync added in v1.11.0 

func (c *PodClient) DeleteSync(name string)

func (*PodClient) GetPod added in v1.12.0 

func (c *PodClient) GetPod(name string) *corev1.Pod

func (*PodClient) Patch added in v1.12.0 

func (c *PodClient) Patch(original, modified *corev1.Pod) *corev1.Pod

func (*PodClient) WaitForNotFound added in v1.12.0 

func (c *PodClient) WaitForNotFound(name string)

func (*PodClient) WaitForRunning added in v1.12.0 

func (c *PodClient) WaitForRunning(name string)

type ProviderNetworkClient added in v1.11.0 

type ProviderNetworkClient struct {
	v1.ProviderNetworkInterface
	// contains filtered or unexported fields
}

ProviderNetworkClient is a struct for provider network client.

func (*ProviderNetworkClient) Create added in v1.11.0 

func (c *ProviderNetworkClient) Create(pn *apiv1.ProviderNetwork) *apiv1.ProviderNetwork

Create creates a new provider network according to the framework specifications

func (*ProviderNetworkClient) CreateSync added in v1.11.0 

func (c *ProviderNetworkClient) CreateSync(pn *apiv1.ProviderNetwork) *apiv1.ProviderNetwork

CreateSync creates a new provider network according to the framework specifications, and waits for it to be ready.

func (*ProviderNetworkClient) Delete added in v1.11.0 

func (c *ProviderNetworkClient) Delete(name string)

Delete deletes a provider network if the provider network exists

func (*ProviderNetworkClient) DeleteSync added in v1.11.0 

func (c *ProviderNetworkClient) DeleteSync(name string)

DeleteSync deletes the provider network and waits for the provider network to disappear for `timeout`. If the provider network doesn't disappear before the timeout, it will fail the test.

func (*ProviderNetworkClient) Get added in v1.11.0 

func (c *ProviderNetworkClient) Get(name string) *apiv1.ProviderNetwork

func (*ProviderNetworkClient) Patch added in v1.11.0 

func (c *ProviderNetworkClient) Patch(original, modified *apiv1.ProviderNetwork) *apiv1.ProviderNetwork

Patch patches the provider network

func (*ProviderNetworkClient) PatchSync added in v1.11.0 

func (c *ProviderNetworkClient) PatchSync(original, modified *apiv1.ProviderNetwork, _ []string, timeout time.Duration) *apiv1.ProviderNetwork

PatchSync patches the provider network and waits for the provider network to be ready for `timeout`. If the provider network doesn't become ready before the timeout, it will fail the test.

func (*ProviderNetworkClient) WaitConditionToBe added in v1.11.0 

func (c *ProviderNetworkClient) WaitConditionToBe(name, node string, conditionType apiv1.ConditionType, wantTrue bool, deadline time.Time) bool

WaitConditionToBe returns whether provider network "name's" condition state matches wantTrue within timeout. If wantTrue is true, it will ensure the provider network condition status is ConditionTrue; if it's false, it ensures the provider network condition is in any state other than ConditionTrue (e.g. not true or unknown).

func (*ProviderNetworkClient) WaitToBeReady added in v1.11.0 

func (c *ProviderNetworkClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the provider network is ready within timeout.

func (*ProviderNetworkClient) WaitToBeUpdated added in v1.11.0 

func (c *ProviderNetworkClient) WaitToBeUpdated(pn *apiv1.ProviderNetwork, timeout time.Duration) bool

WaitToBeUpdated returns whether the provider network is updated within timeout.

func (*ProviderNetworkClient) WaitToDisappear added in v1.11.0 

func (c *ProviderNetworkClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified provider network to disappear.

type QoSPolicyClient added in v1.12.0 

type QoSPolicyClient struct {
	v1.QoSPolicyInterface
	// contains filtered or unexported fields
}

QoSPolicyClient is a struct for qosPolicy client.

func (*QoSPolicyClient) Create added in v1.12.0 

func (c *QoSPolicyClient) Create(qosPolicy *apiv1.QoSPolicy) *apiv1.QoSPolicy

Create creates a new qosPolicy according to the framework specifications

func (*QoSPolicyClient) CreateSync added in v1.12.0 

func (c *QoSPolicyClient) CreateSync(qosPolicy *apiv1.QoSPolicy) *apiv1.QoSPolicy

CreateSync creates a new qosPolicy according to the framework specifications, and waits for it to be ready.

func (*QoSPolicyClient) Delete added in v1.12.0 

func (c *QoSPolicyClient) Delete(name string)

Delete deletes a qosPolicy if the qosPolicy exists

func (*QoSPolicyClient) DeleteSync added in v1.12.0 

func (c *QoSPolicyClient) DeleteSync(name string)

DeleteSync deletes the qosPolicy and waits for the qosPolicy to disappear for `timeout`. If the qosPolicy doesn't disappear before the timeout, it will fail the test.

func (*QoSPolicyClient) Get added in v1.12.0 

func (c *QoSPolicyClient) Get(name string) *apiv1.QoSPolicy

func (*QoSPolicyClient) Patch added in v1.12.0 

func (c *QoSPolicyClient) Patch(original, modified *apiv1.QoSPolicy) *apiv1.QoSPolicy

Patch patches the qosPolicy

func (*QoSPolicyClient) PatchSync added in v1.12.0 

func (c *QoSPolicyClient) PatchSync(original, modified *apiv1.QoSPolicy) *apiv1.QoSPolicy

PatchSync patches the qosPolicy and waits for the qosPolicy to be ready for `timeout`. If the qosPolicy doesn't become ready before the timeout, it will fail the test.

func (*QoSPolicyClient) Update added in v1.12.0 

func (c *QoSPolicyClient) Update(qosPolicy *apiv1.QoSPolicy, options metav1.UpdateOptions, timeout time.Duration) *apiv1.QoSPolicy

Update updates the qosPolicy

func (*QoSPolicyClient) UpdateSync added in v1.12.0 

func (c *QoSPolicyClient) UpdateSync(qosPolicy *apiv1.QoSPolicy, options metav1.UpdateOptions, timeout time.Duration) *apiv1.QoSPolicy

UpdateSync updates the qosPolicy and waits for the qosPolicy to be ready for `timeout`. If the qosPolicy doesn't become ready before the timeout, it will fail the test.

func (*QoSPolicyClient) WaitConditionToBe added in v1.12.0 

func (c *QoSPolicyClient) WaitConditionToBe(name string, conditionType apiv1.ConditionType, wantTrue bool, timeout time.Duration) bool

WaitConditionToBe returns whether qosPolicy "name's" condition state matches wantTrue within timeout. If wantTrue is true, it will ensure the qosPolicy condition status is ConditionTrue; if it's false, it ensures the qosPolicy condition is in any state other than ConditionTrue (e.g. not true or unknown).

func (*QoSPolicyClient) WaitToBeReady added in v1.12.0 

func (c *QoSPolicyClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the qosPolicy is ready within timeout.

func (*QoSPolicyClient) WaitToBeUpdated added in v1.12.0 

func (c *QoSPolicyClient) WaitToBeUpdated(qosPolicy *apiv1.QoSPolicy, timeout time.Duration) bool

WaitToBeUpdated returns whether the qosPolicy is updated within timeout.

func (*QoSPolicyClient) WaitToDisappear added in v1.12.0 

func (c *QoSPolicyClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified qosPolicy to disappear.

func (*QoSPolicyClient) WaitToQoSReady added in v1.12.0 

func (c *QoSPolicyClient) WaitToQoSReady(name string) bool

WaitToQoSReady returns whether the qos is ready within timeout.

func (*QoSPolicyClient) WaitUntil added in v1.12.0 

func (c *QoSPolicyClient) WaitUntil(name string, cond func(s *apiv1.QoSPolicy) (bool, error), condDesc string, interval, timeout time.Duration) *apiv1.QoSPolicy

WaitUntil waits the given timeout duration for the specified condition to be met.

type ServiceClient added in v1.11.0 

type ServiceClient struct {
	v1core.ServiceInterface
	// contains filtered or unexported fields
}

ServiceClient is a struct for service client.

func (*ServiceClient) Create added in v1.11.0 

func (c *ServiceClient) Create(service *corev1.Service) *corev1.Service

Create creates a new service according to the framework specifications

func (*ServiceClient) CreateSync added in v1.11.0 

func (c *ServiceClient) CreateSync(service *corev1.Service, cond func(s *corev1.Service) (bool, error), condDesc string) *corev1.Service

CreateSync creates a new service according to the framework specifications, and waits for it to be updated.

func (*ServiceClient) Delete added in v1.11.0 

func (c *ServiceClient) Delete(name string)

Delete deletes a service if the service exists

func (*ServiceClient) DeleteSync added in v1.11.0 

func (c *ServiceClient) DeleteSync(name string)

DeleteSync deletes the service and waits for the service to disappear for `timeout`. If the service doesn't disappear before the timeout, it will fail the test.

func (*ServiceClient) Get added in v1.11.0 

func (c *ServiceClient) Get(name string) *corev1.Service

func (*ServiceClient) Patch added in v1.12.0 

func (c *ServiceClient) Patch(original, modified *corev1.Service) *corev1.Service

Patch patches the service

func (*ServiceClient) PatchSync added in v1.12.0 

func (c *ServiceClient) PatchSync(original, modified *corev1.Service, cond func(s *corev1.Service) (bool, error), condDesc string) *corev1.Service

PatchSync patches the service and waits the service to meet the condition

func (*ServiceClient) WaitToDisappear added in v1.11.0 

func (c *ServiceClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified service to disappear.

func (*ServiceClient) WaitUntil added in v1.12.0 

func (c *ServiceClient) WaitUntil(name string, cond func(s *corev1.Service) (bool, error), condDesc string, interval, timeout time.Duration) *corev1.Service

WaitUntil waits the given timeout duration for the specified condition to be met.

type StatefulSetClient added in v1.12.0 

type StatefulSetClient struct {
	v1apps.StatefulSetInterface
	// contains filtered or unexported fields
}

func (*StatefulSetClient) Create added in v1.12.0 

func (c *StatefulSetClient) Create(sts *appsv1.StatefulSet) *appsv1.StatefulSet

Create creates a new statefulset according to the framework specifications

func (*StatefulSetClient) CreateSync added in v1.12.0 

func (c *StatefulSetClient) CreateSync(sts *appsv1.StatefulSet) *appsv1.StatefulSet

CreateSync creates a new statefulset according to the framework specifications, and waits for it to complete.

func (*StatefulSetClient) Delete added in v1.12.0 

func (c *StatefulSetClient) Delete(name string)

Delete deletes a statefulset if the statefulset exists

func (*StatefulSetClient) DeleteSync added in v1.12.0 

func (c *StatefulSetClient) DeleteSync(name string)

DeleteSync deletes the statefulset and waits for the statefulset to disappear for `timeout`. If the statefulset doesn't disappear before the timeout, it will fail the test.

func (*StatefulSetClient) Get added in v1.12.0 

func (c *StatefulSetClient) Get(name string) *appsv1.StatefulSet

func (*StatefulSetClient) GetPods added in v1.12.0 

func (c *StatefulSetClient) GetPods(sts *appsv1.StatefulSet) *corev1.PodList

func (*StatefulSetClient) WaitForRunningAndReady added in v1.12.0 

func (c *StatefulSetClient) WaitForRunningAndReady(sts *appsv1.StatefulSet)

func (*StatefulSetClient) WaitToDisappear added in v1.12.0 

func (c *StatefulSetClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified statefulset to disappear.

type SubnetClient added in v1.11.0 

type SubnetClient struct {
	v1.SubnetInterface
	// contains filtered or unexported fields
}

SubnetClient is a struct for subnet client.

func (*SubnetClient) Create added in v1.11.0 

func (c *SubnetClient) Create(subnet *apiv1.Subnet) *apiv1.Subnet

Create creates a new subnet according to the framework specifications

func (*SubnetClient) CreateSync added in v1.11.0 

func (c *SubnetClient) CreateSync(subnet *apiv1.Subnet) *apiv1.Subnet

CreateSync creates a new subnet according to the framework specifications, and waits for it to be ready.

func (*SubnetClient) Delete added in v1.11.0 

func (c *SubnetClient) Delete(name string)

Delete deletes a subnet if the subnet exists

func (*SubnetClient) DeleteSync added in v1.11.0 

func (c *SubnetClient) DeleteSync(name string)

DeleteSync deletes the subnet and waits for the subnet to disappear for `timeout`. If the subnet doesn't disappear before the timeout, it will fail the test.

func (*SubnetClient) Get added in v1.11.0 

func (c *SubnetClient) Get(name string) *apiv1.Subnet

func (*SubnetClient) Patch added in v1.11.0 

func (c *SubnetClient) Patch(original, modified *apiv1.Subnet, timeout time.Duration) *apiv1.Subnet

Patch patches the subnet

func (*SubnetClient) PatchSync added in v1.11.0 

func (c *SubnetClient) PatchSync(original, modified *apiv1.Subnet) *apiv1.Subnet

PatchSync patches the subnet and waits for the subnet to be ready for `timeout`. If the subnet doesn't become ready before the timeout, it will fail the test.

func (*SubnetClient) Update added in v1.11.0 

func (c *SubnetClient) Update(subnet *apiv1.Subnet, options metav1.UpdateOptions, timeout time.Duration) *apiv1.Subnet

Update updates the subnet

func (*SubnetClient) UpdateSync added in v1.11.0 

func (c *SubnetClient) UpdateSync(subnet *apiv1.Subnet, options metav1.UpdateOptions, timeout time.Duration) *apiv1.Subnet

UpdateSync updates the subnet and waits for the subnet to be ready for `timeout`. If the subnet doesn't become ready before the timeout, it will fail the test.

func (*SubnetClient) WaitConditionToBe added in v1.11.0 

func (c *SubnetClient) WaitConditionToBe(name string, conditionType apiv1.ConditionType, wantTrue bool, timeout time.Duration) bool

WaitConditionToBe returns whether subnet "name's" condition state matches wantTrue within timeout. If wantTrue is true, it will ensure the subnet condition status is ConditionTrue; if it's false, it ensures the subnet condition is in any state other than ConditionTrue (e.g. not true or unknown).

func (*SubnetClient) WaitToBeReady added in v1.11.0 

func (c *SubnetClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the subnet is ready within timeout.

func (*SubnetClient) WaitToBeUpdated added in v1.11.0 

func (c *SubnetClient) WaitToBeUpdated(subnet *apiv1.Subnet, timeout time.Duration) bool

WaitToBeUpdated returns whether the subnet is updated within timeout.

func (*SubnetClient) WaitToDisappear added in v1.11.0 

func (c *SubnetClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified subnet to disappear.

func (*SubnetClient) WaitUntil added in v1.12.0 

func (c *SubnetClient) WaitUntil(name string, cond func(s *apiv1.Subnet) (bool, error), condDesc string, interval, timeout time.Duration) *apiv1.Subnet

WaitUntil waits the given timeout duration for the specified condition to be met.

type SwitchLBRuleClient added in v1.12.0 

type SwitchLBRuleClient struct {
	v1.SwitchLBRuleInterface
	// contains filtered or unexported fields
}

SwitchLBRuleClient is a struct for switch-lb-rule client.

func (*SwitchLBRuleClient) Create added in v1.12.0 

func (c *SwitchLBRuleClient) Create(rule *apiv1.SwitchLBRule) *apiv1.SwitchLBRule

Create creates a new switch-lb-rule according to the framework specifications

func (*SwitchLBRuleClient) CreateSync added in v1.12.0 

func (c *SwitchLBRuleClient) CreateSync(rule *apiv1.SwitchLBRule, cond func(s *apiv1.SwitchLBRule) (bool, error), condDesc string) *apiv1.SwitchLBRule

CreateSync creates a new switch-lb-rule according to the framework specifications, and waits for it to be updated.

func (*SwitchLBRuleClient) Delete added in v1.12.0 

func (c *SwitchLBRuleClient) Delete(name string)

Delete deletes a switch-lb-rule if the switch-lb-rule exists

func (*SwitchLBRuleClient) DeleteSync added in v1.12.0 

func (c *SwitchLBRuleClient) DeleteSync(name string)

DeleteSync deletes the switch-lb-rule and waits for the switch-lb-rule to disappear for `timeout`. If the switch-lb-rule doesn't disappear before the timeout, it will fail the test.

func (*SwitchLBRuleClient) Get added in v1.12.0 

func (c *SwitchLBRuleClient) Get(name string) *apiv1.SwitchLBRule

func (*SwitchLBRuleClient) Patch added in v1.12.0 

func (c *SwitchLBRuleClient) Patch(original, modified *apiv1.SwitchLBRule) *apiv1.SwitchLBRule

Patch patches the switch-lb-rule

func (*SwitchLBRuleClient) PatchSync added in v1.12.0 

func (c *SwitchLBRuleClient) PatchSync(original, modified *apiv1.SwitchLBRule, cond func(s *apiv1.SwitchLBRule) (bool, error), condDesc string) *apiv1.SwitchLBRule

PatchSync patches the switch-lb-rule and waits the switch-lb-rule to meet the condition

func (*SwitchLBRuleClient) WaitToDisappear added in v1.12.0 

func (c *SwitchLBRuleClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified switch-lb-rule to disappear.

func (*SwitchLBRuleClient) WaitUntil added in v1.12.0 

func (c *SwitchLBRuleClient) WaitUntil(name string, cond func(s *apiv1.SwitchLBRule) (bool, error), condDesc string, _, timeout time.Duration) *apiv1.SwitchLBRule

WaitUntil waits the given timeout duration for the specified condition to be met.

type VipClient added in v1.12.0 

type VipClient struct {
	v1.VipInterface
	// contains filtered or unexported fields
}

VipClient is a struct for vip client.

func (*VipClient) Create added in v1.12.0 

func (c *VipClient) Create(vip *apiv1.Vip) *apiv1.Vip

Create creates a new vip according to the framework specifications

func (*VipClient) CreateSync added in v1.12.0 

func (c *VipClient) CreateSync(vip *apiv1.Vip) *apiv1.Vip

CreateSync creates a new ovn vip according to the framework specifications, and waits for it to be ready.

func (*VipClient) Delete added in v1.12.0 

func (c *VipClient) Delete(name string)

Delete deletes a vip if the vip exists

func (*VipClient) DeleteSync added in v1.12.0 

func (c *VipClient) DeleteSync(name string)

DeleteSync deletes the ovn vip and waits for the ovn vip to disappear for `timeout`. If the ovn vip doesn't disappear before the timeout, it will fail the test.

func (*VipClient) Get added in v1.12.0 

func (c *VipClient) Get(name string) *apiv1.Vip

func (*VipClient) Patch added in v1.12.0 

func (c *VipClient) Patch(original, modified *apiv1.Vip, timeout time.Duration) *apiv1.Vip

Patch patches the vip

func (*VipClient) WaitToBeReady added in v1.12.0 

func (c *VipClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the ovn vip is ready within timeout.

func (*VipClient) WaitToDisappear added in v1.12.0 

func (c *VipClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified OVN VIP to disappear.

type VlanClient added in v1.11.0 

type VlanClient struct {
	v1.VlanInterface
	// contains filtered or unexported fields
}

VlanClient is a struct for vlan client.

func (*VlanClient) Create added in v1.11.0 

func (c *VlanClient) Create(pn *apiv1.Vlan) *apiv1.Vlan

Create creates a new vlan according to the framework specifications

func (*VlanClient) Delete added in v1.11.0 

func (c *VlanClient) Delete(name string, options metav1.DeleteOptions)

Delete deletes a vlan if the vlan exists

func (*VlanClient) Get added in v1.11.0 

func (c *VlanClient) Get(name string) *apiv1.Vlan

func (*VlanClient) Patch added in v1.11.0 

func (c *VlanClient) Patch(original, modified *apiv1.Vlan, timeout time.Duration) *apiv1.Vlan

Patch patches the vlan

type VpcClient added in v1.12.0 

type VpcClient struct {
	v1.VpcInterface
	// contains filtered or unexported fields
}

VpcClient is a struct for vpc client.

func (*VpcClient) Create added in v1.12.0 

func (c *VpcClient) Create(vpc *kubeovnv1.Vpc) *kubeovnv1.Vpc

Create creates a new vpc according to the framework specifications

func (*VpcClient) CreateSync added in v1.12.0 

func (c *VpcClient) CreateSync(vpc *kubeovnv1.Vpc) *kubeovnv1.Vpc

CreateSync creates a new vpc according to the framework specifications, and waits for it to be ready.

func (*VpcClient) Delete added in v1.12.0 

func (c *VpcClient) Delete(name string)

Delete deletes a vpc if the vpc exists

func (*VpcClient) DeleteSync added in v1.12.0 

func (c *VpcClient) DeleteSync(name string)

DeleteSync deletes the vpc and waits for the vpc to disappear for `timeout`. If the vpc doesn't disappear before the timeout, it will fail the test.

func (*VpcClient) Get added in v1.12.0 

func (c *VpcClient) Get(name string) *kubeovnv1.Vpc

func (*VpcClient) Patch added in v1.12.0 

func (c *VpcClient) Patch(original, modified *kubeovnv1.Vpc) *kubeovnv1.Vpc

Patch patches the vpc

func (*VpcClient) PatchSync added in v1.12.0 

func (c *VpcClient) PatchSync(original, modified *kubeovnv1.Vpc, _ []string, timeout time.Duration) *kubeovnv1.Vpc

PatchSync patches the vpc and waits for the vpc to be ready for `timeout`. If the vpc doesn't become ready before the timeout, it will fail the test.

func (*VpcClient) WaitToBeReady added in v1.12.0 

func (c *VpcClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the vpc is ready within timeout.

func (*VpcClient) WaitToBeUpdated added in v1.12.0 

func (c *VpcClient) WaitToBeUpdated(vpc *kubeovnv1.Vpc, timeout time.Duration) bool

WaitToBeUpdated returns whether the vpc is updated within timeout.

func (*VpcClient) WaitToDisappear added in v1.12.0 

func (c *VpcClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified VPC to disappear.

type VpcNatGatewayClient added in v1.12.0 

type VpcNatGatewayClient struct {
	v1.VpcNatGatewayInterface
	// contains filtered or unexported fields
}

VpcNatGatewayClient is a struct for vpc nat gw client.

func (*VpcNatGatewayClient) Create added in v1.12.0 

func (c *VpcNatGatewayClient) Create(vpcNatGw *apiv1.VpcNatGateway) *apiv1.VpcNatGateway

Create creates a new vpc nat gw according to the framework specifications

func (*VpcNatGatewayClient) CreateSync added in v1.12.0 

func (c *VpcNatGatewayClient) CreateSync(vpcNatGw *apiv1.VpcNatGateway, clietSet clientset.Interface) *apiv1.VpcNatGateway

CreateSync creates a new vpc nat gw according to the framework specifications, and waits for it to be ready.

func (*VpcNatGatewayClient) Delete added in v1.12.0 

func (c *VpcNatGatewayClient) Delete(name string)

Delete deletes a vpc nat gw if the vpc nat gw exists

func (*VpcNatGatewayClient) DeleteSync added in v1.12.0 

func (c *VpcNatGatewayClient) DeleteSync(name string)

DeleteSync deletes the vpc nat gw and waits for the vpc nat gw to disappear for `timeout`. If the vpc nat gw doesn't disappear before the timeout, it will fail the test.

func (*VpcNatGatewayClient) Get added in v1.12.0 

func (c *VpcNatGatewayClient) Get(name string) *apiv1.VpcNatGateway

func (*VpcNatGatewayClient) Patch added in v1.12.0 

func (c *VpcNatGatewayClient) Patch(original, modified *apiv1.VpcNatGateway) *apiv1.VpcNatGateway

Patch patches the vpc nat gw

func (*VpcNatGatewayClient) PatchQoSPolicySync added in v1.12.0 

func (c *VpcNatGatewayClient) PatchQoSPolicySync(natgwName, qosPolicyName string) *apiv1.VpcNatGateway

PatchQoS patches the vpc nat gw and waits for the qos to be ready for `timeout`. If the qos doesn't become ready before the timeout, it will fail the test.

func (*VpcNatGatewayClient) PatchSync added in v1.12.0 

func (c *VpcNatGatewayClient) PatchSync(original, modified *apiv1.VpcNatGateway, timeout time.Duration) *apiv1.VpcNatGateway

PatchSync patches the vpc nat gw and waits for the vpc nat gw to be ready for `timeout`. If the vpc nat gw doesn't become ready before the timeout, it will fail the test.

func (*VpcNatGatewayClient) WaitGwPodReady added in v1.12.0 

func (c *VpcNatGatewayClient) WaitGwPodReady(name string, timeout time.Duration, clietSet clientset.Interface) bool

WaitGwPodReady returns whether the vpc nat gw pod is ready within timeout.

func (*VpcNatGatewayClient) WaitToBeReady added in v1.12.0 

func (c *VpcNatGatewayClient) WaitToBeReady(name string, timeout time.Duration) bool

WaitToBeReady returns whether the vpc nat gw is ready within timeout.

func (*VpcNatGatewayClient) WaitToBeUpdated added in v1.12.0 

func (c *VpcNatGatewayClient) WaitToBeUpdated(vpcNatGw *apiv1.VpcNatGateway, timeout time.Duration) bool

WaitToBeUpdated returns whether the vpc nat gw is updated within timeout.

func (*VpcNatGatewayClient) WaitToDisappear added in v1.12.0 

func (c *VpcNatGatewayClient) WaitToDisappear(name string, _, timeout time.Duration) error

WaitToDisappear waits the given timeout duration for the specified VPC NAT gateway to disappear.

func (*VpcNatGatewayClient) WaitToQoSReady added in v1.12.0 

func (c *VpcNatGatewayClient) WaitToQoSReady(name string) bool

WaitToQoSReady returns whether the qos is ready within timeout.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.