@@ -105,7 +105,6 @@ mod test {
105105 // use std::fs::File;
106106 // use std::io::Write;
107107 // use std::mem::size_of;
108- use std:: path:: Path ;
109108 use std:: str:: FromStr ;
110109 // use std::sync::atomic::AtomicBool;
111110 use std:: sync:: Arc ;
@@ -118,7 +117,7 @@ mod test {
118117
119118 use crate :: io:: file:: FileExt ;
120119 use crate :: io:: StdIO ;
121- use crate :: storage:: RestoreOptions ;
120+ use crate :: storage:: { RestoreOptions , SegmentKey } ;
122121 // use crate::registry::WalRegistry;
123122 // use crate::segment::compacted::CompactedSegmentDataHeader;
124123 // use crate::segment::sealed::SealedSegment;
@@ -445,16 +444,6 @@ mod test {
445444 Ok ( ( ) )
446445 }
447446
448- async fn fetch_segment (
449- & self ,
450- _config : & Self :: Config ,
451- _namespace : & NamespaceName ,
452- _frame_no : u64 ,
453- _dest_path : & Path ,
454- ) -> Result < fst:: Map < Vec < u8 > > > {
455- todo ! ( )
456- }
457-
458447 async fn meta (
459448 & self ,
460449 _config : & Self :: Config ,
@@ -476,6 +465,53 @@ mod test {
476465 ) -> Result < ( ) > {
477466 todo ! ( )
478467 }
468+
469+ async fn find_segment (
470+ & self ,
471+ _config : & Self :: Config ,
472+ _namespace : & NamespaceName ,
473+ _frame_no : u64 ,
474+ ) -> Result < SegmentKey > {
475+ todo ! ( )
476+ }
477+
478+ async fn fetch_segment_index (
479+ & self ,
480+ _config : & Self :: Config ,
481+ _namespace : & NamespaceName ,
482+ _key : & SegmentKey ,
483+ ) -> Result < fst:: Map < Arc < [ u8 ] > > > {
484+ todo ! ( )
485+ }
486+
487+ async fn fetch_segment_data_to_file (
488+ & self ,
489+ _config : & Self :: Config ,
490+ _namespace : & NamespaceName ,
491+ _key : & SegmentKey ,
492+ _file : & impl FileExt
493+ ) -> Result < ( ) > {
494+ todo ! ( )
495+ }
496+
497+ async fn fetch_segment_data (
498+ self : Arc < Self > ,
499+ _config : Arc < Self :: Config > ,
500+ _namespace : NamespaceName ,
501+ _key : SegmentKey ,
502+ ) -> Result < impl FileExt > {
503+ Ok ( std:: fs:: File :: open ( "" ) . unwrap ( ) )
504+ }
505+
506+ async fn fetch_segment (
507+ & self ,
508+ _config : & Self :: Config ,
509+ _namespace : & NamespaceName ,
510+ _frame_no : u64 ,
511+ _dest_path : & std:: path:: Path ,
512+ ) -> Result < fst:: Map < Arc < [ u8 ] > > > {
513+ todo ! ( )
514+ }
479515 }
480516
481517 let job = Job {
0 commit comments