lenso-platform-core 0.1.22

Core runtime primitives for the Lenso backend framework.
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

use platform_core::{
    LogFormat, RuntimeSpanAttributes, TelemetryConfig, record_runtime_span_attributes, telemetry,
};
use std::time::{SystemTime, UNIX_EPOCH};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let endpoint = std::env::var("OTEL_EXPORTER_OTLP_ENDPOINT")
        .unwrap_or_else(|_| "http://localhost:4317".to_owned());
    let correlation_id = example_correlation_id();

    telemetry::init(&TelemetryConfig {
        log_level: "info".to_owned(),
        log_format: LogFormat::Compact,
        otlp_endpoint: Some(endpoint),
    })?;

    emit_outbox_span(&correlation_id);
    emit_function_span(&correlation_id);
    telemetry::force_flush()?;

    println!("OTEL_EXAMPLE_CORRELATION_ID={correlation_id}");
    Ok(())
}

fn emit_outbox_span(correlation_id: &str) {
    let span = tracing::info_span!(
        "outbox_publish",
        lenso.correlation_id = tracing::field::Empty,
        lenso.story_id = tracing::field::Empty,
        lenso.outbox_event_id = tracing::field::Empty,
        lenso.execution.kind = tracing::field::Empty,
        lenso.execution.name = tracing::field::Empty,
    );
    record_runtime_span_attributes(
        &span,
        &RuntimeSpanAttributes::outbox(
            correlation_id.to_owned(),
            format!("{correlation_id}:outbox"),
            "otel_example.runtime_event",
        ),
    );
}

fn emit_function_span(correlation_id: &str) {
    let span = tracing::info_span!(
        "function_run",
        lenso.correlation_id = tracing::field::Empty,
        lenso.story_id = tracing::field::Empty,
        lenso.function_run_id = tracing::field::Empty,
        lenso.execution.kind = tracing::field::Empty,
        lenso.execution.name = tracing::field::Empty,
    );
    record_runtime_span_attributes(
        &span,
        &RuntimeSpanAttributes::function(
            correlation_id.to_owned(),
            format!("{correlation_id}:function"),
            "otel_example.runtime_function",
        ),
    );
}

fn example_correlation_id() -> String {
    let timestamp = SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .map(|duration| duration.as_nanos())
        .unwrap_or_default();
    format!("otel_example_{timestamp}")
}