proton_client 0.1.2

Client for Timeplus Proton, a streaming SQL engine
Documentation
1
2
3
4
5
6
7
8
9
10
use proton_client::ProtonClient;

#[tokio::test]
async fn test_execute_query() {
    let client = ProtonClient::new("http://localhost:8123");
    let query = "select count() from table(table_name)";

    let result = client.execute_query(query).await;
    assert!(result.is_err());
}