fdc9cf6ab0
OpenPay (1 crate, ~2940 LOC, 40 tests)
op-statements Statement generation + reconciliation + fee accounting.
Render targets: PDF (template), CSV, JSON, 94-char
NACHA fixed-width. ISO 20022 camt.053 with full
BkToCstmrStmt envelope (GrpHdr/Stmt/Bal/Ntry). BAI2
with 01/02/03/16/49/98/99 records. MT940/MT942
SWIFT with :20:/:25:/:28C:/:60F:/:61:/:86:/:62F:
+ :90C:/:90D: counters. FeeBucket (interchange/scheme/
acquirer/fx/settlement-network/bnpl) + FeeSchedule
with bps + flat rules. Cadence (daily/weekly/monthly/
custom). Two-tier Reconciler (external_id → window
heuristic).
Smart Byte (1 crate, 3032 LOC, 39 tests)
smart-byte-activitypub ActivityPub W3C Rec (2018). AS2 vocab + Public
addressing; Actor (Person/Application/Group/
Organization/Service) with publicKey + shared-inbox;
Object (Note/Article/Image/Video/Tombstone) with
Mastodon extensions (sensitive, CW summary,
conversation, blurhash); 12 Activity types
(Create/Update/Delete/Follow/Accept/Reject/Announce/
Like/Undo/Move/Block/Flag) with side-effect rules;
OrderedCollection + Page; Webfinger (RFC 7033);
HTTP Signatures (cavage draft-12 + RFC 9421);
SHA-256 Digest; Ed25519 sign/verify.
EOC (1 crate, 2759 LOC, 20 tests)
eoc-observability OpenTelemetry-compatible tracing + metrics + logs.
W3C tracecontext + baggage. Span / SpanKind / Status.
Samplers: AlwaysOn/Off/RatioBased/ParentBased. Sync
BatchSpanProcessor + Exporter trait. Counter / Gauge /
Histogram. Prometheus text exposition (HELP/TYPE/
_bucket/_sum/_count/+Inf). StatsD / DogStatsD lines.
GenAI semconv (gen_ai.{operation,system,request.*,
response.*,usage.*}) + EOC extensions (eoc.joules.*,
eoc.co2e_grams, eoc.cost.usd). USD + gCO2e attribution
with PUE. LangSmith + LangFuse export adapters.
Co-Authored-By: Claude Opus 4.7 <[email protected]>
73 lines
2.8 KiB
Rust
73 lines
2.8 KiB
Rust
//! `eoc-observability` — OpenTelemetry-compatible tracing, metrics, and logs
|
|
//! for energy-optimized AI compute.
|
|
//!
|
|
//! This crate is the observability seam for the EOC cascade. It is
|
|
//! deliberately *not* a vendored copy of `opentelemetry-rust`; it is a
|
|
//! minimal, self-contained, runtime-agnostic implementation of the same
|
|
//! data model, so EOC can deploy on `wasm32-unknown-unknown` and embedded
|
|
//! targets where the upstream SDK is too heavy.
|
|
//!
|
|
//! # What's included
|
|
//!
|
|
//! - Spans + [`SpanContext`] + [`SpanKind`] + [`Status`] ([`span`]).
|
|
//! - W3C `traceparent` + `tracestate` + `baggage` ([`context`]).
|
|
//! - Samplers: [`sampler::AlwaysOnSampler`], [`sampler::AlwaysOffSampler`],
|
|
//! [`sampler::TraceIdRatioBased`], [`sampler::ParentBased`].
|
|
//! - [`processor::BatchSpanProcessor`].
|
|
//! - [`exporter::SpanExporter`] trait + [`exporter::InMemoryExporter`].
|
|
//! - Metrics: [`metric::Counter`], [`metric::Gauge`], [`metric::Histogram`].
|
|
//! - Prometheus text exposition ([`prometheus`]).
|
|
//! - StatsD / DogStatsD line format ([`statsd`]).
|
|
//! - GenAI semantic conventions ([`genai_conventions`]).
|
|
//! - Cost attribution: USD + gCO2e ([`cost`]).
|
|
//! - LangSmith ([`langsmith`]) and LangFuse ([`langfuse`]) exporters.
|
|
//! - Log records with trace correlation ([`log`]).
|
|
//!
|
|
//! # Integration with `eoc-meter` and `eoc-carbon`
|
|
//!
|
|
//! `Span::set_joule_cost` accepts an [`eoc_core::JouleCost`] coming from
|
|
//! `eoc-meter`. The [`cost::attribute`] helper turns that joule reading
|
|
//! into USD + gCO2e for a given grid intensity and PUE. Stage-level joule
|
|
//! counters are typically driven directly from `eoc-meter`; this crate just
|
|
//! shapes them into OTel attributes.
|
|
|
|
#![forbid(unsafe_code)]
|
|
#![warn(missing_docs)]
|
|
|
|
pub mod context;
|
|
pub mod cost;
|
|
pub mod error;
|
|
pub mod exporter;
|
|
pub mod genai_conventions;
|
|
pub mod langfuse;
|
|
pub mod langsmith;
|
|
pub mod log;
|
|
pub mod metric;
|
|
pub mod processor;
|
|
pub mod prometheus;
|
|
pub mod sampler;
|
|
pub mod span;
|
|
pub mod statsd;
|
|
|
|
pub use context::{Baggage, SpanContext, SpanId, TraceFlags, TraceId};
|
|
pub use cost::{
|
|
CarbonIntensityGCo2ePerKwh, CostAttribution, EnergyPriceUsdPerKwh, Pue, attribute,
|
|
joules_to_kwh,
|
|
};
|
|
pub use error::{ObsError, ObsResult};
|
|
pub use exporter::{InMemoryExporter, SpanExporter};
|
|
pub use genai_conventions::GenAiAttributes;
|
|
pub use langfuse::{LangFuseExporter, span_to_observation};
|
|
pub use langsmith::{LangSmithExporter, span_to_run};
|
|
pub use log::{LogRecord, Severity};
|
|
pub use metric::{
|
|
Counter, DEFAULT_DURATION_BUCKETS_MS, Gauge, Histogram, HistogramSnapshot,
|
|
};
|
|
pub use processor::{BatchConfig, BatchSpanProcessor};
|
|
pub use prometheus::PrometheusExposer;
|
|
pub use sampler::{
|
|
AlwaysOffSampler, AlwaysOnSampler, ParentBased, Sampler, SamplingDecision,
|
|
TraceIdRatioBased,
|
|
};
|
|
pub use span::{AttrValue, Span, SpanEvent, SpanKind, SpanLink, Status, StatusCode};
|
|
pub use statsd::StatsdLine;
|