forked from
microcosm.blue/Allegedly
Server tools to backfill, tail, mirror, and verify PLC logs
add fjall to --no-bulk
+9
-1
+9
-1
src/bin/backfill.rs
+9
-1
src/bin/backfill.rs
···
118
118
let throttle = Duration::from_millis(upstream_throttle_ms);
119
119
tasks.spawn(poll_upstream(None, upstream, throttle, poll_tx));
120
120
tasks.spawn(full_pages(poll_out, full_tx));
121
-
tasks.spawn(pages_to_stdout(full_out, None));
121
+
if let Some(fjall_path) = to_fjall {
122
+
log::trace!("opening fjall db at {fjall_path:?}...");
123
+
let db = FjallDb::open(&fjall_path)?;
124
+
log::trace!("opened fjall db");
125
+
126
+
tasks.spawn(pages_to_fjall(db, full_out));
127
+
} else {
128
+
tasks.spawn(pages_to_stdout(full_out, None));
129
+
}
122
130
} else {
123
131
// fun mode
124
132