framework

package

v0.5.0-rc0 Latest Latest Go to latest Published: Jul 13, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var SubmarinerClients []*submarinerClientset.Clientset

func GetDeletionChannel(informer cache.SharedIndexInformer) chan string

func NoopCheckEndpoint(endpoint *submarinerv1.Endpoint) (bool, string, error)

type CheckEndpointFunc func(endpoint *submarinerv1.Endpoint) (bool, string, error)

type Framework struct {
	*framework.Framework
}

Framework supports common operations used by e2e tests; it will keep a client & a namespace for you.

func NewFramework(baseName string) *Framework

NewFramework creates a test framework.

func (f *Framework) AwaitGatewayFullyConnected(cluster framework.ClusterIndex, name string) *submarinerv1.Gateway

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

func (f *Framework) AwaitGatewayWithStatus(cluster framework.ClusterIndex,
	name string, status submarinerv1.HAStatus) *submarinerv1.Gateway

func (f *Framework) AwaitGatewaysWithStatus(
	cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway

func (f *Framework) AwaitNewSubmarinerEndpoint(cluster framework.ClusterIndex, prevEndpointUID types.UID) *submarinerv1.Endpoint

func (f *Framework) AwaitSubmarinerEndpoint(cluster framework.ClusterIndex, checkEndpoint CheckEndpointFunc) *submarinerv1.Endpoint

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

func (f *Framework) GatewayCleanup()

GatewayCleanup ensures that only the active gateway node is flagged as gateway node

which could not be after a failed test which left the system on an
unexpected state

func (f *Framework) GetGatewayInformer(cluster framework.ClusterIndex) (cache.SharedIndexInformer, chan struct{})

func (f *Framework) GetGatewaysWithHAStatus(
	cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway