graft 0.2.1

The Graft storage engine.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use std::fmt::Debug;

use crate::core::commit::SegmentRangeRef;
use culprit::ResultExt;

use crate::{
    local::fjall_storage::FjallStorage,
    remote::{Remote, segment::segment_frame_iter},
    rt::action::{Action, Result},
};

/// Fetches one or more Segment frames and loads the pages into Storage.
#[derive(Debug)]
pub struct FetchSegment {
    pub range: SegmentRangeRef,
}

impl Action for FetchSegment {
    async fn run(self, storage: &FjallStorage, remote: &Remote) -> Result<()> {
        let bytes = remote
            .get_segment_range(&self.range.sid, &self.range.bytes)
            .await
            .or_into_ctx()?;
        let pages = segment_frame_iter(self.range.pageset.iter(), &bytes);
        let mut batch = storage.batch();
        for (pageidx, page) in pages {
            batch.write_page(self.range.sid.clone(), pageidx, page);
        }
        batch.commit().or_into_ctx()?;
        Ok(())
    }
}