floe-core 0.4.2

Core library for Floe, a YAML-driven technical ingestion tool.
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

use crate::io::format::{self, InputAdapter, RejectedSinkAdapter};
use crate::io::storage::CloudClient;
use crate::io::write::sink_format::{sink_format as lookup_sink_format, SinkFormat};
use crate::FloeResult;

pub trait Runtime {
    fn input_adapter(&self, format: &str) -> FloeResult<&'static dyn InputAdapter>;
    fn sink_format(&self, format: &str) -> FloeResult<&'static dyn SinkFormat>;
    fn rejected_sink_adapter(&self, format: &str) -> FloeResult<&'static dyn RejectedSinkAdapter>;
    fn storage(&mut self) -> &mut CloudClient;
}

pub struct DefaultRuntime {
    cloud: CloudClient,
}

impl DefaultRuntime {
    pub fn new() -> Self {
        Self {
            cloud: CloudClient::new(),
        }
    }
}

impl Default for DefaultRuntime {
    fn default() -> Self {
        Self::new()
    }
}

impl Runtime for DefaultRuntime {
    fn input_adapter(&self, format: &str) -> FloeResult<&'static dyn InputAdapter> {
        format::input_adapter(format)
    }

    fn sink_format(&self, format: &str) -> FloeResult<&'static dyn SinkFormat> {
        lookup_sink_format(format)
    }

    fn rejected_sink_adapter(&self, format: &str) -> FloeResult<&'static dyn RejectedSinkAdapter> {
        format::rejected_sink_adapter(format)
    }

    fn storage(&mut self) -> &mut CloudClient {
        &mut self.cloud
    }
}