experimental: sse client support

server/Cargo.toml

@@ -29,6 +29,7 @@ actix-http = "3.9.0"
 actix-middleware-etag = "0.4.2"
 actix-service = "2.0.2"
 actix-web = { version = "4.9.0", features = ["rustls-0_23", "compress-zstd"] }
+actix-web-lab = "0.23.0"
 ahash = "0.8.11"
 anyhow = "1.0.91"
 async-trait = "0.1.83"
@@ -40,8 +41,10 @@ cidr = "0.3.0"
 clap = { version = "4.5.19", features = ["derive", "env"] }
 clap-markdown = "0.1.4"
 dashmap = "6.0.1"
+eventsource-client = "0.13.0"
 futures = "0.3.30"
 futures-core = "0.3.30"
+futures-util = "0.3.31"
 iter_tools = "0.24.0"
 itertools = "0.13.0"
 lazy_static = "1.4.0"
@@ -55,6 +58,7 @@ opentelemetry_sdk = { version = "0.24.0", features = [
     "serde_json",
     "logs",
 ] }
+parking_lot = "0.12.3"
 prometheus = { version = "0.13.4", features = ["process"] }
 prometheus-reqwest-remote-write = { version = "0.2.1" }
 prometheus-static-metric = "0.5.1"
@@ -87,6 +91,7 @@ tokio = { version = "1.41.0", features = [
     "tracing",
     "fs",
 ] }
+tokio-stream = "0.1.16"
 tracing = { version = "0.1.40", features = ["log"] }
 tracing-subscriber = { version = "0.3.18", features = ["json", "env-filter"] }
 ulid = "1.1.2"