testbase

Documentation

Index

• type Condition
• type ControllerManagerTestSuiteBase
  • func (s *ControllerManagerTestSuiteBase) AddDeployment(name string, podIps []string, podLabels, annotations map[string]string) *appsv1.Deployment
  • func (s *ControllerManagerTestSuiteBase) AddDeploymentWithService(name string, podIps []string, podLabels map[string]string, ...) (*appsv1.Deployment, *corev1.Service)
  • func (s *ControllerManagerTestSuiteBase) AddEndpoints(name string, podIps []string) *corev1.Endpoints
  • func (s *ControllerManagerTestSuiteBase) AddIngress(serviceName string) *networkingv1.Ingress
  • func (s *ControllerManagerTestSuiteBase) AddIntents(objName, clientName string, callList []otterizev1alpha2.Intent) (*otterizev1alpha2.ClientIntents, error)
  • func (s *ControllerManagerTestSuiteBase) AddKafkaServerConfig(kafkaServerConfig *otterizev1alpha2.KafkaServerConfig)
  • func (s *ControllerManagerTestSuiteBase) AddLoadBalancerService(name string, podIps []string, selector map[string]string) *corev1.Service
  • func (s *ControllerManagerTestSuiteBase) AddNodePortService(name string, podIps []string, selector map[string]string) *corev1.Service
  • func (s *ControllerManagerTestSuiteBase) AddPod(name string, podIp string, labels, annotations map[string]string)
  • func (s *ControllerManagerTestSuiteBase) AddReplicaSet(name string, podIps []string, podLabels, annotations map[string]string) *appsv1.ReplicaSet
  • func (s *ControllerManagerTestSuiteBase) AddService(name string, podIps []string, selector map[string]string) *corev1.Service
  • func (s *ControllerManagerTestSuiteBase) BeforeTest(_, testName string)
  • func (s *ControllerManagerTestSuiteBase) RemoveIntents(objName string) error
  • func (s *ControllerManagerTestSuiteBase) RemoveKafkaServerConfig(objName string)
  • func (s *ControllerManagerTestSuiteBase) SetupTest()
  • func (s *ControllerManagerTestSuiteBase) TearDownSuite()
  • func (s *ControllerManagerTestSuiteBase) TearDownTest()
  • func (s *ControllerManagerTestSuiteBase) UpdateIntents(objName string, callList []otterizev1alpha2.Intent) error
  • func (s *ControllerManagerTestSuiteBase) WaitForDeletionToBeMarked(obj client.Object)
  • func (s *ControllerManagerTestSuiteBase) WaitUntilCondition(cond func(assert *assert.Assertions))

Types

type Condition

type Condition func() bool

type ControllerManagerTestSuiteBase

type ControllerManagerTestSuiteBase struct {
	suite.Suite
	TestEnv         *envtest.Environment
	RestConfig      *rest.Config
	TestNamespace   string
	K8sDirectClient *kubernetes.Clientset

	Mgr manager.Manager
	// contains filtered or unexported fields
}

func (*ControllerManagerTestSuiteBase) AddDeployment

func (s *ControllerManagerTestSuiteBase) AddDeployment(
	name string,
	podIps []string,
	podLabels,
	annotations map[string]string) *appsv1.Deployment

func (*ControllerManagerTestSuiteBase) AddDeploymentWithService

func (s *ControllerManagerTestSuiteBase) AddDeploymentWithService(name string, podIps []string, podLabels map[string]string, podAnnotations map[string]string) (*appsv1.Deployment, *corev1.Service)

func (*ControllerManagerTestSuiteBase) AddEndpoints

func (s *ControllerManagerTestSuiteBase) AddEndpoints(name string, podIps []string) *corev1.Endpoints

func (*ControllerManagerTestSuiteBase) AddIngress

func (s *ControllerManagerTestSuiteBase) AddIngress(serviceName string) *networkingv1.Ingress

func (*ControllerManagerTestSuiteBase) AddIntents

func (s *ControllerManagerTestSuiteBase) AddIntents(
	objName,
	clientName string,
	callList []otterizev1alpha2.Intent) (*otterizev1alpha2.ClientIntents, error)

func (*ControllerManagerTestSuiteBase) AddKafkaServerConfig

func (s *ControllerManagerTestSuiteBase) AddKafkaServerConfig(kafkaServerConfig *otterizev1alpha2.KafkaServerConfig)

func (*ControllerManagerTestSuiteBase) AddLoadBalancerService

func (s *ControllerManagerTestSuiteBase) AddLoadBalancerService(name string, podIps []string, selector map[string]string) *corev1.Service

func (*ControllerManagerTestSuiteBase) AddNodePortService

func (s *ControllerManagerTestSuiteBase) AddNodePortService(name string, podIps []string, selector map[string]string) *corev1.Service

func (*ControllerManagerTestSuiteBase) AddPod

func (s *ControllerManagerTestSuiteBase) AddPod(name string, podIp string, labels, annotations map[string]string)

func (*ControllerManagerTestSuiteBase) AddReplicaSet

func (s *ControllerManagerTestSuiteBase) AddReplicaSet(
	name string,
	podIps []string,
	podLabels,
	annotations map[string]string) *appsv1.ReplicaSet

func (*ControllerManagerTestSuiteBase) AddService

func (s *ControllerManagerTestSuiteBase) AddService(name string, podIps []string, selector map[string]string) *corev1.Service

func (*ControllerManagerTestSuiteBase) BeforeTest

func (s *ControllerManagerTestSuiteBase) BeforeTest(_, testName string)

BeforeTest happens AFTER the SetupTest()

func (*ControllerManagerTestSuiteBase) RemoveIntents

func (s *ControllerManagerTestSuiteBase) RemoveIntents(
	objName string) error

func (*ControllerManagerTestSuiteBase) RemoveKafkaServerConfig

func (s *ControllerManagerTestSuiteBase) RemoveKafkaServerConfig(objName string)

func (*ControllerManagerTestSuiteBase) SetupTest

func (s *ControllerManagerTestSuiteBase) SetupTest()

func (*ControllerManagerTestSuiteBase) TearDownSuite

func (s *ControllerManagerTestSuiteBase) TearDownSuite()

func (*ControllerManagerTestSuiteBase) TearDownTest

func (s *ControllerManagerTestSuiteBase) TearDownTest()

func (*ControllerManagerTestSuiteBase) UpdateIntents

func (s *ControllerManagerTestSuiteBase) UpdateIntents(
	objName string,
	callList []otterizev1alpha2.Intent) error

func (*ControllerManagerTestSuiteBase) WaitForDeletionToBeMarked

func (s *ControllerManagerTestSuiteBase) WaitForDeletionToBeMarked(obj client.Object)

WaitForDeletionToBeMarked tries to get an object multiple times until its deletion timestamp is set in K8S

func (*ControllerManagerTestSuiteBase) WaitUntilCondition

func (s *ControllerManagerTestSuiteBase) WaitUntilCondition(cond func(assert *assert.Assertions))