+66
-293
Cargo.lock
+66
-293
Cargo.lock
················································source = "git+https://github.com/fjall-rs/fjall.git#42d811f7c8cc9004407d520d37d2a1d8d246c03d"·············································································································································
+13
-6
constellation/src/consumer/jetstream.rs
+13
-6
constellation/src/consumer/jetstream.rs
···+counter!("jetstream_read_fail", "url" => stream.clone(), "reason" => "dirty close").increment(1);
-2
links/Cargo.toml
-2
links/Cargo.toml
+2
-3
links/src/lib.rs
+2
-3
links/src/lib.rs
·········
-41
links/src/record.rs
-41
links/src/record.rs
······
+4
-2
slingshot/src/firehose_cache.rs
+4
-2
slingshot/src/firehose_cache.rs
···.with_file_size(16 * 2_usize.pow(20)), // note: this does limit the max cached item size, warning jumbo records
+26
-5
slingshot/src/main.rs
+26
-5
slingshot/src/main.rs
·········let mut tasks: tokio::task::JoinSet<Result<(), MainTaskError>> = tokio::task::JoinSet::new();······
+19
-12
slingshot/src/server.rs
+19
-12
slingshot/src/server.rs
························
-8
spacedust/Cargo.toml
-8
spacedust/Cargo.toml
···
-21
spacedust/src/bin/import_car_file.rs
-21
spacedust/src/bin/import_car_file.rs
···
-258
spacedust/src/bin/import_scraped.rs
-258
spacedust/src/bin/import_scraped.rs
···
-137
spacedust/src/bin/scrape_pds.rs
-137
spacedust/src/bin/scrape_pds.rs
···
-1
spacedust/src/lib.rs
-1
spacedust/src/lib.rs
spacedust/src/storage/car/drive.rs
spacedust/src/storage/car/drive.rs
This is a binary file and will not be displayed.
-1
spacedust/src/storage/car/mod.rs
-1
spacedust/src/storage/car/mod.rs
···
spacedust/src/storage/car/walk.rs
spacedust/src/storage/car/walk.rs
This is a binary file and will not be displayed.
-9
spacedust/src/storage/fjall/mod.rs
-9
spacedust/src/storage/fjall/mod.rs