danube-core 0.16.0

Danube messaging core types and traits
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::error::Error;
//use std::fs;
use std::path::Path;

fn main() -> Result<(), Box<dyn Error>> {
    let out_dir = Path::new("src/proto");
    tonic_prost_build::configure()
        .out_dir(out_dir)
        .bytes(".danube.StreamMessage.payload")
        .protoc_arg("--experimental_allow_proto3_optional")
        .compile_protos(
            &[
                "proto/DanubeApi.proto",
                "proto/DanubeAdmin.proto",
                "proto/SchemaRegistry.proto",
                "proto/raft_transport.proto",
                "proto/EdgeReplicator.proto",
            ],
            &["proto"],
        )?;

    Ok(())
}