feat: expose the flight-sql port (#206)

Author: nathanielc

common/src/peer_info.rs

@@ -57,6 +57,8 @@ pub struct CeramicPeerInfo {
     pub ipfs_rpc_addr: String,
     /// Ceramic API address of the peer.
     pub ceramic_addr: String,
+    /// Flight SQL API address of the peer.
+    pub flight_addr: String,
     /// Set of p2p addresses of the peer.
     /// Each address contains the /p2p/<peer_id> protocol.
     pub p2p_addrs: Vec<String>,

operator/src/network/ceramic.rs

@@ -34,7 +34,8 @@ use crate::{
 };
 
 use super::{
-    controller::CERAMIC_ONE_SWARM_PORT, debug_mode_security_context,
+    controller::{CERAMIC_ONE_FLIGHT_SQL_PORT, CERAMIC_ONE_SWARM_PORT},
+    debug_mode_security_context,
     storage::PersistentStorageConfig,
 };
 
@@ -124,6 +125,12 @@ pub fn service_spec() -> ServiceSpec {
                 protocol: Some("TCP".to_owned()),
                 ..Default::default()
             },
+            ServicePort {
+                port: CERAMIC_ONE_FLIGHT_SQL_PORT,
+                name: Some("flight".to_owned()),
+                protocol: Some("TCP".to_owned()),
+                ..Default::default()
+            },
             ServicePort {
                 port: CERAMIC_ONE_SWARM_PORT,
                 name: Some("swarm-tcp".to_owned()),
@@ -251,6 +258,13 @@ impl CeramicInfo {
             self.stateful_set, self.service
         )
     }
+    /// Determine the Flight SQL address of a Ceramic peer
+    pub fn flight_addr(&self, ns: &str, peer: i32) -> String {
+        format!(
+            "http://{}-{peer}.{}.{ns}.svc.cluster.local:{CERAMIC_ONE_FLIGHT_SQL_PORT}",
+            self.stateful_set, self.service
+        )
+    }
 }
 
 impl From<&CeramicInfo> for IpfsInfo {

operator/src/network/controller.rs

@@ -22,7 +22,7 @@ use crate::{
 };
 
 use super::{
-    controller::{CERAMIC_ONE_IPFS_PORT, CERAMIC_ONE_SWARM_PORT},
+    controller::{CERAMIC_ONE_FLIGHT_SQL_PORT, CERAMIC_ONE_IPFS_PORT, CERAMIC_ONE_SWARM_PORT},
     debug_mode_security_context,
 };
 
@@ -243,6 +243,12 @@ impl RustIpfsConfig {
                 protocol: Some("TCP".to_owned()),
                 ..Default::default()
             },
+            ContainerPort {
+                container_port: CERAMIC_ONE_FLIGHT_SQL_PORT,
+                name: Some("flight".to_owned()),
+                protocol: Some("TCP".to_owned()),
+                ..Default::default()
+            },
             ContainerPort {
                 container_port: 9465,
                 name: Some("metrics".to_owned()),

operator/src/network/ipfs.rs

@@ -29,6 +29,11 @@ Request {
             "port": 5101,
             "protocol": "TCP"
           },
+          {
+            "name": "flight",
+            "port": 5102,
+            "protocol": "TCP"
+          },
           {
             "name": "swarm-tcp",
             "port": 4101,

operator/src/network/testdata/ceramic_go_svc_1

@@ -274,6 +274,11 @@ Request {
                     "name": "rpc",
                     "protocol": "TCP"
                   },
+                  {
+                    "containerPort": 5102,
+                    "name": "flight",
+                    "protocol": "TCP"
+                  },
                   {
                     "containerPort": 9465,
                     "name": "metrics",

operator/src/network/testdata/ceramic_ss_1

@@ -274,6 +274,11 @@ Request {
                     "name": "rpc",
                     "protocol": "TCP"
                   },
+                  {
+                    "containerPort": 5102,
+                    "name": "flight",
+                    "protocol": "TCP"
+                  },
                   {
                     "containerPort": 9465,
                     "name": "metrics",

operator/src/network/testdata/ceramic_ss_weighted_0

@@ -274,6 +274,11 @@ Request {
                     "name": "rpc",
                     "protocol": "TCP"
                   },
+                  {
+                    "containerPort": 5102,
+                    "name": "flight",
+                    "protocol": "TCP"
+                  },
                   {
                     "containerPort": 9465,
                     "name": "metrics",

operator/src/network/testdata/ceramic_ss_weighted_1

@@ -274,6 +274,11 @@ Request {
                     "name": "rpc",
                     "protocol": "TCP"
                   },
+                  {
+                    "containerPort": 5102,
+                    "name": "flight",
+                    "protocol": "TCP"
+                  },
                   {
                     "containerPort": 9465,
                     "name": "metrics",

operator/src/network/testdata/ceramic_ss_weighted_2

@@ -274,6 +274,11 @@ Request {
                     "name": "rpc",
                     "protocol": "TCP"
                   },
+                  {
+                    "containerPort": 5102,
+                    "name": "flight",
+                    "protocol": "TCP"
+                  },
                   {
                     "containerPort": 9465,
                     "name": "metrics",