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))
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 (*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 (*ControllerManagerTestSuiteBase) AddNodePortService ¶
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 (*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))
Click to show internal directories.
Click to hide internal directories.