proton_client 0.1.2

Client for Timeplus Proton, a streaming SQL engine
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

use clickhouse_derive::Row;
use proton_client::ProtonClient;
use serde::{Deserialize, Serialize};

#[derive(Debug, Row, Serialize, Deserialize)]
pub struct MyRow {
    name: String,
}

#[tokio::test]
async fn test_insert() {
    let client = ProtonClient::new("http://localhost:8123");

    let insert = client.insert::<MyRow>("table_name").await;
    assert!(insert.is_ok());
}

#[tokio::test]
async fn test_inserter() {
    let client = ProtonClient::new("http://localhost:8123");

    let insert = client.inserter::<MyRow>("table_name").await;
    assert!(insert.is_ok());
}