twinkled 0.1.2

UDP-based, light key-value store
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

use std::path::Path;
use std::fs::File;

use log::info;

use tokio::time::{Duration, delay_for};
use crate::store::*;


pub struct Snapshooter<P: AsRef<Path>> {
    pub store: Store,
    pub path: P,
    pub duration: Duration,
}

impl <P: AsRef<Path>> Snapshooter<P> {
    pub async fn run(self) -> Result<(), std::io::Error>
    {
        info!("snapshooter launch");
        let Snapshooter{store, path, duration} = self;
        loop {
            delay_for(duration).await;
            store.clone().serialize(File::create(&path)?).await?;
        }
    }
}