testbench

Documentation

Index

• Variables
• func BootstrapFirehoseModule(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 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)