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

//! Integration tests for Azure Function binary.
//!
//! These tests verify the HTTP handling without actually connecting to Event Hub.

#[cfg(feature = "azure-function")]
mod azure_tests {
    // Tests would go here but require mocking Event Hub
    // For now, verify the module structure compiles

    #[test]
    fn test_event_envelope_serialization() {
        use serde_json::json;

        #[derive(serde::Serialize)]
        struct EventEnvelope {
            signal_type: String,
            table: String,
            payload: serde_json::Value,
        }

        let envelope = EventEnvelope {
            signal_type: "logs".to_string(),
            table: "logs".to_string(),
            payload: json!({"message": "test"}),
        };

        let json = serde_json::to_string(&envelope).unwrap();
        assert!(json.contains("signal_type"));
        assert!(json.contains("logs"));
    }
}