sqlpage 0.44.0

Build data user interfaces entirely in SQL. A web server that takes .sql files and formats the query result using pre-made configurable professional-looking components.
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
97

use opentelemetry::global;
use opentelemetry::metrics::{Histogram, ObservableGauge};
use opentelemetry_semantic_conventions::attribute as otel;
use opentelemetry_semantic_conventions::metric as otel_metric;
use sqlx::AnyPool;

pub struct TelemetryMetrics {
    pub http_request_duration: Histogram<f64>,
    pub db_query_duration: Histogram<f64>,
    _pool_connection_count: ObservableGauge<i64>,
}

impl Default for TelemetryMetrics {
    fn default() -> Self {
        let meter = global::meter("sqlpage");
        let http_request_duration = meter
            .f64_histogram(otel_metric::HTTP_SERVER_REQUEST_DURATION)
            .with_unit("s")
            .with_description("Duration of HTTP requests processed by the server.")
            .build();
        let db_query_duration = meter
            .f64_histogram(otel_metric::DB_CLIENT_OPERATION_DURATION)
            .with_unit("s")
            .with_description("Duration of executing SQL queries.")
            .build();
        // This default is only used in tests that don't touch pool metrics.
        let pool_connection_count = meter
            .i64_observable_gauge(otel_metric::DB_CLIENT_CONNECTION_COUNT)
            .with_unit("{connection}")
            .with_description("Number of connections in the database pool.")
            .with_callback(|_| {})
            .build();

        Self {
            http_request_duration,
            db_query_duration,
            _pool_connection_count: pool_connection_count,
        }
    }
}

impl TelemetryMetrics {
    #[must_use]
    pub fn new(pool: &AnyPool, db_system_name: &'static str) -> Self {
        let meter = global::meter("sqlpage");
        let http_request_duration = meter
            .f64_histogram(otel_metric::HTTP_SERVER_REQUEST_DURATION)
            .with_unit("s")
            .with_description("Duration of HTTP requests processed by the server.")
            .build();
        let db_query_duration = meter
            .f64_histogram(otel_metric::DB_CLIENT_OPERATION_DURATION)
            .with_unit("s")
            .with_description("Duration of executing SQL queries.")
            .build();
        let pool_ref = pool.clone();
        let pool_connection_count = meter
            .i64_observable_gauge(otel_metric::DB_CLIENT_CONNECTION_COUNT)
            .with_unit("{connection}")
            .with_description("Number of connections in the database pool.")
            .with_callback(move |observer| {
                let size = pool_ref.size();
                let idle_u32 = u32::try_from(pool_ref.num_idle()).unwrap_or(u32::MAX);
                let used = i64::from(size.saturating_sub(idle_u32));
                let idle = i64::from(idle_u32);
                observer.observe(
                    used,
                    &[
                        opentelemetry::KeyValue::new(otel::DB_SYSTEM_NAME, db_system_name),
                        opentelemetry::KeyValue::new(
                            otel::DB_CLIENT_CONNECTION_POOL_NAME,
                            "sqlpage",
                        ),
                        opentelemetry::KeyValue::new(otel::DB_CLIENT_CONNECTION_STATE, "used"),
                    ],
                );
                observer.observe(
                    idle,
                    &[
                        opentelemetry::KeyValue::new(otel::DB_SYSTEM_NAME, db_system_name),
                        opentelemetry::KeyValue::new(
                            otel::DB_CLIENT_CONNECTION_POOL_NAME,
                            "sqlpage",
                        ),
                        opentelemetry::KeyValue::new(otel::DB_CLIENT_CONNECTION_STATE, "idle"),
                    ],
                );
            })
            .build();

        Self {
            http_request_duration,
            db_query_duration,
            _pool_connection_count: pool_connection_count,
        }
    }
}