utils

Documentation

Index

• func ConnectWithKubeconfig(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, ...) ctrlruntimeclient.Client
• func CreateSelfDestructingNamespace(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, ...)
• func DeployEtcd(t *testing.T, name, namespace string) string
• func DeployRootShard(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, ...) operatorv1alpha1.RootShard
• func DeployShard(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, ...) operatorv1alpha1.Shard
• func GetKubeClient(t *testing.T) ctrlruntimeclient.Client
• func GetSelfSignedIssuerRef() *operatorv1alpha1.ObjectReference
• func SelfDestuctingPortForward(t *testing.T, ctx context.Context, namespace string, target string, ...)
• func WaitForObject(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, ...)
• func WaitForPods(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, ...)

Functions

func ConnectWithKubeconfig

func ConnectWithKubeconfig(
	t *testing.T,
	ctx context.Context,
	client ctrlruntimeclient.Client,
	namespace string,
	kubeconfigName string,
) ctrlruntimeclient.Client

func CreateSelfDestructingNamespace

func CreateSelfDestructingNamespace(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, name string)

func DeployEtcd

func DeployEtcd(t *testing.T, name, namespace string) string

func DeployRootShard

func DeployRootShard(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, namespace string, patches ...func(*operatorv1alpha1.RootShard)) operatorv1alpha1.RootShard

func DeployShard

func DeployShard(ctx context.Context, t *testing.T, client ctrlruntimeclient.Client, namespace, name, rootShard string, patches ...func(*operatorv1alpha1.Shard)) operatorv1alpha1.Shard

func GetKubeClient

func GetKubeClient(t *testing.T) ctrlruntimeclient.Client

func GetSelfSignedIssuerRef

func GetSelfSignedIssuerRef() *operatorv1alpha1.ObjectReference

func SelfDestuctingPortForward

func SelfDestuctingPortForward(
	t *testing.T,
	ctx context.Context,
	namespace string,
	target string,
	targetPort int,
	localPort int,
)

func WaitForObject

func WaitForObject(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, obj ctrlruntimeclient.Object, key types.NamespacedName)

func WaitForPods

func WaitForPods(t *testing.T, ctx context.Context, client ctrlruntimeclient.Client, listOpts ...ctrlruntimeclient.ListOption)