add basic server implementation

Author: agavra

Cargo.lock

@@ -25,4 +25,7 @@ slatedb = "0.9.1"
 thiserror = "2.0"
 tokio = { version = "1.0", features = ["full"] }
 tracing = "0.1"
-uuid = "1.14.0"
+tracing-subscriber = "0.3"
+uuid = "1.14.0"
+axum = "0.7"
+tower-http = { version = "0.5", features = ["cors"] }

Cargo.toml

@@ -13,10 +13,13 @@ opendata-common.workspace = true
 slatedb.workspace = true
 tokio.workspace = true
 tracing.workspace = true
+tracing-subscriber.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 thiserror.workspace = true
 uuid.workspace = true
+axum.workspace = true
+tower-http.workspace = true
 
 blake3 = "1.8.2"
 promql-parser = "0.6"

open-tsdb/Cargo.toml

@@ -13,6 +13,31 @@ mod test_utils;
 mod tsdb;
 mod util;
 
-fn main() {
-    println!("open-tsdb: timeseries store");
+use std::sync::Arc;
+
+use opendata_common::storage::in_memory::InMemoryStorage;
+
+use promql::server::{PromqlServer, ServerConfig};
+use storage::merge_operator::OpenTsdbMergeOperator;
+use tsdb::Tsdb;
+
+#[tokio::main]
+async fn main() {
+    // Initialize tracing
+    tracing_subscriber::fmt::init();
+
+    // Create in-memory storage with merge operator
+    let storage = Arc::new(InMemoryStorage::with_merge_operator(Arc::new(
+        OpenTsdbMergeOperator,
+    )));
+
+    // Create Tsdb
+    let tsdb = Arc::new(Tsdb::new(storage));
+
+    // Create and run server on default port (9090)
+    let config = ServerConfig::default();
+    let server = PromqlServer::new(tsdb, config);
+
+    println!("Starting open-tsdb Prometheus-compatible server on port 9090...");
+    server.run().await;
 }

open-tsdb/src/main.rs

@@ -5,4 +5,5 @@ mod request;
 mod response;
 mod router;
 pub(crate) mod selector;
+pub(crate) mod server;
 mod tsdb_router;