Apache HoraeDB (Incubating) Rust Client

Introduction

Rust client for Apache HoraeDB (Incubating).

[!IMPORTANT] Apache HoraeDB (incubating) is an effort undergoing incubation at the Apache Software Foundation (ASF), sponsored by the Apache Incubator PMC.

Please read the DISCLAIMER and a full explanation of "incubating".

Support features

• Query
• Write

Contributing

Any contribution is welcome!

Read our Contributing Guide and make your first contribution!

License

Under Apache License 2.0.

lib.rs:

This crate provides an user-friendly client for [HoraeDB](https://github.com/HoraeDB /horaedb).

With this crate, you can access a standalone HoraeDB or a HoraeDB cluster and manipulates the data in it. And the underlying communication between the client the HoraeDB servers is based on the gRPC, and the protocol is defined in the horaedbproto.

Choose Mode

Two access Modes are provided by the client, Proxy and Direct:

• When accessing HoraeDB cluster by Direct mode, the requests will be sent directly to the right HoraeDB instance determined by routing information.
• When accessing HoraeDB by Proxy mode, the requests are just sent to any one HoraeDB instance, which takes the responsibilities for forwarding the requests.

If the client can't access the HoraeDB server directly because of the network partition, Proxy mode is the only choice. Otherwise, Direct mode is suggested for better performance.

Usage

Build the client, and then manipulate the HoraeDB by writing and querying.

Example

Here is an example to create a table in HoraeDB by the client.

let client = Builder::new("127.0.0.1:8831".to_string(), Mode::Direct).build();
let rpc_ctx = RpcContext::default().database("public".to_string());

let create_table_sql = r#"CREATE TABLE IF NOT EXISTS horaedb (
    str_tag string TAG,
    int_tag int32 TAG,
    var_tag varbinary TAG,
    str_field string,
    int_field int32,
    bin_field varbinary,
    t timestamp NOT NULL,
    TIMESTAMP KEY(t)) ENGINE=Analytic with
    (enable_ttl='false')"#;

let req = SqlQueryRequest {
    tables: vec!["horaedb".to_string()],
    sql: create_table_sql.to_string(),
};
let resp = client
    .sql_query(&rpc_ctx, &req)
    .await
    .expect("Should succeed to create table");

println!("Create table result:{:?}", resp);