CDRS tokio

CDRS is production-ready Apache Cassandra driver written in pure Rust. Focuses on providing high level of configurability to suit most use cases at any scale, as its Java counterpart, while also leveraging the safety and performance of Rust.

Features

• Asynchronous API;
• TCP/TLS connection (rustls);
• Topology-aware dynamic and configurable load balancing;
• Configurable connection strategies and pools;
• Configurable speculative execution;
• LZ4, Snappy compression;
• Cassandra-to-Rust data serialization/deserialization with custom type support;
• Pluggable authentication strategies;
• ScyllaDB support;
• Server events listening;
• Multiple CQL version support (3, 4, 5), full spec implementation;
• Query tracing information;
• Prepared statements;
• Query paging;
• Batch statements;
• Configurable retry and reconnection policy;
• Support for interleaved queries;
• Support for Yugabyte YCQL JSONB;
• Support for beta protocol usage;

Performance

Due to high configurability of CDRS, the performance will vary depending on use case. The following benchmarks have been made against the latest (master as of 03-12-2021) versions of respective libraries (except cassandra-cpp: 2.16.0) and protocol version 4.

• cdrs-tokio-large-pool - CDRS with node connection pool equal to double of physical CPU cores
• cdrs-tokio-small-pool - CDRS with a single connection per node
• scylladb-rust-large-pool - scylla crate with node connection pool equal to double of physical CPU cores
• scylladb-rust-small-pool - scylla crate with a single connection per node
• cassandra-cpp - Rust bindings for Datastax C++ Driver, running on multiple threads using Tokio
• gocql - a driver written in Go

Knowing given use case, CDRS can be optimized for peak performance.

Documentation and examples

• User guide.
• Examples.
• API docs.
• Using ScyllaDB with RUST lesson.

Getting started

This example configures a cluster consisting of a single node without authentication, and uses round-robin load balancing. Other options are kept as default.

use cdrs_tokio::cluster::session::{TcpSessionBuilder, SessionBuilder};
use cdrs_tokio::cluster::NodeTcpConfigBuilder;
use cdrs_tokio::load_balancing::RoundRobinLoadBalancingStrategy;
use cdrs_tokio::query::*;

#[tokio::main]
async fn main() {
    let cluster_config = NodeTcpConfigBuilder::new()
        .with_contact_point("127.0.0.1:9042".into())
        .build()
        .await
        .unwrap();
    let session = TcpSessionBuilder::new(RoundRobinLoadBalancingStrategy::new(), cluster_config)
        .build()
        .await
        .unwrap();

    let create_ks = "CREATE KEYSPACE IF NOT EXISTS test_ks WITH REPLICATION = { \
                     'class' : 'SimpleStrategy', 'replication_factor' : 1 };";
    session
        .query(create_ks)
        .await
        .expect("Keyspace create error");
}

License

This project is licensed under either of

• Apache License, Version 2.0, (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.