package framework

import "k8s.io/kubernetes/test/e2e_federation/framework"

Index ¶

• Constants
• func CheckFederationVersion(c federation_clientset.Interface, want string) error
• func ClusterIsReadyOrFail(f *Framework, clusterName string)
• func FederationControlPlaneUpgrade(version string) error
• func GetValidDNSSubdomainName(name string) (string, error)
• func GetZoneFromClusterName(clusterName string) string
• func LoadFederatedConfig(overrides *clientcmd.ConfigOverrides) (*restclient.Config, error)
• func LoadFederationClientset(config *restclient.Config) (*federation_clientset.Clientset, error)
• func MasterUpgrade(context, version string) error
• func NewFederatedTypeCRUDTester(adapter federatedtypes.FederatedTypeAdapter, clusterClients []kubeclientset.Interface) *crudtester.FederatedTypeCRUDTester
• func SkipUnlessFederated(c clientset.Interface)
• func WaitForFederationApiserverReady(c *federation_clientset.Clientset) error
• type Cluster
• type ClusterSlice
• type E2EContext
• type Framework
• func NewDefaultFederatedFramework(baseName string) *Framework
• func (f *Framework) FederationAfterEach()
• func (f *Framework) FederationBeforeEach()
• func (f *Framework) GetClusterClients() []kubeclientset.Interface
• func (f *Framework) GetRegisteredClusters() ClusterSlice
• func (f *Framework) GetUnderlyingFederatedContexts() []E2EContext

Constants ¶

const FederatedDefaultTestTimeout = 5 * time.Minute

Functions ¶

func CheckFederationVersion ¶

func CheckFederationVersion(c federation_clientset.Interface, want string) error

func ClusterIsReadyOrFail ¶

func ClusterIsReadyOrFail(f *Framework, clusterName string)

ClusterIsReadyOrFail checks whether the named cluster is ready

func FederationControlPlaneUpgrade ¶

func FederationControlPlaneUpgrade(version string) error

func GetValidDNSSubdomainName ¶

func GetValidDNSSubdomainName(name string) (string, error)

GetValidDNSSubdomainName massages the given name to be a valid dns subdomain name. Most resources (such as secrets, clusters) require the names to be valid dns subdomain. This is a generic function (not specific to federation). Should be moved to a more generic location if others want to use it.

func GetZoneFromClusterName ¶

func GetZoneFromClusterName(clusterName string) string

func LoadFederatedConfig ¶

func LoadFederatedConfig(overrides *clientcmd.ConfigOverrides) (*restclient.Config, error)

func LoadFederationClientset ¶

func LoadFederationClientset(config *restclient.Config) (*federation_clientset.Clientset, error)

func MasterUpgrade ¶

func MasterUpgrade(context, version string) error

func NewFederatedTypeCRUDTester ¶

func NewFederatedTypeCRUDTester(adapter federatedtypes.FederatedTypeAdapter, clusterClients []kubeclientset.Interface) *crudtester.FederatedTypeCRUDTester

func SkipUnlessFederated ¶

func SkipUnlessFederated(c clientset.Interface)

Detects whether the federation namespace exists in the underlying cluster

func WaitForFederationApiserverReady ¶

func WaitForFederationApiserverReady(c *federation_clientset.Clientset) error

WaitForFederationApiserverReady waits for the federation apiserver to be ready. It tests the readiness by sending a GET request and expecting a non error response.

Types ¶

type Cluster ¶

type Cluster struct {
	Name string
	*kubeclientset.Clientset
}

Cluster keeps track of the name and client of a cluster in the federation

type ClusterSlice ¶

type ClusterSlice []*Cluster

ClusterSlice is a slice of clusters

type E2EContext ¶

type E2EContext struct {
	// Raw context name,
	RawName string `yaml:"rawName"`
	// A valid dns subdomain which can be used as the name of kubernetes resources.
	Name    string                 `yaml:"name"`
	Cluster *framework.KubeCluster `yaml:"cluster"`
	User    *framework.KubeUser    `yaml:"user"`
}

type Framework ¶

type Framework struct {
	*framework.Framework

	FederationConfig *restclient.Config

	FederationClientset *federation_clientset.Clientset

	FederationNamespace *v1.Namespace
	// contains filtered or unexported fields
}

Framework extends e2e Framework and adds federation specific fields

func NewDefaultFederatedFramework ¶

func NewDefaultFederatedFramework(baseName string) *Framework

func (*Framework) FederationAfterEach ¶

func (f *Framework) FederationAfterEach()

FederationAfterEach deletes the namespace, after reading its events.

func (*Framework) FederationBeforeEach ¶

func (f *Framework) FederationBeforeEach()

FederationBeforeEach checks for federation apiserver is ready and makes a namespace.

func (*Framework) GetClusterClients ¶

func (f *Framework) GetClusterClients() []kubeclientset.Interface

func (*Framework) GetRegisteredClusters ¶

func (f *Framework) GetRegisteredClusters() ClusterSlice

func (*Framework) GetUnderlyingFederatedContexts ¶

func (f *Framework) GetUnderlyingFederatedContexts() []E2EContext

Source Files ¶

cluster.go crudtester.go framework.go util.go