framework

package
v0.15.0-m0 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MCSClients        []*mcsClientset.Clientset
	EndpointClients   []dynamic.ResourceInterface
	SubmarinerClients []dynamic.ResourceInterface
)

Functions

This section is empty.

Types

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) AwaitEndpointIPs added in v0.6.0 

func (f *Framework) AwaitEndpointIPs(targetCluster framework.ClusterIndex, name,
	namespace string, count int,
) (ipList, hostNameList []string)

func (*Framework) AwaitEndpointSlices added in v0.7.0 

func (f *Framework) AwaitEndpointSlices(targetCluster framework.ClusterIndex, name, namespace string,
	expSliceCount, expEpCount int,
) (endpointSliceList *discovery.EndpointSliceList)

func (*Framework) AwaitPodIPs added in v0.10.1 

func (f *Framework) AwaitPodIPs(targetCluster framework.ClusterIndex, svc *v1.Service, count int,
	isLocal bool,
) (ipList, hostNameList []string)

func (*Framework) AwaitPodIngressIPs added in v0.10.1 

func (f *Framework) AwaitPodIngressIPs(targetCluster framework.ClusterIndex, svc *v1.Service, count int,
	isLocal bool,
) (ipList, hostNameList []string)

func (*Framework) AwaitServiceExportedStatusCondition added in v0.6.0 

func (f *Framework) AwaitServiceExportedStatusCondition(cluster framework.ClusterIndex, name, namespace string)

func (*Framework) AwaitServiceImportCount added in v0.6.0 

func (f *Framework) AwaitServiceImportCount(targetCluster framework.ClusterIndex, name, namespace string, count int)

func (*Framework) AwaitServiceImportDelete added in v0.5.0 

func (f *Framework) AwaitServiceImportDelete(targetCluster framework.ClusterIndex, name, namespace string)

func (*Framework) AwaitServiceImportIP added in v0.5.0 

func (f *Framework) AwaitServiceImportIP(srcCluster, targetCluster framework.ClusterIndex, svc *v1.Service) *mcsv1a1.ServiceImport

func (*Framework) AwaitServiceImportWithIP added in v0.10.1 

func (f *Framework) AwaitServiceImportWithIP(targetCluster framework.ClusterIndex, svc *v1.Service,
	serviceIP string,
) *mcsv1a1.ServiceImport

func (*Framework) DeleteServiceExport added in v0.4.0 

func (f *Framework) DeleteServiceExport(cluster framework.ClusterIndex, name, namespace string)

func (*Framework) GetHealthCheckEnabledInfo added in v0.12.0 

func (f *Framework) GetHealthCheckEnabledInfo(cluster framework.ClusterIndex) (healthCheckEnabled bool)

func (*Framework) GetHealthCheckIPInfo added in v0.8.1 

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

func (*Framework) GetPodIPs added in v0.10.1 

func (f *Framework) GetPodIPs(targetCluster framework.ClusterIndex, service *v1.Service, isLocal bool) (ipList, hostNameList []string)

func (*Framework) GetService added in v0.5.0 

func (f *Framework) GetService(cluster framework.ClusterIndex, name, namespace string) (*v1.Service, error)

func (*Framework) GetServiceIP added in v0.10.1 

func (f *Framework) GetServiceIP(svcCluster framework.ClusterIndex, service *v1.Service, isLocal bool) string

func (*Framework) NewNetShootDeployment 

func (f *Framework) NewNetShootDeployment(cluster framework.ClusterIndex) *corev1.PodList

func (*Framework) NewNginxDeployment 

func (f *Framework) NewNginxDeployment(cluster framework.ClusterIndex) *corev1.PodList

func (*Framework) NewNginxHeadlessService added in v0.6.0 

func (f *Framework) NewNginxHeadlessService(cluster framework.ClusterIndex) *v1.Service

func (*Framework) NewNginxHeadlessServiceWithParams added in v0.7.0 

func (f *Framework) NewNginxHeadlessServiceWithParams(name, app, portName string, protcol v1.Protocol,
	cluster framework.ClusterIndex,
) *v1.Service

func (*Framework) NewNginxStatefulSet added in v0.7.0 

func (f *Framework) NewNginxStatefulSet(cluster framework.ClusterIndex) *appsv1.StatefulSet

func (*Framework) NewServiceExport added in v0.4.0 

func (f *Framework) NewServiceExport(cluster framework.ClusterIndex, name, namespace string) *mcsv1a1.ServiceExport

func (*Framework) SetHealthCheckIP added in v0.8.1 

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

func (*Framework) SetNginxReplicaSet added in v0.6.0 

func (f *Framework) SetNginxReplicaSet(cluster framework.ClusterIndex, count uint32) *appsv1.Deployment

func (*Framework) SetNginxStatefulSetReplicas added in v0.7.0 

func (f *Framework) SetNginxStatefulSetReplicas(cluster framework.ClusterIndex, count uint32) *appsv1.StatefulSet

func (*Framework) VerifyIPWithDig added in v0.10.1 

func (f *Framework) VerifyIPWithDig(srcCluster framework.ClusterIndex, service *v1.Service, targetPod *v1.PodList,
	domains []string, clusterName, serviceIP string, shouldContain bool,
)

func (*Framework) VerifyIPsWithDig added in v0.13.1 

func (f *Framework) VerifyIPsWithDig(cluster framework.ClusterIndex, service *v1.Service, targetPod *v1.PodList,
	ipList, domains []string, clusterName string, shouldContain bool,
)

func (*Framework) VerifyServiceIPWithDig added in v0.10.1 

func (f *Framework) VerifyServiceIPWithDig(srcCluster, targetCluster framework.ClusterIndex, service *v1.Service, targetPod *v1.PodList,
	domains []string, clusterName string, shouldContain bool,
)

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.