Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
todos + remove lingering did_init prop
+5
-8
+4
-4
constellation/readme.md
+4
-4
constellation/readme.md
···
115
115
- [x] cpu usage
116
116
- [x] mem usage
117
117
- [x] network?
118
-
- [ ] make all rocks apis return Result instead of unwrapping
119
-
- [ ] handle all the unwraps
118
+
- [x] make all rocks apis return Result instead of unwrapping
119
+
- [~] handle all the unwraps
120
120
- [ ] deadletter queue of some kind for failed db writes
121
121
- [ ] also for valid json that was rejected?
122
122
- [x] get it running on raspi
123
123
- [x] get an estimate of disk usage per day after a few days of running
124
124
- very close to 1GB with data model before adding rkeys to linkers + fixing paths
125
-
- [ ] make the did_init check only happen on test config (or remove it)
125
+
- [x] make the did_init check only happen on test config (or remove it) (removed)
126
126
- [ ] actual error types (thiserror?) for lib-ish code
127
-
- [ ] clean up the main readme
127
+
- [~] clean up the main readme
128
128
- [x] web server metrics
129
129
- [x] origin and ua labels
130
130
- [ ] tokio metrics?
+1
-4
constellation/src/storage/rocks_store.rs
+1
-4
constellation/src/storage/rocks_store.rs
···
59
59
{
60
60
_key_marker: PhantomData<Orig>,
61
61
_val_marker: PhantomData<IdVal>,
62
-
did_init: bool,
63
62
name: String,
64
63
id_seq: Arc<AtomicU64>,
65
64
}
···
72
71
ColumnFamilyDescriptor::new(&self.name, rocks_opts_base())
73
72
}
74
73
fn init<const WITH_REVERSE: bool>(
75
-
mut self,
74
+
self,
76
75
db: &DBWithThreadMode<MultiThreaded>,
77
76
) -> Result<IdTable<Orig, IdVal, WITH_REVERSE>> {
78
77
if db.cf_handle(&self.name).is_none() {
···
93
92
1
94
93
};
95
94
self.id_seq.store(priv_id_seq, Ordering::SeqCst);
96
-
self.did_init = true;
97
95
Ok(IdTable {
98
96
base: self,
99
97
priv_id_seq,
···
125
123
IdTableBase::<Orig, IdVal> {
126
124
_key_marker: PhantomData,
127
125
_val_marker: PhantomData,
128
-
did_init: false,
129
126
name: name.into(),
130
127
id_seq: Arc::new(AtomicU64::new(0)), // zero is "uninint", first seq num will be 1
131
128
}