framework

Documentation

Overview

© 2021 Red Hat, Inc. and others

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.

© 2021 Red Hat, Inc. and others.

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.

© 2021 Red Hat, Inc. and others

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
• func GetDeletionChannel(informer cache.SharedIndexInformer) chan string
• func NoopCheckEndpoint(endpoint *submarinerv1.Endpoint) (bool, string, error)
• type CheckEndpointFunc
• type Framework
  • func NewFramework(baseName string) *Framework
  • func (f *Framework) AwaitGatewayFullyConnected(cluster framework.ClusterIndex, name string) *submarinerv1.Gateway
  • 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) AwaitSubmarinerEndpointRemoved(cluster framework.ClusterIndex, endpointName string)
  • func (f *Framework) GetGatewayInformer(cluster framework.ClusterIndex) (cache.SharedIndexInformer, chan struct{})
  • func (f *Framework) GetGatewaysWithHAStatus(cluster framework.ClusterIndex, status submarinerv1.HAStatus) []submarinerv1.Gateway

Variables

var SubmarinerClients []*submarinerClientset.Clientset

Functions

func GetDeletionChannel

func GetDeletionChannel(informer cache.SharedIndexInformer) chan string

func NoopCheckEndpoint

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

Types

type CheckEndpointFunc

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

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

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

func (*Framework) AwaitGatewayWithStatus

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

func (*Framework) AwaitGatewaysWithStatus

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

func (*Framework) AwaitNewSubmarinerEndpoint

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

func (*Framework) AwaitSubmarinerEndpoint

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

func (*Framework) AwaitSubmarinerEndpointRemoved

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

func (*Framework) GetGatewayInformer

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

func (*Framework) GetGatewaysWithHAStatus

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