otlp2pipeline 0.2.0

OTLP ingestion worker for Cloudflare Pipelines and AWS
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

// src/aggregator/mod.rs
//! Signal aggregator using Durable Objects for baseline RED metrics.

mod stats;

#[cfg(target_arch = "wasm32")]
mod durable_object;

#[cfg(target_arch = "wasm32")]
mod sender;

#[cfg(not(target_arch = "wasm32"))]
mod sender;

pub use stats::{LogAggregates, TraceAggregates};

#[cfg(target_arch = "wasm32")]
pub use durable_object::AggregatorDO;

#[cfg(target_arch = "wasm32")]
pub use sender::{build_do_name, get_service_name, AggregatorSender, WasmAggregatorSender};

#[cfg(not(target_arch = "wasm32"))]
pub use sender::{AggregatorSender, NativeAggregatorSender};

// Native placeholder for tests
#[cfg(not(target_arch = "wasm32"))]
pub struct AggregatorDO;