diff --git a/sgl-model-gateway/src/auth/audit.rs b/sgl-model-gateway/src/auth/audit.rs index 77aebe3ca..0decc250b 100644 --- a/sgl-model-gateway/src/auth/audit.rs +++ b/sgl-model-gateway/src/auth/audit.rs @@ -217,7 +217,7 @@ impl AuditLogger { // Log the event info!( - target: "sgl_model_gateway::audit", + target: "smg::audit", timestamp = %event.timestamp.to_rfc3339(), principal = %event.principal, auth_method = %event.auth_method, diff --git a/sgl-model-gateway/src/middleware.rs b/sgl-model-gateway/src/middleware.rs index ed464c596..5ad2c1875 100644 --- a/sgl-model-gateway/src/middleware.rs +++ b/sgl-model-gateway/src/middleware.rs @@ -280,7 +280,7 @@ impl MakeSpan for RequestSpan { // Don't try to extract request ID here - it won't be available yet // The RequestIdLayer runs after TraceLayer creates the span info_span!( - target: "sgl_model_gateway::otel-trace", + target: "smg::otel-trace", "http_request", method = %request.method(), uri = %request.uri(), @@ -289,7 +289,7 @@ impl MakeSpan for RequestSpan { status_code = Empty, latency = Empty, error = Empty, - module = "sgl_model_gateway" + module = "smg" ) } } @@ -314,7 +314,7 @@ impl OnRequest for RequestLogger { // Log the request start info!( - target: "sgl_model_gateway::request", + target: "smg::request", "started processing request" ); } @@ -353,17 +353,17 @@ impl OnResponse for ResponseLogger { let _enter = span.enter(); if status.is_server_error() { error!( - target: "sgl_model_gateway::response", + target: "smg::response", "request failed with server error" ); } else if status.is_client_error() { warn!( - target: "sgl_model_gateway::response", + target: "smg::response", "request failed with client error" ); } else { info!( - target: "sgl_model_gateway::response", + target: "smg::response", "finished processing request" ); } diff --git a/sgl-model-gateway/src/observability/events.rs b/sgl-model-gateway/src/observability/events.rs index c6595a744..2698b0ec6 100644 --- a/sgl-model-gateway/src/observability/events.rs +++ b/sgl-model-gateway/src/observability/events.rs @@ -9,7 +9,7 @@ use super::otel_trace::is_otel_enabled; /// Module path used by CustomOtelFilter to identify events for OTEL export. #[inline] pub const fn get_module_path() -> &'static str { - "sgl_model_gateway::observability::events" + "smg::observability::events" } pub trait Event { diff --git a/sgl-model-gateway/src/observability/logging.rs b/sgl-model-gateway/src/observability/logging.rs index 03861c767..188d9b1b1 100644 --- a/sgl-model-gateway/src/observability/logging.rs +++ b/sgl-model-gateway/src/observability/logging.rs @@ -16,7 +16,7 @@ use super::otel_trace::get_otel_layer; use crate::config::TraceConfig; const TIME_FORMAT: &str = "%Y-%m-%d %H:%M:%S"; -const DEFAULT_LOG_TARGET: &str = "sgl_model_gateway"; +const DEFAULT_LOG_TARGET: &str = "smg"; #[derive(Debug, Clone)] pub struct LoggingConfig { @@ -36,7 +36,7 @@ impl Default for LoggingConfig { json_format: false, log_dir: None, colorize: true, - log_file_name: "sgl-model-gateway".to_string(), + log_file_name: "smg".to_string(), log_targets: Some(vec![DEFAULT_LOG_TARGET.to_string()]), } } diff --git a/sgl-model-gateway/src/observability/otel_trace.rs b/sgl-model-gateway/src/observability/otel_trace.rs index b7bd53222..cf4bd4408 100644 --- a/sgl-model-gateway/src/observability/otel_trace.rs +++ b/sgl-model-gateway/src/observability/otel_trace.rs @@ -38,8 +38,8 @@ static ALLOWED_TARGETS: OnceLock<[&'static str; 3]> = OnceLock::new(); fn get_allowed_targets() -> &'static [&'static str; 3] { ALLOWED_TARGETS.get_or_init(|| { [ - "sgl_model_gateway::otel-trace", - "sgl_model_gateway::observability::otel_trace", + "smg::otel-trace", + "smg::observability::otel_trace", events_module_path(), ] }) @@ -118,7 +118,7 @@ pub fn otel_tracing_init(enable: bool, otlp_endpoint: Option<&str>) -> Result<() let resource = Resource::default().merge(&Resource::new(vec![KeyValue::new( "service.name", - "sgl-router", + "smg", )])); let provider = TracerProvider::builder() @@ -130,7 +130,7 @@ pub fn otel_tracing_init(enable: bool, otlp_endpoint: Option<&str>) -> Result<() .set(provider.clone()) .map_err(|_| anyhow::anyhow!("Provider already initialized"))?; - let tracer = provider.tracer("sgl-router"); + let tracer = provider.tracer("smg"); TRACER .set(tracer) diff --git a/sgl-model-gateway/src/routers/grpc/common/stages/request_execution.rs b/sgl-model-gateway/src/routers/grpc/common/stages/request_execution.rs index 0fab748c0..083acf46e 100644 --- a/sgl-model-gateway/src/routers/grpc/common/stages/request_execution.rs +++ b/sgl-model-gateway/src/routers/grpc/common/stages/request_execution.rs @@ -90,7 +90,7 @@ impl PipelineStage for RequestExecutionStage { // Create OTEL span for gRPC request execution let span = info_span!( - target: "sgl_model_gateway::otel-trace", + target: "smg::otel-trace", "grpc_generate", request_id = %request_id, model = %model, diff --git a/sgl-model-gateway/src/server.rs b/sgl-model-gateway/src/server.rs index 95595e723..f3bfe6032 100644 --- a/sgl-model-gateway/src/server.rs +++ b/sgl-model-gateway/src/server.rs @@ -688,7 +688,7 @@ pub async fn startup(config: ServerConfig) -> Result<(), Box rt, Err(e) => { error!( - target: "sgl_model_gateway::wasm::runtime", + target: "smg::wasm::runtime", worker_id = worker_id, "Failed to create tokio runtime: {}", e @@ -242,7 +242,7 @@ impl WasmThreadPool { config: WasmRuntimeConfig, ) { debug!( - target: "sgl_model_gateway::wasm::runtime", + target: "smg::wasm::runtime", worker_id = worker_id, thread_id = ?std::thread::current().id(), "Worker started" @@ -270,7 +270,7 @@ impl WasmThreadPool { Ok(engine) => engine, Err(e) => { error!( - target: "sgl_model_gateway::wasm::runtime", + target: "smg::wasm::runtime", worker_id = worker_id, "Failed to create engine: {}", e @@ -297,7 +297,7 @@ impl WasmThreadPool { }); debug!( - target: "sgl_model_gateway::wasm::runtime", + target: "smg::wasm::runtime", worker_id = worker_id, epoch_interval_ms = EPOCH_INTERVAL_MS, "Epoch incrementer started for timeout enforcement" @@ -308,7 +308,7 @@ impl WasmThreadPool { Ok(task) => task, Err(_) => { debug!( - target: "sgl_model_gateway::wasm::runtime", + target: "smg::wasm::runtime", worker_id = worker_id, "Worker shutting down" );