# 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.
- [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, using custom DNS server is still TODO)
- [ ] 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<dyn std::error::Error>> {
let addr = "127.0.0.1:1113".parse()?;
let connection = Connection::builder()
.single_node_connection("127.0.0.1:1113")
.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)?;
// All the operations are asynchronous but for the sake of this example
// we decide to wait until the server sends a response.
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
[GetEventStore]: https://eventstore.org/
[Talk and exchange ideas in our dedicated Discord Server]: https://discord.gg/x7q37jJ
[EventStore]: https://eventstore.org/