framework

Documentation

Index

• Constants
• Variables
• func CreateKubeNamespace(name string, c kubernetes.Interface) (*corev1.Namespace, error)
• func DeleteKubeNamespace(c kubernetes.Interface, namespace string) error
• func ExpectNoError(err error, explain ...interface{})
• func Failf(format string, args ...interface{})
• func GetBrokerPod(c kubernetes.Interface, deploy *appsv1.Deployment) (*corev1.Pod, error)
• func Logf(format string, args ...interface{})
• func RegisterCommonFlags()
• func RegisterParseFlags()
• func Skipf(format string, args ...interface{})
• func WaitForCreatingSecret(c kubernetes.Interface, secretName, secretNamespace string) error
• func WaitForEndpoint(c kubernetes.Interface, namespace, name string) error
• func WaitForPodRunningInNamespace(c kubernetes.Interface, pod *corev1.Pod) error
• type ClientConfigGetter
• type Framework
  • func NewFramework(baseName string, kubeClient kubernetes.Interface, ...) *Framework
  • func (f *Framework) Invoke() *Invocation
• type Invocation
  • func (f *Invocation) App() string
• type TestContextType

Constants

const (
	// How often to poll for conditions
	Poll = 2 * time.Second

	// Default time to wait for an endpoint to register
	EndpointRegisterTimeout = time.Minute
)

const (
	RecommendedConfigPathEnvVar = "SERVICECATALOGCONFIG"
)

Variables

var RunId = uuid.NewUUID()

unique identifier of the e2e run

Functions

func CreateKubeNamespace

func CreateKubeNamespace(name string, c kubernetes.Interface) (*corev1.Namespace, error)

func DeleteKubeNamespace

func DeleteKubeNamespace(c kubernetes.Interface, namespace string) error

func ExpectNoError

func ExpectNoError(err error, explain ...interface{})

func Failf

func Failf(format string, args ...interface{})

func GetBrokerPod

func GetBrokerPod(c kubernetes.Interface, deploy *appsv1.Deployment) (*corev1.Pod, error)

func Logf

func Logf(format string, args ...interface{})

func RegisterCommonFlags

func RegisterCommonFlags()

Register flags common to all e2e test suites.

func RegisterParseFlags

func RegisterParseFlags()

func Skipf

func Skipf(format string, args ...interface{})

func WaitForCreatingSecret

func WaitForCreatingSecret(c kubernetes.Interface, secretName, secretNamespace string) error

func WaitForEndpoint

func WaitForEndpoint(c kubernetes.Interface, namespace, name string) error

func WaitForPodRunningInNamespace

func WaitForPodRunningInNamespace(c kubernetes.Interface, pod *corev1.Pod) error

Waits default amount of time (PodStartTimeout) for the specified pod to become running. Returns an error if timeout occurs first, or pod goes in to failed state.

Types

type ClientConfigGetter

type ClientConfigGetter func() (*rest.Config, error)

type Framework

type Framework struct {
	BaseName string

	// A Kubernetes and Service Catalog client
	KubeClient           kubernetes.Interface
	ServiceCatalogClient svcat.Interface
	KubedbClient         cs.KubedbV1alpha1Interface
	// Namespace in which all test resources should reside
	Namespace *corev1.Namespace
}

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

func NewFramework

func NewFramework(
	baseName string,
	kubeClient kubernetes.Interface,
	serviceCatalogClient svcat.Interface,
	kubedbClient cs.KubedbV1alpha1Interface) *Framework

NewFramework makes a new framework and sets up a BeforeEach/AfterEach for you (you can write additional before/after each functions).

func (*Framework) Invoke

func (f *Framework) Invoke() *Invocation

type Invocation

type Invocation struct {
	*Framework
	// contains filtered or unexported fields
}

func (*Invocation) App

func (f *Invocation) App() string

type TestContextType

type TestContextType struct {
	KubeHost              string
	KubeConfig            string
	KubeContext           string
	ServiceCatalogHost    string
	ServiceCatalogConfig  string
	ServiceCatalogContext string
}

var TestContext TestContextType