framework

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2024 License: Apache-2.0 Imports: 25 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MCSClients        []*mcsClientset.Clientset
	EndpointClients   []dynamic.ResourceInterface
	SubmarinerClients []dynamic.ResourceInterface
)
View Source 
var CheckedDomains = []string{clustersetDomain}

Functions

func BuildServiceDNSName added in v0.17.0 

func BuildServiceDNSName(clusterName, serviceName, namespace, tld string) string

func IsClusterSetIPEnabled added in v0.19.0 

func IsClusterSetIPEnabled() bool

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) AwaitAggregatedServiceImport added in v0.15.0 

func (f *Framework) AwaitAggregatedServiceImport(targetCluster framework.ClusterIndex, svc *v1.Service, clusterCount int,
) *mcsv1a1.ServiceImport

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) AwaitEndpointIngressIPs added in v0.16.0 

func (f *Framework) AwaitEndpointIngressIPs(targetCluster framework.ClusterIndex, svc *v1.Service) (ipList, hostNameList []string)

func (*Framework) AwaitEndpointSlices added in v0.7.0 

func (f *Framework) AwaitEndpointSlices(targetCluster framework.ClusterIndex, name, namespace string,
	expSliceCount, expReadyCount 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) CreateServiceExport added in v0.19.0 

func (f *Framework) CreateServiceExport(cluster framework.ClusterIndex, serviceExport *mcsv1a1.ServiceExport) *mcsv1a1.ServiceExport

func (*Framework) DeleteServiceExport added in v0.4.0 

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

func (*Framework) GetEndpointIPs added in v0.6.0 

func (f *Framework) GetEndpointIPs(targetCluster framework.ClusterIndex, svc *v1.Service) (ipList, hostNameList []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) string

func (*Framework) NewEndpointForHeadlessService added in v0.16.0 

func (f *Framework) NewEndpointForHeadlessService(cluster framework.ClusterIndex, svc *v1.Service)

func (*Framework) NewHeadlessServiceEndpointIP added in v0.16.0 

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

func (*Framework) NewHeadlessServiceWithParams added in v0.16.0 

func (f *Framework) NewHeadlessServiceWithParams(name, portName string, protcol v1.Protocol,
	labelsMap map[string]string, cluster framework.ClusterIndex,
) *v1.Service

func (*Framework) NewNetShootDeployment 

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

func (*Framework) NewNetShootDeploymentInNS added in v0.16.0 

func (f *Framework) NewNetShootDeploymentInNS(cluster framework.ClusterIndex, namespace string) *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) 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.