+293
-66
Cargo.lock
+293
-66
Cargo.lock
················································source = "git+https://github.com/fjall-rs/fjall.git#42d811f7c8cc9004407d520d37d2a1d8d246c03d"·············································································································································
+6
-13
constellation/src/consumer/jetstream.rs
+6
-13
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
+3
-2
links/src/lib.rs
+3
-2
links/src/lib.rs
·········
+41
links/src/record.rs
+41
links/src/record.rs
······
+2
-4
slingshot/src/firehose_cache.rs
+2
-4
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
+5
-26
slingshot/src/main.rs
+5
-26
slingshot/src/main.rs
·········let mut tasks: tokio::task::JoinSet<Result<(), MainTaskError>> = tokio::task::JoinSet::new();······
+12
-19
slingshot/src/server.rs
+12
-19
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