integration

Documentation

Index

• func MarkIntegrationTest(t *testing.T, testType TestType)
• func Run(t *testing.T, dir, command string, args ...string)
• func WaitForLogs(t *testing.T, out io.Reader, firstMessage string, moreMessages ...string)
• type NSKubernetesClient
  • func SetupNamespace(t *testing.T) (*v1.Namespace, *NSKubernetesClient)
  • func (k *NSKubernetesClient) CreateSecretFrom(ns, name string)
  • func (k *NSKubernetesClient) DefaultSecrets() corev1.SecretInterface
  • func (k *NSKubernetesClient) Deployments() typedappsv1.DeploymentInterface
  • func (k *NSKubernetesClient) ExternalIP(serviceName string) string
  • func (k *NSKubernetesClient) GetDeployment(depName string) *appsv1.Deployment
  • func (k *NSKubernetesClient) GetPod(podName string) *v1.Pod
  • func (k *NSKubernetesClient) Pods() corev1.PodInterface
  • func (k *NSKubernetesClient) Secrets() corev1.SecretInterface
  • func (k *NSKubernetesClient) Services() corev1.ServiceInterface
  • func (k *NSKubernetesClient) WaitForDeploymentsToStabilize(depNames ...string)
  • func (k *NSKubernetesClient) WaitForPodsInPhase(expectedPhase v1.PodPhase, podNames ...string)
  • func (k *NSKubernetesClient) WaitForPodsReady(podNames ...string)
• type TestType

Functions

func MarkIntegrationTest

func MarkIntegrationTest(t *testing.T, testType TestType)

func Run

func Run(t *testing.T, dir, command string, args ...string)

func WaitForLogs

func WaitForLogs(t *testing.T, out io.Reader, firstMessage string, moreMessages ...string)

Types

type NSKubernetesClient

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

NSKubernetesClient wraps a Kubernetes Client for a given namespace.

func SetupNamespace

func SetupNamespace(t *testing.T) (*v1.Namespace, *NSKubernetesClient)

SetupNamespace creates a Kubernetes namespace to run a test.

func (*NSKubernetesClient) CreateSecretFrom

func (k *NSKubernetesClient) CreateSecretFrom(ns, name string)

func (*NSKubernetesClient) DefaultSecrets

func (k *NSKubernetesClient) DefaultSecrets() corev1.SecretInterface

func (*NSKubernetesClient) Deployments

func (k *NSKubernetesClient) Deployments() typedappsv1.DeploymentInterface

func (*NSKubernetesClient) ExternalIP

func (k *NSKubernetesClient) ExternalIP(serviceName string) string

ExternalIP waits for the external IP aof a given service.

func (*NSKubernetesClient) GetDeployment

func (k *NSKubernetesClient) GetDeployment(depName string) *appsv1.Deployment

GetDeployment gets a deployment by name.

func (*NSKubernetesClient) GetPod

func (k *NSKubernetesClient) GetPod(podName string) *v1.Pod

GetDeployment gets a deployment by name.

func (*NSKubernetesClient) Pods

func (k *NSKubernetesClient) Pods() corev1.PodInterface

func (*NSKubernetesClient) Secrets

func (k *NSKubernetesClient) Secrets() corev1.SecretInterface

func (*NSKubernetesClient) Services

func (k *NSKubernetesClient) Services() corev1.ServiceInterface

func (*NSKubernetesClient) WaitForDeploymentsToStabilize

func (k *NSKubernetesClient) WaitForDeploymentsToStabilize(depNames ...string)

WaitForDeploymentsToStabilize waits for a list of deployments to become stable.

func (*NSKubernetesClient) WaitForPodsInPhase

func (k *NSKubernetesClient) WaitForPodsInPhase(expectedPhase v1.PodPhase, podNames ...string)

WaitForPodsInPhase waits for a list of pods to become ready.

func (*NSKubernetesClient) WaitForPodsReady

func (k *NSKubernetesClient) WaitForPodsReady(podNames ...string)

WaitForPodsReady waits for a list of pods to become ready.

type TestType

type TestType int

const (
	CanRunWithoutGcp TestType = iota
	NeedsGcp
)