etcds 0.16.0

An etcd v3 API server - light server version for queue management
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


use tokio::sync::mpsc::Sender;
use tonic::Status;
use crate::cli::EtcdConfig;
use crate::etcdpb::etcdserverpb::{DeleteRangeRequest, PutRequest, TxnRequest, WatchResponse};

rust_i18n::i18n!("locales");

pub mod etcdpb;
pub mod cli;
pub mod cluster;
mod srv;
pub mod queue;
pub mod kv;
mod peer;


/// Logging prefix, to start every logging message with a string to use in a server as a module 
const LP: &'static str = "[etcd] ";


pub type WatchSender = Sender<Result<WatchResponse, Status>>;

/// Etcd reconfiguration and integration events
#[derive(Clone)]
pub enum EtcdEvents {
    /// Cache modification event
    Data(KvEvent),
    /// Node management event
    Mgmt(EtcdMgmtEvent),
}

#[derive(Clone, Debug)]
pub enum EtcdMgmtEvent {
    /// runtime reconfigure event
    Config(EtcdConfig),
    /// change tracer runtime
    #[cfg(feature = "tracer")]
    Tracer(Option<opentelemetry_sdk::trace::SdkTracer>),
    /// Node management event to stop
    Stop,
    /// Node management event to soft restart 
    Restart,
    /// Node management event to pause(sec)  
    Pause(u16)
}

#[derive(Clone)]
pub enum KvEvent {
    Put(PutRequest),
    Delete(DeleteRangeRequest),
    Txn(TxnRequest),
}