iguazu 0.0.1

Tools for viewing, storing, and sharing mixed-signal time series data
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

//! Data storage and access backends.
mod cache;

mod in_memory;

use std::sync::{Arc, Mutex};

use async_executor::Executor;
pub use in_memory::{ MemoryStorage, MemoryStream, MemoryStreamWriter };

mod flat_file;
pub use flat_file::{ FlatFileStream, FlatFileOpts };

use crate::{stream::StreamWriter, ElementSize};

#[cfg(feature = "izs")]
pub mod izs;

/// A storage backend that can create writable streams
pub trait Storage: Send + Sync {
    fn create_stream(&self, element_type: ElementSize) -> Box<dyn StreamWriter>;
}

pub struct Pool {
    cache: Mutex<cache::CachePool>,
    pub executor: Arc<Executor<'static>>,
}

impl Pool {
    pub fn new(executor: Arc<Executor<'static>>, cache_limit: usize) -> Self {
        Pool { cache: Mutex::new(cache::CachePool::new(cache_limit)), executor }
    }

    pub fn stats(&self) -> PoolStats {
        let cache = self.cache.lock().unwrap();
        PoolStats {
            cache_limit: cache.limit(),
            cache_usage: cache.total(),
        }
    }
}

pub struct PoolStats {
    pub cache_limit: usize,
    pub cache_usage: usize,
}