datacake-node-ext-demo.rs

use datacake_node::{ClusterExtension, DatacakeNode};
use async_trait::async_trait;

pub struct MyExtension;

#[async_trait]
impl ClusterExtension for MyExtension {
    type Output = ();
    type Error = MyError;

    async fn init_extension(
        self,
        node: &DatacakeNode,
    ) -> Result<Self::Output, Self::Error> {
        // In here we can setup our system using the live node.
        // This gives us things like the cluster clock and RPC server:
        
        println!("Creating my extension!");
        
        let timestamp = node.clock().get_time().await;
        println!("My timestamp: {timestamp}");
        
        Ok(())
    }  
}

pub struct MyError;