streaming-platform 0.1.0

Data streaming platform and message broker with concurrent data transfer capabilities. 
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

use std::collections::HashMap;
use serde_json::{json, Value, from_value};
use streaming_platform::{client, MagicBall, sp_dto::{MsgMeta, Message, Response, resp}};

pub async fn process_event(config: HashMap<String, String>, mut mb: MagicBall, msg: Message<Value>) -> Result<(), Box<dyn std::error::Error>>  {
    Ok(())
}

pub async fn process_rpc(config: HashMap<String, String>, mut mb: MagicBall, msg: Message<Value>) -> Result<Response<Value>, Box<dyn std::error::Error>> {    
    resp(json!({}))
}

pub async fn startup(config: HashMap<String, String>, mut mb: MagicBall) {
    let msg = mb.rpc::<_, Value>("Client", "Hi", json!({
        "data": "hello"
    })).await;

    println!("{:#?}", msg);	    
}

pub fn main() {
    env_logger::init();

    let mut config = HashMap::new();

    config.insert("addr".to_owned(), "Client2".to_owned());
    config.insert("host".to_owned(), "localhost:11001".to_owned());
    config.insert("access_key".to_owned(), "".to_owned());
 
    client::start(config, process_event, process_rpc, startup);
 }