framework

package
v0.17.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SubmarinerClients []*submarinerClientset.Clientset

Functions

func CanExecuteNonGatewayConnectivityTest added in v0.12.0 

func CanExecuteNonGatewayConnectivityTest(sourceNode, destNode framework.NetworkPodScheduling,
	sourceCluster, destCluster framework.ClusterIndex,
) bool

func FindClusterWithSingleGateway added in v0.16.1 

func FindClusterWithSingleGateway() framework.ClusterIndex

func NoopCheckEndpoint added in v0.1.0 

func NoopCheckEndpoint(_ *submarinerv1.Endpoint) (bool, string, error)

func VerifyDatapathConnectivity added in v0.10.1 

func VerifyDatapathConnectivity(p tcp.ConnectivityTestParams, gn GlobalnetTestParams)

Types

type CheckEndpointFunc added in v0.1.0 

type CheckEndpointFunc func(endpoint *submarinerv1.Endpoint) (bool, string, error)

type Framework 

type Framework struct {
	*framework.Framework
}

Framework supports common operations used by e2e tests; it will keep a client & a namespace for you.

func NewFramework 

func NewFramework(baseName string) *Framework

NewFramework creates a test framework.

func (*Framework) AwaitGatewayFullyConnected added in v0.3.0 

func (f *Framework) AwaitGatewayFullyConnected(cluster framework.ClusterIndex, name string) *submarinerv1.Gateway

func (*Framework) AwaitGatewayWithStatus added in v0.3.0 

func (f *Framework) AwaitGatewayWithStatus(cluster framework.ClusterIndex, name string,
	status submarinerv1.HAStatus,
) *submarinerv1.Gateway

func (*Framework) AwaitGatewaysWithStatus added in v0.3.0 

func (f *Framework) AwaitGatewaysWithStatus(cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway

func (*Framework) AwaitNewSubmarinerEndpoint added in v0.1.0 

func (f *Framework) AwaitNewSubmarinerEndpoint(cluster framework.ClusterIndex, prevEndpointUID types.UID) *submarinerv1.Endpoint

func (*Framework) AwaitSubmarinerEndpoint added in v0.1.0 

func (f *Framework) AwaitSubmarinerEndpoint(cluster framework.ClusterIndex, checkEndpoint CheckEndpointFunc) *submarinerv1.Endpoint

func (*Framework) AwaitSubmarinerEndpointRemoved added in v0.8.0 

func (f *Framework) AwaitSubmarinerEndpointRemoved(cluster framework.ClusterIndex, endpointName string)

func (*Framework) GetGatewayInformer added in v0.3.0 

func (f *Framework) GetGatewayInformer(cluster framework.ClusterIndex) (cache.SharedIndexInformer, chan struct{})

func (*Framework) GetGatewaysWithHAStatus added in v0.3.0 

func (f *Framework) GetGatewaysWithHAStatus(cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway

type GlobalEgressIPType added in v0.10.1 

type GlobalEgressIPType int
const (
	ClusterSelector GlobalEgressIPType = iota
	NameSpaceSelector
	PodSelector
)

func (GlobalEgressIPType) String added in v0.10.1 

func (t GlobalEgressIPType) String() string

type GlobalnetTestParams added in v0.10.1 

type GlobalnetTestParams struct {
	GlobalnetEnabled  bool
	GlobalEgressIP    GlobalEgressIPType
	RunAdditionalTest RunAdditionalTestFn
}

func GetGlobalnetEgressParams added in v0.10.1 

func GetGlobalnetEgressParams(egressIP GlobalEgressIPType) GlobalnetTestParams

type RunAdditionalTestFn added in v0.17.0 

type RunAdditionalTestFn func(listenerPodConfig framework.NetworkPodConfig, connectorPodConfig framework.NetworkPodConfig,
	service *v1.Service, verifyConnectivity func(listener *framework.NetworkPod, connector *framework.NetworkPod))

Source Files

View all Source files

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.