eventstore-rs

Rust [EventStore] TCP Client.

[Talk and exchange ideas in our dedicated Discord Server]

State of implemented features

• [x] Can connect to GetEventStore >=4.* servers (for version 20.6 and above enable the es6 feature flag and use the es6 module).
• [x] Connection health tracking.
• [x] Operation timeout detection and retry.
• [x] Write events.
• [x] Read events (including $all stream).
• [x] Read/Write stream metadata.
• [x] Transactions.
• [x] Delete stream.
• [x] Volatile Subscriptions.
• [x] Catchup Subscriptions.
• [x] Persistent Subscriptions.
• [x] Support connection to server clusters. (through gossip seeds or DNS)
• [x] Support SSL connection.

Example

```rust

[macro_use]

extern crate serde_json;

use eventstore::{ Connection, EventData }; use futures::Future;

[tokio::main]

async fn main() -> Result<(), Box> { let addr = "127.0.0.1:1113".parse()?; let connection = Connection::builder() .singlenodeconnection(addr) .await;

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

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

let result = connection
    .write_events("language-stream")
    .push_event(event)
    .execute()
    .await?;

// Do something productive with the result.
println!("{:?}", result);

Ok(())

} ```

Notes

That library was tested on Linux and OSX.

Contributions and bug reports are welcome!

MIT License