reddb-io-server 1.12.0

RedDB server-side engine: storage, runtime, replication, MCP, AI, and the gRPC/HTTP/RedWire/PG-wire dispatchers. Re-exported by the umbrella `reddb` crate.
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
97
98
99
100
101
102
103
104
105
106
107

use crate::server::route_catalog::{
    RouteAlias, RouteAudience, RouteAuth, RouteEntry, RouteGroupDefaults, RouteMethod,
    RouteMiddleware, RouteRegistry, RouteStability,
};
use crate::server::routes::common::{METRICS_SURFACES, STANDARD_MIDDLEWARE};

const OPS_READ_CLUSTER_MIDDLEWARE: &[RouteMiddleware] = &[
    RouteMiddleware::CorsPreflight,
    RouteMiddleware::ListenerSurfaceGate,
    RouteMiddleware::AuthGate,
    RouteMiddleware::QuotaGate,
    RouteMiddleware::OpsPolicy("ops:read:cluster"),
];

const METRICS_OPERATOR: RouteGroupDefaults = RouteGroupDefaults {
    family: "metrics",
    audience: RouteAudience::Operator,
    auth: RouteAuth::OpsCapability("ops:read:cluster"),
    surfaces: METRICS_SURFACES,
    stability: RouteStability::Stable,
    middlewares: OPS_READ_CLUSTER_MIDDLEWARE,
};

const PROM_COMPAT: RouteGroupDefaults = RouteGroupDefaults {
    family: "prometheus",
    audience: RouteAudience::CompatibilityAdapter,
    auth: RouteAuth::UserRequired,
    surfaces: METRICS_SURFACES,
    stability: RouteStability::Compatibility,
    middlewares: STANDARD_MIDDLEWARE,
};

const METRICS_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Get,
    "/v1/ops/metrics",
    "canonical v1 operator metrics path",
)];
const PROM_QUERY_GET_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Get,
    "/prometheus/api/v1/query",
    "explicit Prometheus adapter namespace",
)];
const PROM_QUERY_POST_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Post,
    "/prometheus/api/v1/query",
    "explicit Prometheus adapter namespace",
)];
const PROM_QUERY_RANGE_GET_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Get,
    "/prometheus/api/v1/query_range",
    "explicit Prometheus adapter namespace",
)];
const PROM_QUERY_RANGE_POST_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Post,
    "/prometheus/api/v1/query_range",
    "explicit Prometheus adapter namespace",
)];
const PROM_REMOTE_WRITE_ALIASES: &[RouteAlias] = &[RouteAlias::canonical(
    RouteMethod::Post,
    "/prometheus/api/v1/write",
    "explicit Prometheus adapter namespace",
)];

const METRICS_ROUTES: &[RouteEntry] = &[RouteEntry::with_aliases(
    "metrics.scrape",
    RouteMethod::Get,
    "/metrics",
    METRICS_ALIASES,
)];

const PROMETHEUS_ROUTES: &[RouteEntry] = &[
    RouteEntry::with_aliases(
        "prometheus.query.get",
        RouteMethod::Get,
        "/api/v1/query",
        PROM_QUERY_GET_ALIASES,
    ),
    RouteEntry::with_aliases(
        "prometheus.query.post",
        RouteMethod::Post,
        "/api/v1/query",
        PROM_QUERY_POST_ALIASES,
    ),
    RouteEntry::with_aliases(
        "prometheus.query_range.get",
        RouteMethod::Get,
        "/api/v1/query_range",
        PROM_QUERY_RANGE_GET_ALIASES,
    ),
    RouteEntry::with_aliases(
        "prometheus.query_range.post",
        RouteMethod::Post,
        "/api/v1/query_range",
        PROM_QUERY_RANGE_POST_ALIASES,
    ),
    RouteEntry::with_aliases(
        "prometheus.remote_write",
        RouteMethod::Post,
        "/api/v1/write",
        PROM_REMOTE_WRITE_ALIASES,
    ),
];

pub(crate) fn register(registry: &mut RouteRegistry) {
    registry.routes(METRICS_OPERATOR, METRICS_ROUTES);
    registry.routes(PROM_COMPAT, PROMETHEUS_ROUTES);
}