framework

Documentation

Index

• Variables
• func CanExecuteNonGatewayConnectivityTest(sourceNode, destNode framework.NetworkPodScheduling, ...) bool
• func FindClusterWithSingleGateway() framework.ClusterIndex
• func NoopCheckEndpoint(_ *submarinerv1.Endpoint) (bool, string, error)
• func VerifyDatapathConnectivity(p tcp.ConnectivityTestParams, gn GlobalnetTestParams)
• type CheckEndpointFunc
• type Framework
  • func NewFramework(baseName string) *Framework
  • func (f *Framework) AwaitGatewayFullyConnected(cluster framework.ClusterIndex, name string) *submarinerv1.Gateway
  • func (f *Framework) AwaitGatewayWithStatus(cluster framework.ClusterIndex, name string, status submarinerv1.HAStatus) *submarinerv1.Gateway
  • func (f *Framework) AwaitGatewaysWithStatus(cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway
  • func (f *Framework) AwaitNewSubmarinerEndpoint(cluster framework.ClusterIndex, prevEndpointUID types.UID) *submarinerv1.Endpoint
  • func (f *Framework) AwaitSubmarinerEndpoint(cluster framework.ClusterIndex, checkEndpoint CheckEndpointFunc) *submarinerv1.Endpoint
  • func (f *Framework) AwaitSubmarinerEndpointRemoved(cluster framework.ClusterIndex, endpointName string)
  • func (f *Framework) GetGatewayInformer(cluster framework.ClusterIndex) (cache.SharedIndexInformer, chan struct{})
  • func (f *Framework) GetGatewaysWithHAStatus(cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway
• type GlobalEgressIPType
  • func (t GlobalEgressIPType) String() string
• type GlobalnetTestParams
  • func GetGlobalnetEgressParams(egressIP GlobalEgressIPType) GlobalnetTestParams
• type RunAdditionalTestFn

Variables

var SubmarinerClients []*submarinerClientset.Clientset

Functions

func CanExecuteNonGatewayConnectivityTest

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

func FindClusterWithSingleGateway

func FindClusterWithSingleGateway() framework.ClusterIndex

func NoopCheckEndpoint

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

func VerifyDatapathConnectivity

func VerifyDatapathConnectivity(p tcp.ConnectivityTestParams, gn GlobalnetTestParams)

Types

type CheckEndpointFunc

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

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

func (*Framework) AwaitGatewayWithStatus

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

func (*Framework) AwaitGatewaysWithStatus

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

func (*Framework) AwaitNewSubmarinerEndpoint

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

func (*Framework) AwaitSubmarinerEndpoint

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

func (*Framework) AwaitSubmarinerEndpointRemoved

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

func (*Framework) GetGatewayInformer

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

func (*Framework) GetGatewaysWithHAStatus

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

type GlobalEgressIPType

type GlobalEgressIPType int

const (
	ClusterSelector GlobalEgressIPType = iota
	NameSpaceSelector
	PodSelector
)

func (GlobalEgressIPType) String

func (t GlobalEgressIPType) String() string

type GlobalnetTestParams

type GlobalnetTestParams struct {
	GlobalnetEnabled  bool
	GlobalEgressIP    GlobalEgressIPType
	RunAdditionalTest RunAdditionalTestFn
}

func GetGlobalnetEgressParams

func GetGlobalnetEgressParams(egressIP GlobalEgressIPType) GlobalnetTestParams

type RunAdditionalTestFn

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