Datacake Cluster

A batteries included library for building your own distributed data stores or replicated state.

This library is largely based on the same concepts as Riak and Cassandra. Consensus, membership and failure detection are managed by Quickwit's Chitchat while state alignment and replication is managed by Datacake CRDT.

RPC is provided and managed entirely within Datacake using Tonic and GRPC.

This library is focused around providing a simple and easy to build framework for your distributed apps without being overwhelming. In fact, you can be up and running just by implementing 2 async traits.

Basic Example

```rust use std::net::SocketAddr; use datacakenode::{Consistency, ConnectionConfig, DCAwareSelector, DatacakeNodeBuilder}; use datacakeeventualconsistency::testutils::MemStore; use datacakeeventualconsistency::EventuallyConsistentStoreExtension;

async fn main() -> anyhow::Result<()> { let addr = "127.0.0.1:8080".parse::().unwrap(); let connectioncfg = ConnectionConfig::new(addr, addr, Vec::::new()); let node = DatacakeNodeBuilder::::new(1, connectioncfg) .connect() .await .expect("Connect node.");

let store = node
    .add_extension(EventuallyConsistentStoreExtension::new(MemStore::default()))
    .await
    .expect("Create store.");

let handle = store.handle();

handle
    .put(
        "my-keyspace",
        1,
        b"Hello, world! From keyspace 1.".to_vec(),
        Consistency::All,
    )
    .await
    .expect("Put doc.");

Ok(())

} ```

Complete Examples

Indepth examples can be found here.