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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

//! Data export
use std::{pin::Pin, sync::Arc};

use async_executor::Executor;
use thiserror::Error;

use crate::{io::WritableFile, schema::EntityStream};

mod json_virtual;
mod flat_file;
#[cfg(feature = "csv")]
mod csv;
#[cfg(feature = "izs")]
mod izs;

#[derive(Error, Debug)]
pub enum ExportError {
    #[error("IO error: {0}")]
    Io(#[from] std::io::Error),

    #[error("Unsupported schema: {0}")]
    UnsupportedSchema(String),

    #[error("Failed to read input: {0}")]
    Source(String),

    #[error("{0}")]
    UnsupportedStream(String),

    #[error("{0}")]
    InvalidFile(String),
}


pub struct ExportFormat {
    pub name: &'static str,
    pub description: &'static str,
    pub extension: &'static str,
    pub export: fn (executor: Arc<Executor<'static>>, EntityStream, Box<dyn WritableFile>) -> Pin<Box<dyn Future<Output=Result<(), ExportError>> + Send>>,
}

impl ExportFormat {
    pub fn export(&self, file: Box<dyn WritableFile>, executor: Arc<Executor<'static>>, entity: EntityStream) -> Pin<Box<dyn Future<Output=Result<(), ExportError>> + Send>> {
        (self.export)(executor, entity, file)
    }
}

pub const VIRTUAL: ExportFormat = ExportFormat {
    name: "virtual",
    description: "Iguazu Virtual JSON",
    extension: ".iguazu.json",
    export: json_virtual::export,
};

#[cfg(feature = "izs")]
pub const IZS: ExportFormat = ExportFormat {
    name: "izs",
    description: "Iguazu Pack",
    extension: ".izs",
    export: izs::export,
};

// pub const BIN: ExportFormat = ExportFormat {
//     name: "bin",
//     description: "Raw binary",
//     extension: ".bin",
//     export: flat_file::binary,
// };

// #[cfg(feature = "csv")]
// pub const CSV: ExportFormat = ExportFormat {
//     name: "csv",
//     description: "Comma-separated values",
//     extension: ".csv",
//     export: csv::csv
// };

// #[cfg(feature = "csv")]
// pub const TSV: ExportFormat = ExportFormat {
//     name: "tsv",
//     description: "Tab-separated values",
//     extension: ".tsv",
//     export: csv::tsv
// };

pub const EXPORTERS: &[ExportFormat] = &[
    VIRTUAL,
    #[cfg(feature = "izs")]
    IZS,
    // BIN,
    // #[cfg(feature = "csv")] CSV,
    // #[cfg(feature = "csv")] TSV,
];