types

Documentation

Index

• Variables
• type DeploymentSize
• type KafkaClusterInfo
• type KafkaConnectPlugin
• type OcpImageReference
• type SuiteContext
• type TestContext
  • func (ctx *TestContext) ExecuteCleanups()
  • func (ctx *TestContext) RegisterCleanup(cleanup func())

Variables

var (
	NormalSize DeploymentSize = DeploymentSize("normal")
	SmallSize  DeploymentSize = DeploymentSize("small")

	Scram kafkaSecurity = kafkaSecurity("scram")
	Tls   kafkaSecurity = kafkaSecurity("tls")
)

Types

type DeploymentSize

type DeploymentSize string

type KafkaClusterInfo

type KafkaClusterInfo struct {
	Name                     string
	Namespace                string
	Replicas                 int
	Topics                   []string
	StrimziDeployed          bool
	BootstrapServers         string
	ExternalBootstrapServers string
	AuthType                 string
	Username                 string
}

KafkaClusterInfo holds useful info to use a kafka cluster

type KafkaConnectPlugin

type KafkaConnectPlugin struct {
	URL       string
	SHA512SUM string
}

type OcpImageReference

type OcpImageReference struct {
	ExternalImage string
	InternalImage string
}

type SuiteContext

type SuiteContext struct {
	SuiteID       string
	Cfg           *rest.Config
	K8sClient     client.Client
	K8sManager    ctrl.Manager
	TestEnv       *envtest.Environment
	PackageClient pmversioned.Interface
	OLMClient     olmapiversioned.Interface
	Clientset     *kubernetes.Clientset
	IsOpenshift   bool

	OcpRouteClient *ocp_route_client.RouteV1Client

	CLIKubernetesClient *kubernetescli.KubernetesClient

	OnlyTestOperator        bool
	DisableClusteredTests   bool
	DisableConvertersTests  bool
	DisableAuthTests        bool
	OLMRunAdvancedTestcases bool

	SetupSelenium bool
	SeleniumHost  string
	SeleniumPort  string
}

SuiteContext holds common info used in a testsuite

type TestContext

type TestContext struct {
	ID            string
	Storage       string
	Replicas      int
	Auth          bool
	Size          DeploymentSize
	KafkaSecurity kafkaSecurity

	RegistryNamespace string

	RegistryName         string
	RegistryHost         string
	RegistryPort         string
	RegistryInternalHost string
	RegistryInternalPort string

	RegistryResource      *apicurio.ApicurioRegistry
	KafkaClusterInfo      *KafkaClusterInfo
	KeycloakURL           string
	KeycloakSubscription  *operatorsv1alpha1.Subscription
	KeycloakOperatorGroup *operatorsv1.OperatorGroup

	FunctionalTestsProfile            string
	FunctionalTestsExtraEnv           []string
	FunctionalTestsSharedKafkaCluster *KafkaClusterInfo

	SkipInfraRemoval bool
	// contains filtered or unexported fields
}

TestContext holds the common information of for a functional test

func (*TestContext) ExecuteCleanups

func (ctx *TestContext) ExecuteCleanups()

func (*TestContext) RegisterCleanup

func (ctx *TestContext) RegisterCleanup(cleanup func())