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

use std::time::Duration;
use crate::core::operation::Operation;
use crate::{LogId, ReplicaId, TypeConfig};
use crate::core::ResultSender;
use crate::error::PacificaError;

pub(crate) enum ApiMsg<C>
where
    C: TypeConfig, {

    CommitOperation {
        operation: Operation<C>
    },

    SaveSnapshot {
        callback: ResultSender<C, LogId, PacificaError<C>>,
    },

    TransferPrimary {
        new_primary: ReplicaId<C::NodeId>,
        timeout: Duration,
        callback: ResultSender<C, (), PacificaError<C>>,
    },

    Recovery {
        callback: ResultSender<C, (), PacificaError<C>>,
    },


}