Add embedded PostgreSQL extension POC

Author: jamals86

Cargo.lock

@@ -1,6 +1,13 @@
 [workspace]
 resolver = "2"
 members = [
+    "kalam-pg/crates/kalam-pg-common",
+    "kalam-pg/crates/kalam-pg-api",
+    "kalam-pg/crates/kalam-pg-embedded",
+    "kalam-pg/crates/kalam-pg-fdw",
+    "kalam-pg/crates/kalam-pg-extension",
+    "kalam-pg/crates/kalam-pg-types",
+    "kalam-pg/crates/kalam-pg-client",
     "backend/crates/kalamdb-macros",
     "backend/crates/kalamdb-commons",
     "backend/crates/kalamdb-configs",
@@ -135,6 +142,7 @@ prost-types = "0.14.3"
 bcrypt = "0.19.0"
 rand = "0.10.0"
 kalamdb-commons = { path = "backend/crates/kalamdb-commons" }
+kalamdb-tables = { path = "backend/crates/kalamdb-tables" }
 kalamdb-views = { path = "backend/crates/kalamdb-views" }
 cookie = { version = "0.18", features = ["secure"] }
 colored = "3.1.1"

Cargo.toml

@@ -326,6 +326,7 @@ mod tests {
                 max_rows_per_user: 256, // Default per-user retention limit
                 shard_router: ShardRouter::default_config(),
                 ttl_seconds: Some(1),
+                storage_mode: kalamdb_tables::StreamTableStorageMode::File,
             },
         ));
         let tables_schema_registry =

backend/crates/kalamdb-core/src/jobs/executors/stream_eviction.rs

@@ -64,6 +64,7 @@ async fn create_test_manager() -> (Arc<ConnectionsManager>, LiveQueryManager, Te
             max_rows_per_user: 256, // Default per-user retention limit
             shard_router: ShardRouter::default_config(),
             ttl_seconds: Some(60),
+            storage_mode: kalamdb_tables::StreamTableStorageMode::File,
         },
     ));
 

backend/crates/kalamdb-core/src/live/manager/tests.rs

@@ -673,6 +673,7 @@ impl SchemaRegistry {
                         max_rows_per_user: 256, // Default per-user retention limit
                         shard_router: ShardRouter::default_config(),
                         ttl_seconds: Some(ttl_seconds),
+                        storage_mode: kalamdb_tables::StreamTableStorageMode::File,
                     },
                 ));
 

backend/crates/kalamdb-core/src/schema_registry/registry/core.rs

@@ -68,7 +68,7 @@ pub use shared_tables::shared_table_store::{
     SharedTableRow, SharedTableStore,
 };
 pub use stream_tables::stream_table_store::{
-    new_stream_table_store, StreamTableStore, StreamTableStoreConfig,
+    new_stream_table_store, StreamTableStorageMode, StreamTableStore, StreamTableStoreConfig,
 };
 pub use topics::topic_message_models::{TopicMessage, TopicMessageId};
 pub use topics::topic_message_store::TopicMessageStore;

backend/crates/kalamdb-tables/src/lib.rs

@@ -10,7 +10,9 @@ pub mod stream_table_store;
 
 pub use kalamdb_commons::models::StreamTableRow;
 pub use stream_table_provider::StreamTableProvider;
-pub use stream_table_store::{new_stream_table_store, StreamTableStore, StreamTableStoreConfig};
+pub use stream_table_store::{
+    new_stream_table_store, StreamTableStorageMode, StreamTableStore, StreamTableStoreConfig,
+};
 
 // Re-export StreamTableRowId from kalamdb_commons for convenience
 pub use kalamdb_commons::ids::StreamTableRowId;