framework

Documentation

Index

• Variables
• type Framework
  • func NewFramework(baseName string) *Framework
  • func (f *Framework) AwaitEndpointIPs(targetCluster framework.ClusterIndex, name, namespace string, count int) (ipList []string)
  • func (f *Framework) AwaitEndpointSlices(targetCluster framework.ClusterIndex, name, namespace string, ...) (endpointSliceList *v1beta1.EndpointSliceList)
  • func (f *Framework) AwaitGlobalnetIP(cluster framework.ClusterIndex, name, namespace string) string
  • func (f *Framework) AwaitServiceExportedStatusCondition(cluster framework.ClusterIndex, name, namespace string)
  • func (f *Framework) AwaitServiceImportCount(targetCluster framework.ClusterIndex, name, namespace string, count int)
  • func (f *Framework) AwaitServiceImportDelete(targetCluster framework.ClusterIndex, name, namespace string)
  • func (f *Framework) AwaitServiceImportIP(targetCluster framework.ClusterIndex, svc *v1.Service) *mcsv1a1.ServiceImport
  • func (f *Framework) DeleteServiceExport(cluster framework.ClusterIndex, name, namespace string)
  • func (f *Framework) GetEndpointIPs(targetCluster framework.ClusterIndex, name, namespace string) (ipList []string)
  • func (f *Framework) GetService(cluster framework.ClusterIndex, name, namespace string) (*v1.Service, error)
  • func (f *Framework) NewNginxHeadlessService(cluster framework.ClusterIndex) *v1.Service
  • func (f *Framework) NewNginxHeadlessServiceWithParams(name, app string, cluster framework.ClusterIndex) *v1.Service
  • func (f *Framework) NewNginxStatefulSet(cluster framework.ClusterIndex) *appsv1.StatefulSet
  • func (f *Framework) NewServiceExport(cluster framework.ClusterIndex, name, namespace string) *mcsv1a1.ServiceExport
  • func (f *Framework) SetNginxReplicaSet(cluster framework.ClusterIndex, count uint32) *appsv1.Deployment
  • func (f *Framework) SetNginxStatefulSetReplicas(cluster framework.ClusterIndex, count uint32) *appsv1.StatefulSet

Variables

var MCSClients []*mcsClientset.Clientset

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

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

func (*Framework) AwaitEndpointSlices

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

func (*Framework) AwaitGlobalnetIP

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

func (*Framework) AwaitServiceExportedStatusCondition

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

func (*Framework) AwaitServiceImportCount

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

func (*Framework) AwaitServiceImportDelete

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

func (*Framework) AwaitServiceImportIP

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

func (*Framework) DeleteServiceExport

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

func (*Framework) GetEndpointIPs

func (f *Framework) GetEndpointIPs(targetCluster framework.ClusterIndex, name, namespace string) (ipList []string)

func (*Framework) GetService

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

func (*Framework) NewNginxHeadlessService

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

func (*Framework) NewNginxHeadlessServiceWithParams

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

func (*Framework) NewNginxStatefulSet

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

func (*Framework) NewServiceExport

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

func (*Framework) SetNginxReplicaSet

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

func (*Framework) SetNginxStatefulSetReplicas

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