e2e

Documentation

Index

• Variables
• func ConnectionJob(container []v1.Container, jobName string, namespace string) *bv1.Job
• func GetTestDeployment(name string, namespace string) *appsv1.Deployment
• func GetTestPVC(name string, namespace string) *v1.PersistentVolumeClaim
• func GetTestService(name string, namespace string) *v1.Service
• func HasSelfSignedCerts(url string, httpClient *http.Client) (bool, error)
• func Int32Ptr(i int32) *int32
• func Int64Ptr(i int64) *int64
• func NewTestingHTTPClient(kubeConfig *rest.Config) (*http.Client, error)
• func WaitForDeployment(t TestingTB, kubeclient kubernetes.Interface, namespace, name string, ...) error
• type TestingContext
  • func NewTestingContext(kubeConfig *rest.Config) (*TestingContext, error)
• type TestingTB

Variables

var (
	OpenShiftConsoleRoute     = "console"
	OpenShiftConsoleNamespace = "openshift-console"
)

Functions

func ConnectionJob

func ConnectionJob(container []v1.Container, jobName string, namespace string) *bv1.Job

returns job template

func GetTestDeployment

func GetTestDeployment(name string, namespace string) *appsv1.Deployment

func GetTestPVC

func GetTestPVC(name string, namespace string) *v1.PersistentVolumeClaim

func GetTestService

func GetTestService(name string, namespace string) *v1.Service

func HasSelfSignedCerts

func HasSelfSignedCerts(url string, httpClient *http.Client) (bool, error)

func Int32Ptr

func Int32Ptr(i int32) *int32

func Int64Ptr

func Int64Ptr(i int64) *int64

func NewTestingHTTPClient

func NewTestingHTTPClient(kubeConfig *rest.Config) (*http.Client, error)

func WaitForDeployment

func WaitForDeployment(t TestingTB, kubeclient kubernetes.Interface, namespace, name string, replicas int,
	retryInterval, timeout time.Duration) error

Types

type TestingContext

type TestingContext struct {
	Client          k8sclient.Client
	KubeConfig      *rest.Config
	KubeClient      kubernetes.Interface
	ExtensionClient *clientset.Clientset
	HttpClient      *http.Client
	SelfSignedCerts bool
}

func NewTestingContext

func NewTestingContext(kubeConfig *rest.Config) (*TestingContext, error)

type TestingTB

type TestingTB interface {
	Fail()
	Error(args ...interface{})
	Errorf(format string, args ...interface{})
	FailNow()
	Fatal(args ...interface{})
	Fatalf(format string, args ...interface{})
	Log(args ...interface{})
	Logf(format string, args ...interface{})
	Failed() bool
	Parallel()
	Skip(args ...interface{})
	Skipf(format string, args ...interface{})
	SkipNow()
	Skipped() bool
}