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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

/// Normalize environment name by stripping otlp2pipeline prefix if present
pub fn normalize(name: &str) -> &str {
    name.strip_prefix("otlp2pipeline-")
        .or_else(|| name.strip_prefix("otlp2pipeline_"))
        .unwrap_or(name)
}

/// Normalize environment name to use hyphens (for bucket/worker names)
fn normalize_with_hyphens(env: &str) -> String {
    normalize(env).replace('_', "-")
}

/// Normalize environment name to use underscores (for stream/sink/pipeline names)
fn normalize_with_underscores(env: &str) -> String {
    normalize(env).replace('-', "_")
}

pub fn bucket_name(env: &str) -> String {
    format!("otlp2pipeline-{}", normalize_with_hyphens(env))
}

pub fn stream_name(env: &str, signal: &str) -> String {
    format!(
        "otlp2pipeline_{}_{}",
        normalize_with_underscores(env),
        signal
    )
}

pub fn sink_name(env: &str, signal: &str) -> String {
    format!(
        "otlp2pipeline_{}_{}_sink",
        normalize_with_underscores(env),
        signal
    )
}

pub fn pipeline_name(env: &str, signal: &str) -> String {
    format!(
        "otlp2pipeline_{}_{}",
        normalize_with_underscores(env),
        signal
    )
}

pub fn worker_name(env: &str) -> String {
    format!("otlp2pipeline-{}", normalize_with_hyphens(env))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_normalize_strips_dash_prefix() {
        assert_eq!(normalize("otlp2pipeline-test05"), "test05");
    }

    #[test]
    fn test_normalize_strips_underscore_prefix() {
        assert_eq!(normalize("otlp2pipeline_test05"), "test05");
    }

    #[test]
    fn test_normalize_no_prefix() {
        assert_eq!(normalize("test05"), "test05");
    }

    #[test]
    fn test_bucket_name_with_prefix() {
        assert_eq!(bucket_name("otlp2pipeline-test05"), "otlp2pipeline-test05");
    }

    #[test]
    fn test_bucket_name_without_prefix() {
        assert_eq!(bucket_name("test05"), "otlp2pipeline-test05");
    }

    #[test]
    fn test_stream_name_with_prefix() {
        assert_eq!(
            stream_name("otlp2pipeline-test05", "logs"),
            "otlp2pipeline_test05_logs"
        );
    }

    #[test]
    fn test_worker_name_with_prefix() {
        assert_eq!(worker_name("otlp2pipeline-test05"), "otlp2pipeline-test05");
    }

    #[test]
    fn test_worker_name_without_prefix() {
        assert_eq!(worker_name("test05"), "otlp2pipeline-test05");
    }
}