eventstore-rs

Rust GetEventStore TCP Client.

Talk and exchange ideas in our dedicated Discord Server

State of implemented features

• Can connect to GetEventStore 4.* servers.
• Connection health tracking.
• Operation timeout detection and retry.
• Write events.
• Read events (including $all stream).
• Read/Write stream metadata.
• Transactions.
• Delete stream.
• Volatile Subscriptions.
• Catchup Subscriptions.
• Persistent Subscriptions.
• Support connection to server clusters.
• Support SSL connection.

Example

extern crate eventstore;
extern crate futures;
#[macro_use]
extern crate serde_json;

use eventstore::Client;
use eventstore::types::{ Settings, EventData };
use futures::future::Future;

fn main() {
    // No connection has started yet.
    let client = Client::new(
        Settings::default(),
        "127.0.0.1:1113".parse().unwrap(),
    );

    // Now the asynchronous connection procedure will start.
    client.start();

    // It is not mandatory to use JSON as a data format however GetEventStore
    // provides great additional values if you do so.
    let payload = json!({
        "is_rust_a_nice_language": true,
    });

    let event = EventData::json("language-poll", payload);

    // All the operations are asynchronous but for the sake of this example
    // we decide to wait until the server sends a response.
    let result = client
        .write_events("language-stream")
        .push_event(event)
        .execute()
        .wait()
        .unwrap();

    // Do something productive with the result.
}

Notes

That library was tested on Linux and OSX.

Contributions and bug reports are welcome!

MIT License

-Yorick Laupa