talos_cohort_replicator 0.3.17

Talos Replicator for serial installation of statemaps and updating snapshot of cohort db.
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

use thiserror::Error as ThisError;

// enum ServiceErrorKind {
//     // i/o errors
//     DBError,
//     EventStreamError,
//     // internal channel errors
//     ChannelError,
//     // general system related errors
//     SystemError,
// }

#[derive(Debug, ThisError, PartialEq, Clone)]
#[error("error reason={reason} ")]
pub struct ServiceError {
    // pub kind: SystemServiceErrorKind,
    pub reason: String,
    // pub data: Option<String>,
    // pub service: String,
}

// enum ReplicatorInstallerError {
//     DBConnectionError
//     DB
//     // DB Connection Error
//     // DB Transaction Error
//     // Data deserialization Error
//     // Update table - Cohort related or snapshot ([table name], retry count)
//     // Exhausted retry and no install

// }

#[derive(strum::Display, Debug, Clone)]
pub enum ReplicatorErrorKind {
    Messaging,
    Internal,
    Persistence,
}

#[derive(Debug, Clone)]
pub struct ReplicatorError {
    pub kind: ReplicatorErrorKind,
    pub reason: String,
    pub cause: Option<String>,
}