Create session management

otel-worker-cli/Cargo.toml

@@ -56,6 +56,7 @@ rust-mcp-schema = { version = "0.1.0", features = ["2024_11_05"] }
 schemars = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
+serde_urlencoded = "0.7.1"
 serde_with = { version = "3.8.1" }
 strum = { version = "0.26", features = ["derive"] }
 thiserror = { version = "2.0" }
@@ -72,6 +73,7 @@ tracing = { version = "0.1" }
 tracing-opentelemetry = { version = "0.28" }
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }
 url = { version = "2.5" }
+uuid = { version = "1.15.1", features = ["v4"] }
 
 [dev-dependencies]
 test-log = { version = "0.2", default-features = false, features = ["trace"] }

otel-worker-cli/src/commands/client/spans.rs

@@ -1,6 +1,6 @@
 use anyhow::Result;
 use clap::Subcommand;
-use otel_worker_core::api::client;
+use otel_worker_core::api::client::ApiClient;
 use std::io::stdout;
 use url::Url;
 
@@ -46,7 +46,7 @@ pub struct GetArgs {
 }
 
 async fn handle_get(args: GetArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();
 
@@ -70,7 +70,7 @@ pub struct ListArgs {
 }
 
 async fn handle_list(args: ListArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();
 
@@ -97,7 +97,7 @@ pub struct DeleteArgs {
 }
 
 async fn handle_delete(args: DeleteArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();
 

otel-worker-cli/src/commands/client/traces.rs

@@ -1,7 +1,7 @@
 use crate::commands::util::parse_rfc3339_from_str;
 use anyhow::Result;
 use clap::Subcommand;
-use otel_worker_core::api::client;
+use otel_worker_core::api::client::ApiClient;
 use std::io::stdout;
 use time::OffsetDateTime;
 use url::Url;
@@ -45,7 +45,7 @@ pub struct GetArgs {
 }
 
 async fn handle_get(args: GetArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();
 
@@ -74,7 +74,7 @@ pub struct ListArgs {
 }
 
 async fn handle_list(args: ListArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();
 
@@ -98,7 +98,7 @@ pub struct DeleteArgs {
 }
 
 async fn handle_delete(args: DeleteArgs) -> Result<()> {
-    let api_client = client::builder(args.base_url.clone())
+    let api_client = ApiClient::builder(args.base_url.clone())
         .set_bearer_token(args.auth_token)
         .build();