mirror of
https://github.com/openai/codex.git
synced 2026-11-08 20:40:33 +00:00
feat(app-server, core): add more spans
This commit is contained in:
@@ -1,12 +1,12 @@
|
||||
use http::Error as HttpError;
|
||||
use http::HeaderMap;
|
||||
use http::HeaderName;
|
||||
use http::HeaderValue;
|
||||
use opentelemetry::global;
|
||||
use opentelemetry::propagation::Injector;
|
||||
use reqwest::IntoUrl;
|
||||
use reqwest::Method;
|
||||
use reqwest::Response;
|
||||
use reqwest::header::HeaderMap;
|
||||
use reqwest::header::HeaderName;
|
||||
use reqwest::header::HeaderValue;
|
||||
use serde::Serialize;
|
||||
use std::fmt::Display;
|
||||
use std::time::Duration;
|
||||
@@ -154,14 +154,15 @@ impl<'a> Injector for HeaderMapInjector<'a> {
|
||||
}
|
||||
}
|
||||
|
||||
pub fn inject_current_span_trace_headers(headers: &mut HeaderMap) {
|
||||
global::get_text_map_propagator(|prop| {
|
||||
prop.inject_context(&Span::current().context(), &mut HeaderMapInjector(headers));
|
||||
});
|
||||
}
|
||||
|
||||
fn trace_headers() -> HeaderMap {
|
||||
let mut headers = HeaderMap::new();
|
||||
global::get_text_map_propagator(|prop| {
|
||||
prop.inject_context(
|
||||
&Span::current().context(),
|
||||
&mut HeaderMapInjector(&mut headers),
|
||||
);
|
||||
});
|
||||
inject_current_span_trace_headers(&mut headers);
|
||||
headers
|
||||
}
|
||||
|
||||
|
||||
@@ -8,6 +8,7 @@ mod transport;
|
||||
|
||||
pub use crate::default_client::CodexHttpClient;
|
||||
pub use crate::default_client::CodexRequestBuilder;
|
||||
pub use crate::default_client::inject_current_span_trace_headers;
|
||||
pub use crate::error::StreamError;
|
||||
pub use crate::error::TransportError;
|
||||
pub use crate::request::Request;
|
||||
|
||||
Reference in New Issue
Block a user