kdb-connection 0.1.0

kDB connection.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

// Run with cargo run --example ping

use kdb_connection::{Connection, queries::krql};

fn main()
{
    let mqtt_c = mqtt_channel::Client::build("ping_example_rs", "localhost", 1883).start();
    let c = kdb_connection::MqttConnection::new("kdb", mqtt_c.0);
    let q = krql::Test {
        return_value: Some("Hello world!".into()),
        ..Default::default()
    };
    let r = c.execute_query(&q);
    let res = futures::executor::block_on(r.unwrap());
    match res
    {
        Ok(v) => println!("Result is {v:?}"),
        Err(e) => println!("Error occured {e:?}"),
    }
}