datacake-node-demo.rs

use std::net::SocketAddr;

use datacake_node::{ConnectionConfig, DCAwareSelector, DatacakeNodeBuilder};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let bind_addr = "127.0.0.1:8000".parse::<SocketAddr>().unwrap();

    // We setup our connection config for the node passing in the bind address, public address and seed nodes.
    // Here we're just using the bind address as our public address with no seed, but in the real world
    // this will be a different value when deployed across several servers with seeds to contact.
    let connection_cfg = ConnectionConfig::new(bind_addr, bind_addr, Vec::<String>::new());

    // Our builder lets us configure the node. 
    // 
    // We can configure the node selector, data center of the node, cluster ID, etc...
    let my_node = DatacakeNodeBuilder::<DCAwareSelector>::new(1, connection_cfg).connect().await?;

    // Now we're connected we can add any extensions at runtime, our RPC server will already be
    // running and setup.
    //
    // Check out the `datacake-eventual-consistency` implementation for a demo.

    Ok(())
}