Add statefulset filterfuncs

* Copy the filter funcs from @wcmitchell's PR :)

Author: psav

controllers/cloud.redhat.com/clowdapp_controller.go

@@ -203,6 +203,7 @@ func (r *ClowdAppReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	watchers := []Watcher{
 		{obj: &apps.Deployment{}, filter: deploymentFilter},
 		{obj: &core.Service{}, filter: generationOnlyFilter},
+		{obj: &apps.StatefulSet{}, filter: statefulSetFilter},
 		{obj: &core.ConfigMap{}, filter: generationOnlyFilter},
 		{obj: &core.Secret{}, filter: alwaysFilter},
 	}

controllers/cloud.redhat.com/clowdenvironment_controller.go

@@ -234,6 +234,7 @@ func (r *ClowdEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		{obj: &apps.Deployment{}, filter: deploymentFilter},
 		{obj: &core.Service{}, filter: alwaysFilter},
 		{obj: &core.Secret{}, filter: alwaysFilter},
+		{obj: &apps.StatefulSet{}, filter: statefulSetFilter},
 	}
 
 	if clowderconfig.LoadedConfig.Features.WatchStrimziResources {

controllers/cloud.redhat.com/filters.go

@@ -66,6 +66,21 @@ func deploymentUpdateFunc(e event.UpdateEvent) bool {
 	return false
 }
 
+func statefulSetUpdateFunc(e event.UpdateEvent) bool {
+	objOld := e.ObjectOld.(*apps.StatefulSet)
+	objNew := e.ObjectNew.(*apps.StatefulSet)
+	if objNew.GetGeneration() != objOld.GetGeneration() {
+		return true
+	}
+	if (objOld.Status.AvailableReplicas != objNew.Status.AvailableReplicas) && (objNew.Status.AvailableReplicas == objNew.Status.ReadyReplicas) {
+		return true
+	}
+	if (objOld.Status.AvailableReplicas == objOld.Status.ReadyReplicas) && (objNew.Status.AvailableReplicas != objNew.Status.ReadyReplicas) {
+		return true
+	}
+	return false
+}
+
 func kafkaUpdateFunc(e event.UpdateEvent) bool {
 	objOld := e.ObjectOld.(*strimzi.Kafka)
 	objNew := e.ObjectNew.(*strimzi.Kafka)
@@ -114,6 +129,10 @@ func deploymentFilter(logr logr.Logger, ctrlName string) HandlerFuncs {
 	return genFilterFunc(deploymentUpdateFunc, logr, ctrlName)
 }
 
+func statefulSetFilter(logr logr.Logger, ctrlName string) HandlerFuncs {
+	return genFilterFunc(statefulSetUpdateFunc, logr, ctrlName)
+}
+
 func kafkaFilter(logr logr.Logger, ctrlName string) HandlerFuncs {
 	return genFilterFunc(kafkaUpdateFunc, logr, ctrlName)
 }