framework

Documentation

Overview

SPDX-License-Identifier: Apache-2.0

Copyright Contributors to the Submariner project.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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) GetHealthCheckIPInfo(cluster framework.ClusterIndex) (endpointName, healthCheckIP 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) SetHealthCheckIP(cluster framework.ClusterIndex, ip, endpointName string)
  • func (f *Framework) SetNginxReplicaSet(cluster framework.ClusterIndex, count uint32) *appsv1.Deployment
  • func (f *Framework) SetNginxStatefulSetReplicas(cluster framework.ClusterIndex, count uint32) *appsv1.StatefulSet

Variables

var EndpointClients []dynamic.ResourceInterface

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) GetHealthCheckIPInfo

func (f *Framework) GetHealthCheckIPInfo(cluster framework.ClusterIndex) (endpointName, healthCheckIP 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) SetHealthCheckIP

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

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