feat: add a controller implementation of rag

api/evaluation/v1alpha1/common.go

@@ -17,6 +17,8 @@ limitations under the License.
 package v1alpha1
 
 import (
+	"reflect"
+
 	batchv1 "k8s.io/api/batch/v1"
 	corev1 "k8s.io/api/core/v1"
 )
@@ -134,3 +136,22 @@ func RagStatus(rag *RAG) (string, RAGPhase, string) {
 	}
 	return status, phase, phaseMsg
 }
+
+func RAGSpecChanged(a, b RAGSpec) bool {
+	if !reflect.DeepEqual(*a.Application, *b.Application) {
+		return true
+	}
+	if !reflect.DeepEqual(a.Datasets, b.Datasets) {
+		return true
+	}
+	if !reflect.DeepEqual(a.JudgeLLM, b.JudgeLLM) {
+		return true
+	}
+	if !reflect.DeepEqual(*a.Storage, *b.Storage) {
+		return true
+	}
+	if a.ServiceAccountName != b.ServiceAccountName {
+		return true
+	}
+	return false
+}

config/rbac/role.yaml

@@ -36,6 +36,12 @@ rules:
   - get
   - list
   - watch
+- apiGroups:
+  - ""
+  resources:
+  - persistentvolumeclaims
+  verbs:
+  - '*'
 - apiGroups:
   - ""
   resources:
@@ -408,6 +414,12 @@ rules:
   - subjectaccessreviews
   verbs:
   - create
+- apiGroups:
+  - batch
+  resources:
+  - jobs
+  verbs:
+  - '*'
 - apiGroups:
   - chain.arcadia.kubeagi.k8s.com.cn
   resources: