···

       
150
       
 
       
    let mut total_count = 0_u64;

     

       
151
       
 
       
    for nsid in from.get_nsids() {

     

       
152
       
 
       
        tracing::info!("migrating {} ...", nsid.deref());

     

       
153
       
-
       
        for hit in from.get_hits(&nsid, ..).expect("cant read hits") {

     

       
154
       
 
       
            let (timestamp, data) = hit.expect("cant read event");

     

       
155
       
 
       
            to.record_event(EventRecord {

     

       
156
       
 
       
                nsid: nsid.to_smolstr(),

     
···

       
162
       
 
       
        }

     

       
163
       
 
       
    }

     

       
164
       
 
       


     

       
0
       
 
       

     

       
165
       
 
       
    tracing::info!("migrated {total_count} events!");

     

       
166
       
 
       
}

     

···

       
150
       
 
       
    let mut total_count = 0_u64;

     

       
151
       
 
       
    for nsid in from.get_nsids() {

     

       
152
       
 
       
        tracing::info!("migrating {} ...", nsid.deref());

     

       
153
       
+
       
        for hit in from.get_hits(&nsid, ..) {

     

       
154
       
 
       
            let (timestamp, data) = hit.expect("cant read event");

     

       
155
       
 
       
            to.record_event(EventRecord {

     

       
156
       
 
       
                nsid: nsid.to_smolstr(),

     
···

       
162
       
 
       
        }

     

       
163
       
 
       
    }

     

       
164
       
 
       


     

       
165
       
+
       
    to.sync(true).expect("cant sync");

     

       
166
       
 
       
    tracing::info!("migrated {total_count} events!");

     

       
167
       
 
       
}