influxc 0.4.2

InfluxDB Client Library
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

//!
//! Data Constistency Guarantee Methods.
//!
//! These are designed to provide the same interface than the client, wrapping around it and providing the same
//! interface `ClientTrait`.
//!
mod file;

use std::fmt::Debug;

pub use file::FileBacklog;

use crate::Record;
use crate::InfluxResult;


/// API definition that any backlog service needs to abide by so the [Client](struct.Client.html) can use it.
pub trait Backlog: Debug + Send + Sync
{
    /// Return any pending records that sits in backlog and requires to be commited.
    fn read_pending(&mut self) -> InfluxResult<Vec<Record>>;

    /// Write records that could not be commited, so they get written into backlog for future processing.
    fn write_pending(&mut self, record: &Record) -> InfluxResult<()>;

    /// Empty backlog from pending records. This gets called once all pending records have been
    /// successfully commited.
    fn truncate_pending(&mut self, record: &Record) -> InfluxResult<()>;
}


/// Backlog that does nothing
#[derive(Debug)]
pub struct NoopBacklog;


impl NoopBacklog
{
    /// Construct this dummy backlog that does nothing
    pub fn new() -> Self
    {
        Self {}
    }
}


impl Backlog for NoopBacklog
{
    fn read_pending(&mut self) -> InfluxResult<Vec<Record>> {
        Ok(Vec::new())
    }

    fn write_pending(&mut self, _: &Record) -> InfluxResult<()> {
        Ok(())
    }

    fn truncate_pending(&mut self, _: &Record) -> InfluxResult<()> {
        Ok(())
    }
}