Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ShouldLastFor

func ShouldLastFor(interval, timeout time.Duration, conditionalFunc func() bool) error

func WaitForFunction

func WaitForFunction(interval, timeout time.Duration, conditionalFunc func() bool) error

Types

type HelmClient

type HelmClient interface {
	CheckReleaseStatus(rlsName string) (*rls.GetReleaseStatusResponse, error)
	CheckReleaseExistence(name string) (bool, error)
	IsInstalled(rlsName string) bool
	TestRelease(rlsName string) (<-chan *rls.TestReleaseResponse, <-chan error)
}

func NewHelmClient

func NewHelmClient(host, tlsKeyFile, tlsCertFile string, skipVerify bool) (HelmClient, error)

type K8sResourceChecker

type K8sResourceChecker struct {
	// contains filtered or unexported fields
}

func NewAppK8sChecker

func NewAppK8sChecker(client K8sResourcesClient, appName string, checkGateway bool) *K8sResourceChecker

func NewServiceInstanceK8SChecker

func NewServiceInstanceK8SChecker(client K8sResourcesClient, releaseName string) *K8sResourceChecker

func (*K8sResourceChecker) CheckK8sResourceRemoved

func (c *K8sResourceChecker) CheckK8sResourceRemoved(t *testing.T)

func (*K8sResourceChecker) CheckK8sResourcesDeployed

func (c *K8sResourceChecker) CheckK8sResourcesDeployed(t *testing.T)

type K8sResourcesClient

type K8sResourcesClient interface {
	GetDeployment(name string, options metav1.GetOptions) (interface{}, error)
	GetService(name string, options metav1.GetOptions) (interface{}, error)
	GetVirtualService(name string, options metav1.GetOptions) (interface{}, error)
	GetRole(name string, options metav1.GetOptions) (interface{}, error)
	GetRoleBinding(name string, options metav1.GetOptions) (interface{}, error)
	GetClusterRole(name string, options metav1.GetOptions) (interface{}, error)
	GetClusterRoleBinding(name string, options metav1.GetOptions) (interface{}, error)
	GetServiceAccount(name string, options metav1.GetOptions) (interface{}, error)
	CreateDummyApplication(name string, accessLabel string, skipInstallation bool) (*v1alpha1.Application, error)
	DeleteApplication(name string, options *metav1.DeleteOptions) error
	GetApplication(name string, options metav1.GetOptions) (*v1alpha1.Application, error)
	ListPods(options metav1.ListOptions) (*corev1.PodList, error)
	DeletePod(name string, options *metav1.DeleteOptions) error
	GetLogs(podName string, options *corev1.PodLogOptions) *restclient.Request
	CreateNamespace(*corev1.Namespace) (*corev1.Namespace, error)
	DeleteNamespace() error
	CreateServiceInstance(serviceInstance *v1beta1.ServiceInstance) (*v1beta1.ServiceInstance, error)
	DeleteServiceInstance(siName string) error
}

func NewK8sResourcesClient

func NewK8sResourcesClient(namespace string) (K8sResourcesClient, error)

type TestConfig

type TestConfig struct {
	Namespace                  string
	TillerHost                 string
	TillerTLSKeyFile           string
	TillerTLSCertificateFile   string
	TillerTLSSkipVerify        bool
	InstallationTimeoutSeconds int
	GatewayOncePerNamespace    bool
}

func ReadConfig

func ReadConfig() (TestConfig, error)