Initial federation link types

Author: michaelklishin

src/responses.rs

@@ -2046,6 +2046,49 @@ impl TryFrom<RuntimeParameter> for FederationUpstream {
     }
 }
 
+#[derive(Debug, Deserialize, Clone, Eq, PartialEq, Default)]
+#[serde(rename_all = "lowercase")]
+pub enum FederationType {
+    #[default]
+    Exchange,
+    Queue,
+}
+
+impl fmt::Display for FederationType {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        match self {
+            FederationType::Exchange => write!(f, "exchange"),
+            FederationType::Queue => write!(f, "queue"),
+        }
+    }
+}
+
+impl From<String> for FederationType {
+    fn from(value: String) -> Self {
+        match value.as_str() {
+            "exchange" => FederationType::Exchange,
+            "queue" => FederationType::Queue,
+            _ => FederationType::default(),
+        }
+    }
+}
+
+#[derive(Debug, Deserialize, Clone, Eq, PartialEq)]
+#[cfg_attr(feature = "tabled", derive(Tabled))]
+#[allow(dead_code)]
+pub struct FederationLink {
+    pub node: String,
+    pub vhost: String,
+    pub id: String,
+    pub uri: String,
+    pub status: String,
+    #[serde(rename = "type")]
+    pub typ: FederationType,
+    pub upstream: String,
+    #[cfg_attr(feature = "tabled", tabled(display = "display_option"))]
+    pub consumer_tag: Option<String>,
+}
+
 //
 // Shovels
 //

tests/unit_federation_conversion_tests.rs

@@ -15,7 +15,7 @@ mod test_helpers;
 
 use rabbitmq_http_client::{
     commons::MessageTransferAcknowledgementMode,
-    responses::{FederationUpstream, RuntimeParameter},
+    responses::{FederationLink, FederationType, FederationUpstream, RuntimeParameter},
 };
 
 #[test]
@@ -86,3 +86,65 @@ fn test_unit_deserialize_federation_upstream_case2() {
         upstream.ack_mode
     );
 }
+
+#[test]
+fn test_unit_deserialize_federation_link_case1() {
+    let json = r#"
+        {
+          "node": "rabbit@sunnyside",
+          "queue": "fed.cq.1",
+          "upstream_queue": "fed.cq.overridden",
+          "consumer_tag": "hgksdh98s7f98au9u",
+          "type": "queue",
+          "vhost": "/",
+          "upstream": "up-1",
+          "id": "e178dfad",
+          "status": "running",
+          "local_connection": "<[email protected]>",
+          "uri": "amqp://localhost:5672/fed",
+          "timestamp": "2025-03-16 0:41:29",
+          "local_channel": {
+            "acks_uncommitted": 0,
+            "confirm": true,
+            "connection_details": {
+              "name": "<[email protected]>",
+              "peer_host": "undefined",
+              "peer_port": "undefined"
+            },
+            "consumer_count": 0,
+            "garbage_collection": {
+              "fullsweep_after": 65535,
+              "max_heap_size": 0,
+              "min_bin_vheap_size": 1727361,
+              "min_heap_size": 233,
+              "minor_gcs": 6
+            },
+            "idle_since": "2025-03-16T00:41:30.097-04:00",
+            "messages_unacknowledged": 0,
+            "messages_uncommitted": 0,
+            "messages_unconfirmed": 0,
+            "name": "<[email protected]> (1)",
+            "node": "rabbit@sunnyside",
+            "number": 1,
+            "pending_raft_commands": 0,
+            "prefetch_count": 0,
+            "reductions": 1127,
+            "reductions_details": {
+              "rate": 0.0
+            },
+            "state": "running",
+            "transactional": false,
+            "user": "none",
+            "user_who_performed_action": "none",
+            "vhost": "/"
+          }
+        }
+    "#;
+
+    let link: FederationLink = serde_json::from_str(&json).unwrap();
+    assert_eq!(link.uri, "amqp://localhost:5672/fed");
+    assert_eq!(link.id, "e178dfad");
+    assert_eq!(link.typ, FederationType::Queue);
+    assert_eq!(link.upstream, "up-1");
+    assert_eq!(link.consumer_tag.unwrap(), "hgksdh98s7f98au9u");
+}