Add AutoOps for Kafka (#1362)

* Add AutoOps for Kafka

Signed-off-by: raihankhan <[email protected]>

apis/kubedb/v1/helpers.go

@@ -19,6 +19,7 @@ package v1
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"kubedb.dev/apimachinery/apis/kubedb"
 
@@ -167,3 +168,14 @@ func GetSelectorForNetworkPolicy() map[string]string {
 		meta_util.ManagedByLabelKey: kubedb.GroupName,
 	}
 }
+
+func GetActivationTimeFromSecret(secretName *core.Secret) (*metav1.Time, error) {
+	if val, exists := secretName.Annotations[kubedb.AuthActiveFromAnnotation]; exists {
+		t, err := time.Parse(time.RFC3339, val)
+		if err != nil {
+			return nil, err
+		}
+		return &metav1.Time{Time: t}, nil
+	}
+	return nil, nil
+}

apis/kubedb/v1/kafka_types.go

@@ -55,6 +55,10 @@ type Kafka struct {
 
 // KafkaSpec defines the desired state of Kafka
 type KafkaSpec struct {
+	// AutoOps contains configuration of automatic ops-request-recommendation generation
+	// +optional
+	AutoOps AutoOpsSpec `json:"autoOps,omitempty"`
+
 	// Version of Kafka to be deployed.
 	Version string `json:"version"`
 

crds/kubedb.com_kafkas.yaml

@@ -60,6 +60,11 @@ spec:
                     type: string
                 type: object
                 x-kubernetes-map-type: atomic
+              autoOps:
+                properties:
+                  disabled:
+                    type: boolean
+                type: object
               configSecret:
                 properties:
                   name: