rillflow 0.1.0-alpha.8

Rillflow — a lightweight document + event store for Rust, powered by Postgres.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use rillflow::{Event, Expected, Store};
use uuid::Uuid;

#[tokio::main]
async fn main() -> rillflow::Result<()> {
    let url = std::env::var("DATABASE_URL")
        .unwrap_or_else(|_| "postgres://postgres:postgres@localhost:5432/postgres".into());

    let store = Store::connect(&url).await?;

    #[derive(Debug, serde::Serialize, serde::Deserialize)]
    struct Customer {
        id: Uuid,
        email: String,
    }

    let customer = Customer {
        id: Uuid::new_v4(),
        email: "alice@example.com".into(),
    };

    store.docs().upsert(&customer.id, &customer).await?;
    let fetched = store.docs().get::<Customer>(&customer.id).await?;
    println!("Fetched: {fetched:?}");

    store
        .events()
        .append_stream(
            customer.id,
            Expected::Any,
            vec![Event::new("CustomerRegistered", &customer)],
        )
        .await?;

    let events = store.events().read_stream(customer.id).await?;
    println!("Events: {events:#?}");

    Ok(())
}