storage

Documentation

Overview

Package storage implements an E2E storage test suite.

Index

• Constants
• func DeployApp(ctx context.Context, cluster *tester.ClusterContext, namespace string, ...) error
• func ReadFromVolume(ctx context.Context, cl kubernetes.Interface, config *rest.Config, ...) (string, error)
• func ScaleStatefulSet(ctx context.Context, t ginkgo.GinkgoTInterface, options *k8s.KubectlOptions, ...) error
• func WaitDemoApp(t ginkgo.GinkgoTInterface, options *k8s.KubectlOptions, replicas int)
• func WriteToVolume(ctx context.Context, cl kubernetes.Interface, config *rest.Config, ...) error

Constants

const (

	// StatefulSetName is the name of the test StatefulSet.
	StatefulSetName = "liqo-storage"
)

Functions

func DeployApp

func DeployApp(ctx context.Context, cluster *tester.ClusterContext, namespace string, replicas int32) error

DeployApp creates the namespace and deploys the applications. It returns an error in case of failures.

func ReadFromVolume

func ReadFromVolume(ctx context.Context,
	cl kubernetes.Interface, config *rest.Config, namespace string) (string, error)

ReadFromVolume reads a file from the volume of the StatefulSet.

func ScaleStatefulSet

func ScaleStatefulSet(ctx context.Context, t ginkgo.GinkgoTInterface, options *k8s.KubectlOptions,
	cl kubernetes.Interface, namespace string, replicas int32) error

ScaleStatefulSet scales the StatefulSet to the desired number of replicas.

func WaitDemoApp

func WaitDemoApp(t ginkgo.GinkgoTInterface, options *k8s.KubectlOptions, replicas int)

WaitDemoApp waits until each pod in the StatefulSet is ready.

func WriteToVolume

func WriteToVolume(ctx context.Context, cl kubernetes.Interface, config *rest.Config, namespace string) error

WriteToVolume writes a file to the volume of the StatefulSet.