Skip to content

Commit 882fee6

Browse files
committed
fix test storage impl
1 parent 71d8c86 commit 882fee6

File tree

1 file changed

+48
-12
lines changed

1 file changed

+48
-12
lines changed

libsql-wal/src/storage/job.rs

Lines changed: 48 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)