26 releases (7 breaking)

✓ Uses Rust 2018 edition

0.8.0 Jun 30, 2020
0.7.4 Mar 27, 2020
0.5.0 Nov 15, 2019
0.4.1 Jul 29, 2019
0.1.0 Jun 20, 2018

#57 in Database interfaces

Download history 132/week @ 2020-03-21 107/week @ 2020-03-28 61/week @ 2020-04-04 161/week @ 2020-04-11 38/week @ 2020-04-18 46/week @ 2020-04-25 52/week @ 2020-05-02 26/week @ 2020-05-09 33/week @ 2020-05-16 45/week @ 2020-05-23 114/week @ 2020-05-30 39/week @ 2020-06-06 84/week @ 2020-06-13 75/week @ 2020-06-20 70/week @ 2020-06-27 48/week @ 2020-07-04

265 downloads per month
Used in cerberus-es

MIT license

1MB
20K SLoC

eventstore-rs

Crates.io Crates.io Travis (.org) Discord Crates.io

Rust EventStore TCP Client.

Talk and exchange ideas in our dedicated Discord Server

State of implemented features

  • Can connect to GetEventStore >=4.* servers (for version 20.6 and above enable the es6 feature flag and use the es6 module).
  • 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. (through gossip, using custom DNS server is still TODO)
  • Support SSL connection.

Example

#[macro_use]
extern crate serde_json;

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

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let addr = "127.0.0.1:1113".parse()?;
    let connection = Connection::builder()
        .single_node_connection(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

Dependencies

~7–12MB
~259K SLoC