Tanzu RabbitMQ support: SDS status

michaelklishin · Jan 17, 2025 · 054f5eb · 054f5eb
1 parent 99424a3
commit 054f5eb
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 4 deletions.
diff --git a/src/blocking_api.rs b/src/blocking_api.rs
@@ -26,7 +26,7 @@ use crate::{
         self, BulkUserDelete, EnforcedLimitParams, ExchangeParams, Permissions, PolicyParams,
         QueueParams, RuntimeParameterDefinition, UserParams, VirtualHostParams, XArguments,
     },
-    responses::{self, BindingInfo, DefinitionSet},
+    responses::{self, BindingInfo, DefinitionSet, SchemaDefinitionSyncStatus},
 };
 use backtrace::Backtrace;
 use reqwest::{
@@ -1238,6 +1238,24 @@ where
         Ok(response)
     }
 
+    //
+    // Schema Definition Sync (Tanzu RabbitMQ)
+    //
+
+    pub fn schema_definition_sync_status(&self, node: Option<&str>) -> Result<SchemaDefinitionSyncStatus> {
+        let response = match node {
+            Some(val) => {
+                self.http_get(path!("tanzu", "osr", "schema", "status", val), None, None)?
+            }
+            None => {
+                self.http_get("tanzu/osr/schema/status", None, None)?
+            }
+        };
+        let response = response.json()?;
+
+        Ok(response)
+    }
+
     //
     // Implementation
     //

diff --git a/src/responses.rs b/src/responses.rs
@@ -1121,7 +1121,7 @@ impl From<FeatureFlagState> for String {
     fn from(value: FeatureFlagState) -> Self {
         match value {
             FeatureFlagState::Enabled => "enabled".to_owned(),
-            FeatureFlagState::Disabled => "disbled".to_owned(),
+            FeatureFlagState::Disabled => "disabled".to_owned(),
             FeatureFlagState::StateChanging => "state_changing".to_owned(),
             FeatureFlagState::Unavailable => "unavailable".to_owned(),
         }
@@ -1224,7 +1224,7 @@ impl From<&str> for DeprecationPhase {
     fn from(value: &str) -> Self {
         match value {
             "permitted_by_default" => DeprecationPhase::PermittedByDefault,
-            "denited_by_default" => DeprecationPhase::DeniedByDefault,
+            "denied_by_default" => DeprecationPhase::DeniedByDefault,
             "disconnected" => DeprecationPhase::Disconnected,
             "removed" => DeprecationPhase::Removed,
             _ => DeprecationPhase::Undefined,
@@ -1236,7 +1236,7 @@ impl From<String> for DeprecationPhase {
     fn from(value: String) -> Self {
         match value.as_str() {
             "permitted_by_default" => DeprecationPhase::PermittedByDefault,
-            "denited_by_default" => DeprecationPhase::DeniedByDefault,
+            "denied_by_default" => DeprecationPhase::DeniedByDefault,
             "disconnected" => DeprecationPhase::Disconnected,
             "removed" => DeprecationPhase::Removed,
             _ => DeprecationPhase::Undefined,
@@ -1286,6 +1286,18 @@ pub struct DeprecatedFeature {
 #[serde(transparent)]
 pub struct DeprecatedFeatureList(pub Vec<DeprecatedFeature>);
 
+#[derive(Debug, Serialize, Deserialize, Clone, Eq, PartialEq)]
+#[cfg_attr(feature = "tabled", derive(Tabled))]
+#[allow(dead_code)]
+pub struct SchemaDefinitionSyncStatus {
+    pub node: String,
+    pub upstream_username: String,
+}
+
+//
+// Implementation
+//
+
 fn undefined() -> String {
     "?".to_string()
 }