pacifica-rs 1.0.0

rust implementation of PacificA: Replication in Log-Based Distributed Storage Systems
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
33
34

use crate::{LogId, TypeConfig};
use crate::core::ResultSender;
use crate::error::{Fatal, PacificaError};
use crate::type_config::alias::{SnapshotReaderOf, SnapshotWriteOf};
use crate::util::AutoClose;

pub(crate) enum Task<C>
where
    C: TypeConfig,
{
    ReplayAt {
        log_index: usize,
    },

    CommitBatch {
        primary_term: usize,
        start_log_index: usize,
        requests: Vec<Option<C::Request>>
    },

    SnapshotLoad {
        snapshot_reader: AutoClose<SnapshotReaderOf<C>>,
        callback: ResultSender<C, LogId, PacificaError<C>>,
    },

    SnapshotSave {
        snapshot_writer: AutoClose<SnapshotWriteOf<C>>,
        callback: ResultSender<C, LogId, PacificaError<C>>,
    },

    ReportError {
        fatal: Fatal,
    }
}