Feat/refactor iceberg context for concurrency

Cargo.toml

@@ -24,11 +24,12 @@ http-serde = "2"
 iceberg = "0.4"
 iceberg-catalog-rest = "0.4"
 miette = { version = "7", features = ["fancy"] }
+num-format = { version = "0.4", features = ["with-system-locale"] }
 ratatui = "0.29"
 serde = "1"
 streemap = "0.1"
 terminal_size = "0.4"
 thiserror = "2"
 tokio = "1"
 tracing = "0.1"
-tracing-subscriber = { version = "0.3", features = ["env-filter"] }
+tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }

tanic-core/config.rs

@@ -37,6 +37,12 @@ impl ConnectionDetails {
     }
 }
 
+impl PartialEq for ConnectionDetails {
+    fn eq(&self, other: &Self) -> bool {
+        self.uri == other.uri
+    }
+}
+
 /// persistable user config.
 ///
 /// Loaded in at application startup from $CONFIG/tanic/tanic.toml

tanic-core/error.rs

@@ -27,3 +27,9 @@ pub enum TanicError {
     #[error("Unexpected")]
     UnexpectedError(String),
 }
+
+impl TanicError {
+    pub fn unexpected<T: ToString>(msg: T) -> Self {
+        Self::UnexpectedError(msg.to_string())
+    }
+}

tanic-core/message.rs

@@ -11,3 +11,14 @@ pub struct TableDeets {
     pub name: String,
     pub row_count: usize,
 }
+
+impl NamespaceDeets {
+    pub fn from_parts(parts: Vec<String>) -> Self {
+        let name = parts.clone().join(".");
+        Self {
+            parts,
+            name,
+            table_count: 0,
+        }
+    }
+}

tanic-svc/Cargo.toml

@@ -28,6 +28,10 @@ iceberg-catalog-rest = "0.4.0"
 serde = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }
-uuid = { version = "1.12.0", features = ["v4"] }
-names = "0.14.0"
-tokio-stream = { version = "0.1.17", features = ["sync"] }
+uuid = { version = "1", features = ["v4"] }
+names = "0.14"
+num-format = { workspace = true }
+tokio-stream = { version = "0.1", features = ["sync"] }
+parquet = "54.0.0"
+indexmap = "2"
+futures = "0.3"