Struct FileBacklog

pub struct FileBacklog { /* private fields */ }

Backlog for the Client to persist Record`s that could not be submitted to the InfluxDB due to conectivity or configuration errors.

Implementations

impl FileBacklog

pub fn new<P: AsRef<Path>>(dir: P) -> Result<Self, InfluxError>

Construct file based backlog by providing a directory to write Record files to.

Examples found in repository

examples/simple.rs (line 19)

fn main() -> Result<(), InfluxError>
{
    let creds   = Credentials::from_basic("testuser", "testpasswd");
    let backlog = FileBacklog::new("./ignore/backlog")?;

    let mut client = Client::build("http://127.0.0.1:8086".into(), creds)
        .backlog(backlog)
        .finish()?;

    let mut rec = Record::new("org", "bucket")
        .precision(Precision::Milliseconds);

    loop
    {
        rec.measurement("sensor1")
            .tag("floor", "second")
            .tag("exposure", "west")
            .field("temp", 123)
            .field("brightness", 500);

        rec.measurement("sensor2")
            .tag("floor", "second")
            .tag("exposure", "east")
            .field("temp", 321)
            .field("brightness", 999);

        if let Err(e) = client.write(&rec) {
            eprintln!("{}", e);
        }

        sleep(Duration::from_secs(1));
    }
}

Trait Implementations

impl Backlog for FileBacklog

fn read_pending(&mut self) -> Result<Vec<Record>, InfluxError>

Return any pending records that sits in backlog and requires to be commited.

fn write_pending(&mut self, record: &Record) -> Result<(), InfluxError>

Write records that could not be commited, so they get written into backlog for future processing.

fn truncate_pending(&mut self, record: &Record) -> Result<(), InfluxError>

Empty backlog from pending records. This gets called once all pending records have been successfully commited.

impl Debug for FileBacklog

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.