test: add unit test for extractor

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

operator-k8s/Cargo.toml

@@ -39,3 +39,4 @@ event-listener = "2.5.3"
 
 [dev-dependencies]
 garde = { version = "0.11.2", default-features = false, features = ["derive", "pattern"] }
+serde_yaml = "0.9.25"

operator-k8s/src/consts.rs

@@ -28,3 +28,5 @@ pub(crate) const ANNOTATION_INHERIT_LABELS_PREFIX: &str =
 pub(crate) const LABEL_CLUSTER_NAME: &str = "xlinecluster/name";
 /// The label attach to subresources, indicate the component type of this subresource
 pub(crate) const LABEL_CLUSTER_COMPONENT: &str = "xlinecluster/component";
+/// Indicate the version of operator that creates this subresource
+pub(crate) const LABEL_OPERATOR_VERSION: &str = "xlinecluster/operator-version";

operator-k8s/src/crd/v1alpha1/cluster.rs

@@ -89,6 +89,15 @@ pub(crate) enum StorageSpec {
     },
 }
 
+impl StorageSpec {
+    pub(crate) fn as_pvc(&self) -> Option<&PersistentVolumeClaim> {
+        match *self {
+            Self::Pvc { ref pvc } => Some(pvc),
+            Self::S3 { .. } => None,
+        }
+    }
+}
+
 /// Xline cluster backup S3 specification
 #[derive(Serialize, Deserialize, Clone, Debug, JsonSchema)]
 #[cfg_attr(test, derive(Validate))]

operator-k8s/src/crd/v1alpha1/mod.rs

@@ -1,6 +1,5 @@
 #![allow(unused)] // TODO: remove when this CRD is used
 
-pub(crate) use cluster::Cluster;
-pub(crate) use cluster::StorageSpec;
+pub(crate) use cluster::{BackupSpec, Cluster, ClusterSpec, StorageSpec};
 
 mod cluster;