fluent_data 1.2.4

A low footprint streaming data modelization library and service.
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

use std::error::Error;

use clap::Parser;
use fluent_data::{service, space, streamer};
use fluent_data::{Algo, Model, Streamer};

#[derive(Parser, Debug)]
#[clap(author, version, about, long_about = None)]
struct Args {
    /// starts in service mode.
    #[clap(short, long, value_parser)]
    service: bool,
}

fn main() -> Result<(), Box<dyn Error>> {
    let args = Args::parse();
    let (algo, mut model) = get_algo_model();
    let streamer = get_streamer(&args);
    Streamer::run(streamer, algo, &mut model)?;
    Ok(())
}

type BoxedInOut = (
    Box<dyn Iterator<Item = Result<String, Box<dyn Error>>>>,
    Box<dyn FnMut(String) -> Result<(), Box<dyn Error>>>,
);

fn get_streamer(
    args: &Args,
) -> Streamer<
    Box<dyn Iterator<Item = Result<String, Box<dyn Error>>>>,
    Box<dyn FnMut(String) -> Result<(), Box<dyn Error>>>,
> {
    let (points, write): BoxedInOut = if args.service {
        let (points, write) = service::backend();
        (Box::new(points), Box::new(write))
    } else {
        let (points, write) = streamer::stdio();
        (Box::new(points), Box::new(write))
    };
    let streamer = Streamer::new(points, write);
    streamer
}

fn get_algo_model() -> (Algo<Vec<f64>>, Model<Vec<f64>>) {
    let algo = Algo::new(space::euclid_dist, space::real_combine);
    let model = Model::new(space::euclid_dist);
    (algo, model)
}