ciruela 0.6.12

A peer-to-peer synchronization software for servers in datacenters.
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
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

use index::{ImageId};
use {VPath};
use proto::Hash;
use machine_id::MachineId;
use mask::Mask;
use std::collections::{BTreeMap, HashSet, BTreeSet};


#[derive(Serialize, Deserialize, Debug)]
pub struct Packet {
    pub machine_id: MachineId,
    pub your_config: Option<Hash>,
    pub message: Message,
}

#[derive(Serialize, Deserialize, Debug)]
pub enum Message {
    BaseDirs {
        in_progress: BTreeMap<VPath, (ImageId, Mask, bool, bool)>,
        watching: BTreeSet<VPath>,
        complete: BTreeMap<VPath, ImageId>,
        deleted: HashSet<(VPath, ImageId)>,
        base_dirs: BTreeMap<VPath, Hash>,
    },
    Downloading {
        path: VPath,
        image: ImageId,
        mask: Mask,
        source: bool,
        #[serde(default, skip_serializing_if="HashSet::is_empty")]
        watches: HashSet<MachineId>,
    },
    Reconcile {
        path: VPath, hash: Hash,
        #[serde(default, skip_serializing_if="BTreeMap::is_empty")]
        watches: BTreeMap<VPath, HashSet<MachineId>>,
    },
    Complete { path: VPath, image: ImageId },
    CompleteAck { path: VPath },
    ConfigSync { paths: BTreeSet<VPath>  },
}

#[derive(Serialize, Debug)]
pub struct PacketRef<'a> {
    pub machine_id: &'a MachineId,
    pub your_config: &'a Option<Hash>,
    pub message: MessageRef<'a>,
}

#[derive(Serialize, Debug)]
#[allow(dead_code)]
pub enum MessageRef<'a> {
    BaseDirs {
        in_progress: BTreeMap<&'a VPath, (&'a ImageId, &'a Mask, bool, bool)>,
        watching: &'a BTreeSet<VPath>,
        deleted: &'a Vec<(VPath, ImageId)>,
        base_dirs: &'a BTreeMap<VPath, Hash>,
        complete: &'a BTreeMap<VPath, ImageId>,
    },
    ConfigSync { paths: &'a BTreeSet<VPath>  },
    CompleteAck { path: &'a VPath },
}