···

       
224
       
224
       
 
       
            sketch_secret

     

       
225
       
225
       
 
       
        };

     

       
226
       
226
       
 
       


     

       
227
       
227
       
+
       
        for (partition, name) in [

     

       
228
       
228
       
+
       
            (&global, "global"),

     

       
229
       
229
       
+
       
            (&feeds, "feeds"),

     

       
230
       
230
       
+
       
            (&records, "records"),

     

       
231
       
231
       
+
       
            (&rollups, "rollups"),

     

       
232
       
232
       
+
       
            (&queues, "queues"),

     

       
233
       
233
       
+
       
        ] {

     

       
234
       
234
       
+
       
            let size0 = partition.disk_space();

     

       
235
       
235
       
+
       
            log::info!("beggining major compaction for {name} (original size: {size0})");

     

       
236
       
236
       
+
       
            let t0 = Instant::now();

     

       
237
       
237
       
+
       
            partition.major_compact().expect("compact better work 😬");

     

       
238
       
238
       
+
       
            let dt = t0.elapsed();

     

       
239
       
239
       
+
       
            let sizef = partition.disk_space();

     

       
240
       
240
       
+
       
            let dsize = (sizef as i64) - (size0 as i64);

     

       
241
       
241
       
+
       
            log::info!("completed compaction for {name} in {dt:?} (new size: {sizef}, {dsize})");

     

       
242
       
242
       
+
       
        }

     

       
243
       
243
       
+
       


     

       
227
       
244
       
 
       
        let reader = FjallReader {

     

       
228
       
245
       
 
       
            keyspace: keyspace.clone(),

     

       
229
       
246
       
 
       
            global: global.clone(),