From: naman.gupta <naman.gupta@samsung.com>
Date: Wed, 29 Nov 2023 08:02:30 +0000 (+0530)
Subject: Adding Persistent Volume for Alarm Manager.
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=2fab3e607e7abd243b15a94ce8a1aa3ce9d984de;p=ric-plt%2Fric-dep.git

Adding Persistent Volume for Alarm Manager.

Adding Persistent Volume & PV Claim for Alarm Manager.

Change-Id: I3d65782c3cd8f9310952e8eec929cbf030f73d51
Signed-off-by: naman.gupta <naman.gupta@samsung.com>
---

diff --git a/depRicKubernetesOperator/internal/controller/create_controller.go b/depRicKubernetesOperator/internal/controller/create_controller.go
index 8c94658..de4cdb6 100644
--- a/depRicKubernetesOperator/internal/controller/create_controller.go
+++ b/depRicKubernetesOperator/internal/controller/create_controller.go
@@ -47,5 +47,52 @@ func (r *RicPlatformReconciler) CreateAll() {
 			fmt.Println("Erorr During Creating resource of GetIngress()| Error --> |", err)
 		}
 	}
+	for _, resource := range GetPersistentVolume() {
+		if resource.GetNamespace() == "" {
+			resource.SetNamespace(namespaceProvided)
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetPersistentVolume()| Error --> |", err)
+		}
+	}
+	for _, resource := range GetRoleBinding() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetRoleBinding()| Error --> |", err)
+		}
+	}
+	for _, resource := range GetPersistentVolumeClaim() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetPersistentVolumeClaim()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetServiceAccount() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetServiceAccount()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetRole() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetRole()| Error --> |", err)
+		}
+	}
 
 }
diff --git a/depRicKubernetesOperator/internal/controller/getPersistentVolume.go b/depRicKubernetesOperator/internal/controller/getPersistentVolume.go
new file mode 100644
index 0000000..8fbb043
--- /dev/null
+++ b/depRicKubernetesOperator/internal/controller/getPersistentVolume.go
@@ -0,0 +1,34 @@
+package controller
+
+import "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+
+func GetPersistentVolume() []*unstructured.Unstructured {
+
+	persistentVolume1 := &unstructured.Unstructured{
+		Object: map[string]interface{}{
+			"apiVersion": "v1",
+			"kind":       "PersistentVolume",
+			"metadata": map[string]interface{}{
+				"labels": map[string]interface{}{
+					"type": "local",
+				},
+				"name":      "pv-ricplt-alarmmanager",
+				"namespace": "ricplt",
+			},
+			"spec": map[string]interface{}{
+				"accessModes": []interface{}{
+					"ReadWriteOnce",
+				},
+				"capacity": map[string]interface{}{
+					"storage": "100Mi",
+				},
+				"hostPath": map[string]interface{}{
+					"path": "/mnt/pv-ricplt-alarmmanager",
+				},
+				"storageClassName": "local-storage",
+			},
+		},
+	}
+
+	return []*unstructured.Unstructured{persistentVolume1}
+}
diff --git a/depRicKubernetesOperator/internal/controller/getPersistentVolumeClaim.go b/depRicKubernetesOperator/internal/controller/getPersistentVolumeClaim.go
new file mode 100644
index 0000000..9bab433
--- /dev/null
+++ b/depRicKubernetesOperator/internal/controller/getPersistentVolumeClaim.go
@@ -0,0 +1,34 @@
+package controller
+
+import (
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func GetPersistentVolumeClaim() []*corev1.PersistentVolumeClaim {
+
+	persistentVolumeClaim1 := &corev1.PersistentVolumeClaim{
+		Spec: corev1.PersistentVolumeClaimSpec{
+			AccessModes: []corev1.PersistentVolumeAccessMode{
+
+				corev1.PersistentVolumeAccessMode("ReadWriteOnce"),
+			},
+			Resources: corev1.ResourceRequirements{
+				Requests: corev1.ResourceList{
+					"storage": resource.MustParse("100Mi"),
+				},
+			},
+			StorageClassName: stringPtr("local-storage"),
+		},
+		TypeMeta: metav1.TypeMeta{
+			Kind:       "PersistentVolumeClaim",
+			APIVersion: "v1",
+		},
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      "pvc-ricplt-alarmmanager",
+			Namespace: "ricplt",
+		},
+	}
+	return []*corev1.PersistentVolumeClaim{persistentVolumeClaim1}
+}