Skip to main content
Version: Next

Fluss Rust Client

The Fluss Rust Client is a high-performance, asynchronous library powered by the Tokio runtime. It provides a native interface for interacting with Fluss clusters with minimal overhead.

The client provides two main APIs:

  • Admin API: For managing databases, tables, and partitions.
  • Table API: For reading and writing to Log and Primary Key tables

Installation​

The Fluss Rust client is published to crates.io as fluss-rs. The crate's library name is fluss, so you import it with use fluss::....

Add the following to your Cargo.toml:

[dependencies]
fluss-rs = "0.1"
tokio = { version = "1", features = ["full"] }

Quick Example​

use fluss::client::FlussConnection;
use fluss::config::Config;
use fluss::error::Result;

#[tokio::main]
async fn main() -> Result<()> {
    let mut config = Config::default();
    config.bootstrap_servers = "127.0.0.1:9123".to_string();

    let conn = FlussConnection::new(config).await?;
    let admin = conn.get_admin().await?;

    Ok(())
}

For more examples, see Fluss Rust Client documentation.

Full Documentation​

For the complete Rust client reference including all configuration options, API methods, data types, error handling, and worked examples — see the Fluss Rust Client documentation.