feat: wip

Author: oxyno-zeta

api/postgresql/v1alpha1/postgresqlbackup_types.go

@@ -18,6 +18,8 @@ package v1alpha1
 
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	"github.com/easymile/postgresql-operator/api/postgresql/common"
 )
 
 // EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
@@ -27,12 +29,38 @@ import (
 type PostgresqlBackupSpec struct {
 	// Schedule for cronjob
 	Schedule string `json:"schedule"`
+	// One shot backup ?
+	OneShot bool `json:"oneShot"`
+	// Postgresql Database
+	// +required
+	// +kubebuilder:validation:Required
+	Database *common.CRLink `json:"database"`
+	// Postgresql backup provider
+	// +required
+	// +kubebuilder:validation:Required
+	BackupProvider *common.CRLink `json:"backupProvider"`
 }
 
+type BackupStatusPhase string
+
+const (
+	BackupNoPhase    BackupStatusPhase = ""
+	BackupErrorPhase BackupStatusPhase = "Error"
+	BackupValidPhase BackupStatusPhase = "Valid"
+)
+
 // PostgresqlBackupStatus defines the observed state of PostgresqlBackup.
 type PostgresqlBackupStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// Current phase of the operator
+	Phase BackupProviderStatusPhase `json:"phase,omitempty"`
+	// Human-readable message indicating details about current operator phase or error.
+	// +optional
+	Message string `json:"message,omitempty"`
+	// True if all resources are in a ready state and all work is done.
+	// +optional
+	Ready bool `json:"ready,omitempty"`
+	// Resource Spec hash
+	Hash string `json:"hash,omitempty"`
 }
 
 // +kubebuilder:object:root=true

api/postgresql/v1alpha1/zz_generated.deepcopy.go

@@ -340,8 +340,20 @@ func main() {
 		os.Exit(1)
 	}
 	if err := (&postgresqlcontrollers.PostgresqlBackupReconciler{
-		Client: mgr.GetClient(),
-		Scheme: mgr.GetScheme(),
+		Client:   mgr.GetClient(),
+		Scheme:   mgr.GetScheme(),
+		Recorder: mgr.GetEventRecorderFor("postgresqlbackup-controller"),
+		Log: ctrl.Log.WithValues(
+			"controller",
+			"postgresqlbackup",
+			"controllerKind",
+			"PostgresqlBackup",
+			"controllerGroup",
+			"postgresql.easymile.com",
+		),
+		ControllerRuntimeDetailedErrorTotal: controllerRuntimeDetailedErrorTotal,
+		ControllerName:                      "postgresqlbackup",
+		ReconcileTimeout:                    reconcileTimeout,
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "PostgresqlBackup")
 		os.Exit(1)

cmd/main.go

@@ -39,13 +39,59 @@ spec:
           spec:
             description: PostgresqlBackupSpec defines the desired state of PostgresqlBackup.
             properties:
-              foo:
-                description: Foo is an example field of PostgresqlBackup. Edit postgresqlbackup_types.go
-                  to remove/update
+              backupProvider:
+                description: Postgresql backup provider
+                properties:
+                  name:
+                    description: Custom resource name
+                    type: string
+                  namespace:
+                    description: Custom resource namespace
+                    type: string
+                required:
+                - name
+                type: object
+              database:
+                description: Postgresql Database
+                properties:
+                  name:
+                    description: Custom resource name
+                    type: string
+                  namespace:
+                    description: Custom resource namespace
+                    type: string
+                required:
+                - name
+                type: object
+              oneShot:
+                description: One shot backup ?
+                type: boolean
+              schedule:
+                description: Schedule for cronjob
                 type: string
+            required:
+            - backupProvider
+            - database
+            - oneShot
+            - schedule
             type: object
           status:
             description: PostgresqlBackupStatus defines the observed state of PostgresqlBackup.
+            properties:
+              hash:
+                description: Resource Spec hash
+                type: string
+              message:
+                description: Human-readable message indicating details about current
+                  operator phase or error.
+                type: string
+              phase:
+                description: Current phase of the operator
+                type: string
+              ready:
+                description: True if all resources are in a ready state and all work
+                  is done.
+                type: boolean
             type: object
         type: object
     served: true

config/crd/bases/postgresql.easymile.com_postgresqlbackups.yaml

@@ -18,8 +18,12 @@ package postgresql
 
 import (
 	"context"
+	"time"
 
+	"github.com/go-logr/logr"
+	"github.com/prometheus/client_golang/prometheus"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/client-go/tools/record"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	ctrl "sigs.k8s.io/controller-runtime"
@@ -30,8 +34,13 @@ import (
 
 // PostgresqlBackupReconciler reconciles a PostgresqlBackup object.
 type PostgresqlBackupReconciler struct {
+	Recorder record.EventRecorder
 	client.Client
-	Scheme *runtime.Scheme
+	Scheme                              *runtime.Scheme
+	ControllerRuntimeDetailedErrorTotal *prometheus.CounterVec
+	Log                                 logr.Logger
+	ControllerName                      string
+	ReconcileTimeout                    time.Duration
 }
 
 // +kubebuilder:rbac:groups=postgresql.easymile.com,resources=postgresqlbackups,verbs=get;list;watch;create;update;patch;delete