testbench

Documentation

Index

• Variables
• func BootstrapFirehoseModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, ...) error
• func BootstrapFlinkModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, ...) error
• func BootstrapKubernetesModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, ...) error
• func BootstrapKubernetesResource(ctx context.Context, client entropyv1beta1.ResourceServiceClient, ...) error
• func GetClusterCredentials(kubeProvider *cluster.Provider, clusterName string) (string, string, string, error)
• func SetupTests(t *testing.T, spawnWorkers bool, setupKube bool) (context.Context, entropyv1beta1.ModuleServiceClient, ...)
• func SetupWorker(t *testing.T, ctx context.Context, appConfig cli.Config)

Variables

var (
	UserIDHeader = "user-id"

	TestDataPath    = ""
	TestClusterName = fmt.Sprintf("test-cluster-%s", uuid.New())
	TestNamespace   = "default"
)

Functions

func BootstrapFirehoseModule

func BootstrapFirehoseModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, testDataPath string) error

func BootstrapFlinkModule

func BootstrapFlinkModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, testDataPath string) error

func BootstrapKubernetesModule

func BootstrapKubernetesModule(ctx context.Context, client entropyv1beta1.ModuleServiceClient, testDataPath string) error

func BootstrapKubernetesResource

func BootstrapKubernetesResource(ctx context.Context, client entropyv1beta1.ResourceServiceClient, kubeProvider *cluster.Provider, testDataPath string) error

func GetClusterCredentials

func GetClusterCredentials(kubeProvider *cluster.Provider, clusterName string) (string, string, string, error)

func SetupTests

func SetupTests(t *testing.T, spawnWorkers bool, setupKube bool) (context.Context, entropyv1beta1.ModuleServiceClient, entropyv1beta1.ResourceServiceClient, *cli.Config,
	*dockertest.Pool, *dockertest.Resource, *cluster.Provider, func(), func(), func())

func SetupWorker

func SetupWorker(t *testing.T, ctx context.Context, appConfig cli.Config)