otlp2pipeline 0.4.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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

// src/lib.rs

// Re-export for native module and lambda binary
#[cfg(not(target_arch = "wasm32"))]
pub use bytes::Bytes;

// Re-export InputFormat for external use
pub use otlp2records::decode::InputFormat;

pub mod aggregator;
mod handler;
pub mod livetail;
mod pipeline;
pub mod registry;
mod schema;
mod signal;

pub use signal::Signal;

// Re-export tracing for use in other modules
pub use tracing;

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

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

#[cfg(feature = "lambda")]
pub mod lambda;

#[cfg(feature = "azure-function")]
pub mod azure;

// Re-export for tests
pub use handler::{
    handle_signal, HandleError, HandleResponse, LogsHandler, MetricsHandler, SignalHandler,
    SkippedMetricsWarning, TracesHandler,
};
pub use pipeline::{PipelineSender, SendResult};

fn parse_content_metadata(mut header: impl FnMut(&str) -> Option<String>) -> (bool, InputFormat) {
    let is_gzipped = header("content-encoding")
        .map(|v| v.eq_ignore_ascii_case("gzip"))
        .unwrap_or(false);
    let decode_format = InputFormat::from_content_type(header("content-type").as_deref());
    (is_gzipped, decode_format)
}

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

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

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

#[cfg(not(target_arch = "wasm32"))]
pub use native::build_router;