Initial stuff for managed connector specs

infinyon · simlay · Aug 24, 2021 · Aug 24, 2021 · Aug 25, 2021 · Aug 25, 2021
commit a56aa5c7e1b6bd2aa922e0595fba9e3f8ed7a751
diff --git a/src/controlplane-metadata/src/lib.rs b/src/controlplane-metadata/src/lib.rs
@@ -3,6 +3,7 @@ pub mod topic;
 pub mod partition;
 pub mod spg;
 pub mod message;
+pub mod managed_connector;
 
 pub use fluvio_stream_model::core;
 

diff --git a/src/controlplane-metadata/src/managed_connector/k8/mod.rs b/src/controlplane-metadata/src/managed_connector/k8/mod.rs
@@ -0,0 +1,15 @@
+//!
+//! # Cluster
+//!
+//! Interface to the Cluster metadata in K8 key value store
+//!
+mod spec;
+
+pub use self::spec::*;
+
+use super::ManagedConnectorStatus;
+use super::ManagedConnectorConfig;
+use crate::k8_types::Status as K8Status;
+
+/// implement k8 status for spu group status because they are same
+impl K8Status for ManagedConnectorStatus {}
diff --git a/src/controlplane-metadata/src/managed_connector/k8/spec.rs b/src/controlplane-metadata/src/managed_connector/k8/spec.rs
@@ -0,0 +1,84 @@
+//!
+//! # SPU Spec
+//!
+//! Interface to the SPU metadata spec in K8 key value store
+//!
+use serde::Deserialize;
+use serde::Serialize;
+
+use fluvio_types::defaults::{SPU_PUBLIC_PORT, SPU_LOG_BASE_DIR, SPU_LOG_SIZE};
+use fluvio_types::defaults::SPU_PRIVATE_PORT;
+
+use crate::spu::EncryptionEnum;
+use super::super::ManagedConnectorStatus;
+use crate::k8_types::{Spec, Crd, DefaultHeader, TemplateSpec, Env};
+
+use crd::MANAGED_CONNECTOR_API;
+mod crd {
+
+    use crate::k8_types::{Crd, CrdNames, GROUP, V1};
+
+    pub const MANAGED_CONNECTOR_API: Crd = Crd {
+        group: GROUP,
+        version: V1,
+        names: CrdNames {
+            kind: "ManagedConnector",
+            plural: "managedconnectors",
+            singular: "managedconnector",
+        },
+    };
+}
+
+impl Spec for K8ManagedConnectorSpec {
+    type Status = ManagedConnectorStatus;
+    type Header = DefaultHeader;
+    fn metadata() -> &'static Crd {
+        &MANAGED_CONNECTOR_API
+    }
+}
+use super::ManagedConnectorConfig;
+
+#[derive(Deserialize, Serialize, Default, Debug, Clone)]
+#[serde(rename_all = "camelCase", default)]
+pub struct K8ManagedConnectorSpec {
+    pub name: String,
+    pub config: ManagedConnectorConfig,
+}
+mod convert {
+
+    use crate::managed_connector::*;
+
+    use super::*;
+
+    impl From<K8ManagedConnectorSpec> for ManagedConnectorSpec {
+        fn from(spec: K8ManagedConnectorSpec) -> Self {
+            Self {
+                name: spec.name,
+                config: spec.config,
+            }
+        }
+    }
+    /*
+    impl From<SpuTemplate> for SpuConfig {
+        fn from(template: SpuTemplate) -> Self {
+            Self {
+                rack: template.rack,
+                replication: template.replication.map(|r| r.into()),
+                storage: template.storage.map(|s| s.into()),
+                env: vec![], // doesn't really matter
+            }
+        }
+    }
+    */
+
+    impl From<ManagedConnectorSpec> for K8ManagedConnectorSpec {
+        fn from(spec: ManagedConnectorSpec) -> Self {
+            Self {
+                name: spec.name,
+                config: spec.config,
+            }
+        }
+    }
+
+
+}
diff --git a/src/controlplane-metadata/src/managed_connector/mod.rs b/src/controlplane-metadata/src/managed_connector/mod.rs
@@ -0,0 +1,65 @@
+mod spec;
+mod status;
+pub mod store;
+
+pub use spec::*;
+pub use status::*;
+
+#[cfg(feature = "k8")]
+mod k8;
+#[cfg(feature = "k8")]
+pub use k8::*;
+
+mod convert {
+
+    use crate::core::{Spec, Status, Removable, Creatable};
+    use crate::extended::{ObjectType, SpecExt};
+    use super::*;
+
+    impl Spec for ManagedConnectorSpec {
+        const LABEL: &'static str = "SpuGroup";
+
+        type Status = ManagedConnectorStatus;
+
+        type Owner = Self;
+        type IndexKey = String;
+    }
+
+    impl SpecExt for ManagedConnectorSpec {
+        const OBJECT_TYPE: ObjectType = ObjectType::SpuGroup;
+    }
+
+    impl Removable for ManagedConnectorSpec {
+        type DeleteKey = String;
+    }
+
+    impl Creatable for ManagedConnectorSpec {}
+
+    impl Status for ManagedConnectorStatus {}
+
+    #[cfg(feature = "k8")]
+    mod extended {
+
+        use crate::store::k8::K8ExtendedSpec;
+        use crate::store::k8::K8ConvertError;
+        use crate::store::k8::K8MetaItem;
+        use crate::store::MetadataStoreObject;
+        use crate::k8_types::K8Obj;
+        use crate::store::k8::default_convert_from_k8;
+
+        use super::ManagedConnectorSpec;
+        use super::K8ManagedConnectorSpec;
+
+        impl K8ExtendedSpec for ManagedConnectorSpec {
+            type K8Spec = K8ManagedConnectorSpec;
+            type K8Status = Self::Status;
+
+            fn convert_from_k8(
+                k8_obj: K8Obj<Self::K8Spec>,
+            ) -> Result<MetadataStoreObject<Self, K8MetaItem>, K8ConvertError<Self::K8Spec>>
+            {
+                default_convert_from_k8(k8_obj)
+            }
+        }
+    }
+}
diff --git a/src/controlplane-metadata/src/managed_connector/spec.rs b/src/controlplane-metadata/src/managed_connector/spec.rs
@@ -0,0 +1,29 @@
+#![allow(clippy::assign_op_pattern)]
+
+use dataplane::core::{Encoder, Decoder};
+use fluvio_types::defaults::{SPU_LOG_BASE_DIR, SPU_LOG_SIZE};
+
+#[derive(Encoder, Decoder, Default, Debug, PartialEq, Clone)]
+#[cfg_attr(
+    feature = "use_serde",
+    derive(serde::Serialize, serde::Deserialize),
+    serde(rename_all = "camelCase")
+)]
+pub struct ManagedConnectorSpec {
+    pub name: String,
+    /// Configuration elements to be applied to each SPUs in the group
+    pub config: ManagedConnectorConfig,
+}
+
+#[derive(Encoder, Decoder, Default, Debug, Clone, PartialEq)]
+#[cfg_attr(
+    feature = "use_serde",
+    derive(serde::Serialize, serde::Deserialize),
+    serde(rename_all = "camelCase")
+)]
+pub struct ManagedConnectorConfig {
+    pub r#type: String, // syslog, github star, slack
+}
+
+impl ManagedConnectorConfig {
+}
diff --git a/src/controlplane-metadata/src/managed_connector/status.rs b/src/controlplane-metadata/src/managed_connector/status.rs
@@ -0,0 +1,72 @@
+#![allow(clippy::assign_op_pattern)]
+
+use std::fmt;
+
+use dataplane::core::{Encoder, Decoder};
+
+#[derive(Encoder, Decoder, Default, Debug, Clone, PartialEq)]
+#[cfg_attr(
+    feature = "use_serde",
+    derive(serde::Serialize, serde::Deserialize),
+    serde(rename_all = "camelCase")
+)]
+pub struct ManagedConnectorStatus {
+    /// Status resolution
+    pub resolution: ManagedConnectorStatusResolution,
+
+    /// Reason for Status resolution (if applies)
+    pub reason: Option<String>,
+}
+
+impl fmt::Display for ManagedConnectorStatus {
+    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+        write!(f, "{:#?}", self.resolution)
+    }
+}
+
+impl ManagedConnectorStatus {
+    pub fn invalid(reason: String) -> Self {
+        Self {
+            resolution: ManagedConnectorStatusResolution::Invalid,
+            reason: Some(reason),
+        }
+    }
+
+    pub fn reserved() -> Self {
+        Self {
+            resolution: ManagedConnectorStatusResolution::Reserved,
+            ..Default::default()
+        }
+    }
+
+    pub fn is_already_valid(&self) -> bool {
+        self.resolution == ManagedConnectorStatusResolution::Reserved
+    }
+}
+
+#[cfg_attr(feature = "use_serde", derive(serde::Serialize, serde::Deserialize))]
+#[derive(Encoder, Decoder, Debug, Clone, PartialEq)]
+pub enum ManagedConnectorStatusResolution {
+    Init,
+    Invalid,
+    Reserved,
+}
+
+// -----------------------------------
+// Implementation - FlvSpuGroupResolution
+// -----------------------------------
+impl Default for ManagedConnectorStatusResolution {
+    fn default() -> Self {
+        Self::Init
+    }
+}
+
+impl fmt::Display for ManagedConnectorStatusResolution {
+    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+        match self {
+            Self::Init => write!(f, "Init"),
+            Self::Invalid => write!(f, "Invalid"),
+            Self::Reserved => write!(f, "Reserved"),
+        }
+    }
+}
diff --git a/src/controlplane-metadata/src/managed_connector/store.rs b/src/controlplane-metadata/src/managed_connector/store.rs
@@ -0,0 +1,11 @@
+//!
+//! Spu Group
+//!
+
+use crate::store::*;
+
+use super::*;
+
+pub type SpuGroupMetadata<C> = MetadataStoreObject<ManagedConnectorSpec, C>;
+
+pub type SpuGroupLocalStore<C> = LocalStore<ManagedConnectorSpec, C>;