Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
add axum metrics
neat lil crate seems ok and does enough out of the box
+25
-5
+15
Cargo.lock
+15
Cargo.lock
···
161
161
]
162
162
163
163
[[package]]
164
+
name = "axum-metrics"
165
+
version = "0.1.0"
166
+
source = "git+https://github.com/uniphil/axum-metrics.git#0835d58b628104ada1f1c89c9d52bbedf34f921f"
167
+
dependencies = [
168
+
"axum",
169
+
"bytes",
170
+
"http-body",
171
+
"metrics",
172
+
"pin-project-lite",
173
+
"tower-layer",
174
+
"tower-service",
175
+
]
176
+
177
+
[[package]]
164
178
name = "backtrace"
165
179
version = "0.3.74"
166
180
source = "registry+https://github.com/rust-lang/crates.io-index"
···
845
859
dependencies = [
846
860
"anyhow",
847
861
"axum",
862
+
"axum-metrics",
848
863
"bincode",
849
864
"clap",
850
865
"flume",
+1
link_aggregator/Cargo.toml
+1
link_aggregator/Cargo.toml
+2
-1
link_aggregator/readme.md
+2
-1
link_aggregator/readme.md
···
38
38
- [ ] make the did_init check only happen on test config (or remove it)
39
39
- [ ] actual error types (thiserror?) for lib-ish code
40
40
- [ ] clean up the main readme
41
-
- [ ] web server metrics
41
+
- [x] web server metrics
42
42
- [ ] tokio metrics?
43
43
- [ ] handle shutdown cleanly -- be nice to rocksdb
44
44
- [x] add user-agent to jetstream request
45
+
- [ ] possibly add tracing stuff also to complement metrics (at least for web reqs)
+7
-4
link_aggregator/src/server.rs
+7
-4
link_aggregator/src/server.rs
···
11
11
S: LinkReader,
12
12
A: ToSocketAddrs,
13
13
{
14
-
let app = Router::new().route("/", get(hello)).route(
15
-
"/links/count",
16
-
get(move |query| async { block_in_place(|| count_links(query, store)) }),
17
-
);
14
+
let app = Router::new()
15
+
.route("/", get(hello))
16
+
.route(
17
+
"/links/count",
18
+
get(move |query| async { block_in_place(|| count_links(query, store)) }),
19
+
)
20
+
.layer(axum_metrics::MetricLayer::default());
18
21
19
22
let listener = TcpListener::bind(addr).await?;
20
23
println!("api: listening at http://{:?}", listener.local_addr()?);