testhelpers

Documentation

Index

• func ApplyFile(ctx context.Context, k8s client.Client, filepath string) (result []string, err error)
• func CreateKubernetesCluster(ctx context.Context, t *testing.T) (*k3s.K3sContainer, error)
• func CreateSecretForTraefikHub(ctx context.Context, t *testing.T, k8s client.Client)
• func Delete(ctx context.Context, k8s client.Client, kind, name, ns, group, version string) error
• func HasNotHeader(header string) try.ResponseCondition
• func InstallTraefikHubAPIGW(ctx context.Context, t *testing.T, k8s client.Client) (string, error)
• func InstallTraefikHubAPIM(ctx context.Context, t *testing.T, k8s client.Client) (string, error)
• func InstallTraefikProxy(ctx context.Context, t *testing.T, k8s client.Client) (string, error)
• func LaunchHelmCommand(t *testing.T, arg ...string)
• func LaunchHelmUpgradeCommand(t *testing.T, arg ...string)
• func LaunchKubectl(t *testing.T, arg ...string) *bytes.Buffer
• func RestartDeployment(ctx context.Context, t *testing.T, k8s client.Client, name, ns string) error
• func WaitForJobCompleted(ctx context.Context, t *testing.T, k8s client.Client, interval time.Duration, ...) error
• func WaitForPodsReady(ctx context.Context, t *testing.T, k8s client.Client, interval time.Duration, ...) error

Functions

func ApplyFile

func ApplyFile(ctx context.Context, k8s client.Client, filepath string) (result []string, err error)

ApplyFile applies a yaml on k8s client

func CreateKubernetesCluster

func CreateKubernetesCluster(ctx context.Context, t *testing.T) (*k3s.K3sContainer, error)

func CreateSecretForTraefikHub

func CreateSecretForTraefikHub(ctx context.Context, t *testing.T, k8s client.Client)

func Delete

func Delete(ctx context.Context, k8s client.Client, kind, name, ns, group, version string) error

func HasNotHeader

func HasNotHeader(header string) try.ResponseCondition

func InstallTraefikHubAPIGW

func InstallTraefikHubAPIGW(ctx context.Context, t *testing.T, k8s client.Client) (string, error)

InstallTraefikHubAPIGW install Traefik Hub with Helm and return LB IP

func InstallTraefikHubAPIM

func InstallTraefikHubAPIM(ctx context.Context, t *testing.T, k8s client.Client) (string, error)

InstallTraefikHubAPIM install Traefik Hub API Management with Helm and return LB IP

func InstallTraefikProxy

func InstallTraefikProxy(ctx context.Context, t *testing.T, k8s client.Client) (string, error)

InstallTraefikProxy install Traefik Proxy with Helm and return LB IP

func LaunchHelmCommand

func LaunchHelmCommand(t *testing.T, arg ...string)

LaunchHelmCommand execute `helm` CLI with arg and display stdout+stder with testcontainer logger

func LaunchHelmUpgradeCommand

func LaunchHelmUpgradeCommand(t *testing.T, arg ...string)

LaunchHelmUpgradeCommand execute `helm` CLI with arg and display stdout+stder with testcontainer logger

func LaunchKubectl

func LaunchKubectl(t *testing.T, arg ...string) *bytes.Buffer

LaunchKubectl execute `kubectl` CLI with arg and return stdout+stderr in a single string

func RestartDeployment

func RestartDeployment(ctx context.Context, t *testing.T, k8s client.Client, name, ns string) error

func WaitForJobCompleted

func WaitForJobCompleted(ctx context.Context, t *testing.T, k8s client.Client, interval time.Duration, labelSelector string) error

func WaitForPodsReady

func WaitForPodsReady(ctx context.Context, t *testing.T, k8s client.Client, interval time.Duration, labelSelector string) error