KurrentDB Server Compatibility

Example

use kurrentdb::{Client,EventData};use serde::{Serialize,Deserialize};#[derive(Serialize,Deserialize,Debug)]structFoo{is_rust_a_nice_language:bool,}#[tokio::main]asyncfnmain() ->Result<(),Box<dyn std::error::Error>>{// Creates a client settings for a single node configuration.let settings ="kurrentdb://admin:changeit@localhost:2113".parse()?;let client =Client::new(settings)?;let payload =Foo{is_rust_a_nice_language:true,};// It is not mandatory to use JSON as a data format however KurrentDB// provides great additional value if you do so.let evt =EventData::json("language-poll",&payload)?;    client.append_to_stream("language-stream",&Default::default(), evt).await?;letmut stream = client.read_stream("language-stream",&Default::default()).await?;whileletSome(event) = stream.next().await?{let event = event.get_original_event().as_json::<Foo>()?;// Do something productive with the result.println!("{:?}", event);}Ok(())}

Support

Documentation

Communities