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

use std::sync::Arc;
use std::fmt;

use failure::Error;

use cluster::upload::Stats;

/// Network error happened
///
/// Network error means we couldn't upload data to all peers we wanted, either
/// because they are inaccessible or some kind of timeout happened, or they
/// refused to accept the image
#[derive(Debug, Fail, Clone)]
pub enum ErrorKind {
    /// Deadline reached when doing upload
    #[fail(display="deadline reached")]
    DeadlineReached,
    /// Some hosts rejected the download
    #[fail(display="some hosts rejected the download")]
    Rejected,
    #[doc(hidden)]
    #[fail(display="undefined error")]
    __Nonexhaustive,
}

/// Error when uploading image
#[derive(Debug, Fail)]
pub enum UploadErr {
    /// Unexpected fatal error happened
    Fatal(Error),
    /// Deadline reached
    // TODO(tailhook) maybe make stats here
    NetworkError(ErrorKind, Arc<Stats>),
    #[doc(hidden)]
    __Nonexhaustive,
}

impl fmt::Display for UploadErr {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        use self::UploadErr::*;
        match *self {
            Fatal(ref e) => write!(f, "fatal error: {:?}", e),
            NetworkError(ref kind, ref stats) => {
                write!(f, "network error: {}. Overall progress: {}",
                    kind, stats.one_line_progress())
            }
            __Nonexhaustive => write!(f, "undefined error"),
        }
    }
}

/// Error when downloading index or block
#[derive(Debug, Fail)]
pub enum FetchErr {
    /// Unexpected fatal error happened
    #[fail(display="{:?}", _0)]
    Fatal(Error),
    #[doc(hidden)]
    #[fail(display="undefined error")]
    __Nonexhaustive,
}