opensensor 0.4.0

A crate for streaming and archiving measurements from sensors
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use parquet;

use parquet::schema::types::Type;
use std::sync::Arc;

///  This purpose of this trait is to facilitate code reuse for sensor data serialization and archiving.  Sensors should implement this trait.
pub trait ParquetArchivable {
    /// Should be the same as the sensor error
    type Error;

    /// Writes out the contents of self into get_file() and returns Ok() or the sensor error
    fn to_bytes_parquet(self) -> Result<Vec<u8>, Self::Error>;

    /// Reads the file in get_file() into either Ok(ParquetArchivableType) or the sensor error
    fn from_bytes_parquet(bytes: &[u8]) -> Result<Self, Self::Error>
    where
        Self: Sized;

    /// The output of this is a parquet schema.
    fn schema(&self) -> Arc<Type>;
}