mirror of
https://github.com/hanzoai/dev.git
synced 2026-10-25 03:32:32 +00:00
zeekayandHanzo Dev
54a8eed885
Wholesale-adopt latest upstream codex-rs (97 crates, new architecture: model-provider-info crate, app-server-daemon/transport, code-mode-host, thread-store, file-watcher, etc.). Hanzo-only crates (browser, debug-client, instructions, tui2) preserved on disk (not yet re-added to workspace). Builds clean as upstream (codex bin). Hanzo overlay (dev bin, api.hanzo.ai default, hanzo.id/Claude login, branding) re-applied in following commits. Co-authored-by: Hanzo Dev <[email protected]>
41 lines
1.1 KiB
Rust
41 lines
1.1 KiB
Rust
use std::sync::Arc;
|
|
use std::time::Duration;
|
|
|
|
use codex_otel::ORIGINATOR_TAG;
|
|
use codex_otel::bounded_originator_tag_value;
|
|
use codex_state::DbTelemetry;
|
|
use codex_state::DbTelemetryHandle;
|
|
|
|
struct OtelDbTelemetry {
|
|
metrics: codex_otel::MetricsClient,
|
|
originator: &'static str,
|
|
}
|
|
|
|
impl DbTelemetry for OtelDbTelemetry {
|
|
fn counter(&self, name: &str, inc: i64, tags: &[(&str, &str)]) {
|
|
let tags = with_originator(tags, self.originator);
|
|
let _ = self.metrics.counter(name, inc, &tags);
|
|
}
|
|
|
|
fn record_duration(&self, name: &str, duration: Duration, tags: &[(&str, &str)]) {
|
|
let tags = with_originator(tags, self.originator);
|
|
let _ = self.metrics.record_duration(name, duration, &tags);
|
|
}
|
|
}
|
|
|
|
pub(crate) fn recorder(metrics: codex_otel::MetricsClient, originator: &str) -> DbTelemetryHandle {
|
|
Arc::new(OtelDbTelemetry {
|
|
metrics,
|
|
originator: bounded_originator_tag_value(originator),
|
|
})
|
|
}
|
|
|
|
fn with_originator<'a>(
|
|
tags: &[(&'a str, &'a str)],
|
|
originator: &'static str,
|
|
) -> Vec<(&'a str, &'a str)> {
|
|
let mut tags = tags.to_vec();
|
|
tags.push((ORIGINATOR_TAG, originator));
|
|
tags
|
|
}
|