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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

use crate::config_cluster::MetaClient;
use crate::pacifica::{Codec, Request, Response};
use crate::rpc::ReplicaClient;
use crate::runtime::AsyncRuntime;
use std::fmt::{Debug, Display};
use std::hash::Hash;
use crate::storage::{LogStorage, SnapshotStorage};

pub trait NodeIdEssential:
    From<String>
    + Into<String>
    + Send
    + Sync
    + Sized
    + Eq
    + PartialEq
    + Ord
    + PartialOrd
    + Debug
    + Display
    + Hash
    + Clone
    + Default
    + 'static
{
}

impl<T> NodeIdEssential for T where
    T: From<String>
        + Into<String>
        + Send
        + Sync
        + Sized
        + Eq
        + PartialEq
        + Ord
        + PartialOrd
        + Debug
        + Display
        + Hash
        + Copy
        + Clone
        + Default
        + 'static
{
}

pub trait NodeId: NodeIdEssential {}

impl<T> NodeId for T where T: NodeIdEssential {}

pub trait TypeConfig: Sized + Send + Sync + Debug + Clone + Copy + Default +  Eq + PartialEq + Ord + PartialOrd + 'static {
    type Request: Request;
    type Response: Response;
    type RequestCodec: Codec<Self::Request>;
    type MetaClient: MetaClient<Self>;
    type ReplicaClient: ReplicaClient<Self>;

    type NodeId: NodeId;
    type AsyncRuntime: AsyncRuntime;
    type LogStorage: LogStorage;
    type SnapshotStorage: SnapshotStorage<Self>;
}

pub mod alias {
    use crate::runtime::{Mpsc, MpscUnbounded, Oneshot, Watch};
    use crate::TypeConfig;
    use crate::{AsyncRuntime};
    use crate::storage::{LogStorage, SnapshotStorage};

    pub type NodeIdOf<C> = <C as TypeConfig>::NodeId;
    pub type MetaClientOf<C> = <C as TypeConfig>::MetaClient;
    pub type ReplicaClientOf<C> = <C as TypeConfig>::ReplicaClient;
    pub type AsyncRuntimeOf<C> = <C as TypeConfig>::AsyncRuntime;

    type RT<C> = AsyncRuntimeOf<C>;

    pub type JoinErrorOf<C> = <RT<C> as AsyncRuntime>::JoinError;
    pub type JoinHandleOf<C, T> = <RT<C> as AsyncRuntime>::JoinHandle<T>;
    pub type InstantOf<C> = <RT<C> as AsyncRuntime>::Instant;
    pub type SleepOf<C> = <RT<C> as AsyncRuntime>::Sleep;
    pub type TimeoutErrorOf<C> = <RT<C> as AsyncRuntime>::TimeoutError;
    pub type TimeoutOf<C, R, F> = <RT<C> as AsyncRuntime>::Timeout<R, F>;

    pub type MpscOf<C> = <RT<C> as AsyncRuntime>::Mpsc;

    type MpscB<C> = MpscOf<C>;
    pub type MpscSenderOf<C, T> = <MpscB<C> as Mpsc>::Sender<T>;
    pub type MpscReceiverOf<C, T> = <MpscB<C> as Mpsc>::Receiver<T>;

    pub type MpscUnboundedOf<C> = <RT<C> as AsyncRuntime>::MpscUnbounded;
    type MpscUB<C> = MpscUnboundedOf<C>;
    pub type MpscUnboundedSenderOf<C, T> = <MpscUB<C> as MpscUnbounded>::Sender<T>;
    pub type MpscUnboundedReceiverOf<C, T> = <MpscUB<C> as MpscUnbounded>::Receiver<T>;

    pub type OneshotOf<C> = <RT<C> as AsyncRuntime>::Oneshot;
    pub type OneshotSenderOf<C, T> = <OneshotOf<C> as Oneshot>::Sender<T>;
    pub type OneshotReceiverOf<C, T> = <OneshotOf<C> as Oneshot>::Receiver<T>;
    pub type OneshotReceiverErrorOf<C> = <OneshotOf<C> as Oneshot>::ReceiverError;


    pub type WatchOf<C> = <RT<C> as AsyncRuntime>::Watch;
    pub type WatchSenderOf<C, T> = <WatchOf<C> as Watch>::Sender<T>;
    pub type WatchReceiverOf<C, T> = <WatchOf<C> as Watch>::Receiver<T>;

    pub type SnapshotStorageOf<C> = <C as TypeConfig>::SnapshotStorage;
    pub type SnapshotReaderOf<C> = <SnapshotStorageOf<C> as SnapshotStorage<C>>::Reader;
    pub type SnapshotWriteOf<C> = <SnapshotStorageOf<C> as SnapshotStorage<C>>::Writer;

    pub type LogStorageOf<C> = <C as TypeConfig>::LogStorage;
    pub type LogReaderOf<C> = <LogStorageOf<C> as LogStorage>::Reader;
    pub type LogWriteOf<C> = <LogStorageOf<C> as LogStorage>::Writer;
}