forked from
microcosm.blue/microcosm-rs
Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
only reset connection retry count after queuing a message
saw a retry loop oops
this isn't actually sufficient -- need to add a timeout. but it's slightly better for the moment.
+6
-2
+2
-1
link_aggregator/readme.md
+2
-1
link_aggregator/readme.md
···
110
110
- [x] handle shutdown cleanly -- be nice to rocksdb
111
111
- [x] add user-agent to jetstream request
112
112
- [ ] wow the shutdown stuff i wrote is really bad and doesn't work a lot
113
-
- [~] serve html for browser requests
113
+
- [x] serve html for browser requests
114
114
- [ ] add a health check endpoint
115
115
- [ ] add seq numbers to metrics
116
116
- [ ] persist the jetstream server url, error if started with a different one (maybe with --switch-streams or something)
117
117
- [ ] put delete-account tasks into a separate (persisted?) task queue for the writer so it can work on them incrementally.
118
+
- [ ] jetstream: connect retry: only reset counter after some *time* has passed.
118
119
119
120
data fixes
120
121
- [x] add rkey to linkers 🤦♀️
+4
-1
link_aggregator/src/consumer/jetstream.rs
+4
-1
link_aggregator/src/consumer/jetstream.rs
···
98
98
let mut socket = match tungstenite::client_tls(req, tcp_stream) {
99
99
Ok((socket, _)) => {
100
100
println!("jetstream connected.");
101
-
connect_retries = 0;
101
+
// connect_retries = 0; // only reset once we have received a message vvv
102
102
socket
103
103
}
104
104
Err(e) => {
···
271
271
latest_cursor = Some(ts);
272
272
gauge!("jetstream_cursor_age", "url" => stream.clone())
273
273
.set(ts_age(ts).as_micros() as f64);
274
+
275
+
// great news if we got this far -- might be safe to assume the connection is up.
276
+
connect_retries = 0;
274
277
}
275
278
}
276
279
Ok(())