Rebrand the codebase.

Cargo.toml

@@ -1,8 +1,8 @@
 [workspace]
 resolver = "2"
 members = [
-    "eventstore",
-    "eventstore-extras",
+    "kurrentdb",
+    "kurrentdb-extras",
 
     # internals
     "eventstore-macros",

README.md

@@ -1,4 +1,4 @@
-# EventStoreDB Rust Client
+# KurrentDB Rust Client
 [![Crates.io][crates-badge]][crates-url]
 [![Crates.io][crates-download]][crates-url]
 [![Build Status][ci-badge]][ci-url]
@@ -8,25 +8,25 @@
 [crates-badge]: https://img.shields.io/crates/v/eventstore.svg
 [crates-download]: https://img.shields.io/crates/d/eventstore.svg
 [crates-url]: https://crates.io/crates/eventstore
-[ci-badge]: https://github.com/EventStore/EventStoreDB-Client-Rust/workflows/CI/badge.svg
-[ci-url]: https://github.com/EventStore/EventStoreDB-Client-Rust/actions
+[ci-badge]: https://github.com/EventStore/KurrentDB-Client-Rust/workflows/CI/badge.svg
+[ci-url]: https://github.com/EventStore/KurrentDB-Client-Rust/actions
 
 [Documentation](https://docs.rs/eventstore)
 
-Official Rust [EventStoreDB rust gRPC] gRPC Client.
+Official Rust [KurrentDB rust gRPC] gRPC Client.
 
-[EventStoreDB] is the event-native database, where business events are immutably stored and streamed. Designed for event-sourced, event-driven, and microservices architectures.
+[KurrentDB] is the event-native database, where business events are immutably stored and streamed. Designed for event-sourced, event-driven, and microservices architectures.
 
-## EventStoreDB Server Compatibility
+## KurrentDB Server Compatibility
 This client is compatible with version `20.6.1` upwards and works on Linux, MacOS and Windows.
 
 
-Server setup instructions can be found here [EventStoreDB Docs], follow the docker setup for the simplest configuration.
+Server setup instructions can be found here [KurrentDB Docs], follow the docker setup for the simplest configuration.
 
 # Example
 
 ```rust
-use eventstore::{ Client, EventData };
+use kurrentdb::{ Client, EventData };
 use serde::{Serialize, Deserialize};
 
 #[derive(Serialize, Deserialize, Debug)]
@@ -45,7 +45,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         is_rust_a_nice_language: true,
     };
 
-    // It is not mandatory to use JSON as a data format however EventStoreDB
+    // It is not mandatory to use JSON as a data format however KurrentDB
     // provides great additional value if you do so.
     let evt = EventData::json("language-poll", &payload)?;
 
@@ -71,11 +71,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
 ## Support
 
-Information on support can be found here: [EventStoreDB Support]
+Information on support can be found here: [KurrentDB Support]
 
 ## Documentation
 
-Documentation for EventStoreDB can be found here: [EventStoreDB Docs]
+Documentation for KurrentDB can be found here: [KurrentDB Docs]
 
 Bear in mind that this client is not yet properly documented. We are working hard on a new version of the documentation.
 
@@ -84,8 +84,8 @@ Bear in mind that this client is not yet properly documented. We are working har
 - [Discuss](https://discuss.eventstore.com/)
 - [Discord (Event Store)](https://discord.gg/Phn9pmCw3t)
 
-[EventStoreDB]: https://eventstore.com/
-[EventStoreDB rust gRPC]: https://developers.eventstore.com/clients/grpc/getting-started?codeLanguage=Rust
+[KurrentDB]: https://eventstore.com/
+[KurrentDB rust gRPC]: https://developers.eventstore.com/clients/grpc/getting-started?codeLanguage=Rust
 [eventstoredb docs]: https://developers.eventstore.com/latest.html
 [eventstoredb discuss]: https://discuss.eventstore.com/
 [eventstoredb support]: https://eventstore.com/support/

configure-tls-for-tests.yml

@@ -4,7 +4,7 @@ services:
     environment:
       PROVISION_DIRECTORIES: "1000:1000:0755:/tmp/certs"
     volumes:
-      - "./eventstore/certs:/tmp/certs"
+      - "./kurrentdb/certs:/tmp/certs"
     network_mode: "none"
 
   setup:
@@ -19,6 +19,6 @@ services:
       && find . -type f -print0 | xargs -0 chmod 666"
     container_name: setup
     volumes:
-      - ./eventstore/certs:/certs
+      - ./kurrentdb/certs:/certs
     depends_on:
       - volumes-provisioner

configure-user-certs-for-tests.yml

@@ -4,7 +4,7 @@ services:
     environment:
       PROVISION_DIRECTORIES: "1000:1000:0755:/tmp/certs"
     volumes:
-      - "./eventstore/certs:/tmp/certs"
+      - "./kurrentdb/certs:/tmp/certs"
     network_mode: "none"
 
   setup:
@@ -18,6 +18,6 @@ services:
       && find . -type f -print0 | xargs -0 chmod 666"
     container_name: setup
     volumes:
-      - ./eventstore/certs:/certs
+      - ./kurrentdb/certs:/certs
     depends_on:
       - volumes-provisioner

examples/Cargo.toml

@@ -2,10 +2,10 @@
 name = "examples"
 version = "0.0.0"
 publish = false
-edition = "2021"
+edition = "2024"
 
 [dev-dependencies]
-eventstore = { path = "../eventstore" }
+kurrentdb = { path = "../kurrentdb" }
 futures = "0.3"
 uuid = { version  = "1.1", features = [ "v4", "serde" ] }
 serde = "1"

examples/appending_events.rs

@@ -3,11 +3,11 @@
 #![allow(unused_results)]
 #![allow(unused_variables)]
 
-use eventstore::{
+use futures::TryStreamExt;
+use kurrentdb::{
     AppendToStreamOptions, Client, Credentials, EventData, ExpectedRevision, ReadStreamOptions,
     StreamPosition,
 };
-use futures::TryStreamExt;
 use serde::{Deserialize, Serialize};
 use std::error::Error;
 use uuid::Uuid;

examples/persistent_subscriptions.rs

@@ -3,12 +3,12 @@
 #![allow(unused_results)]
 #![allow(unused_variables)]
 #![allow(dead_code)]
-use eventstore::{
+use kurrentdb::{
     Client, PersistentSubscriptionEvent, PersistentSubscriptionOptions,
     PersistentSubscriptionToAllOptions, ReplayParkedMessagesOptions, SubscriptionFilter,
 };
 
-async fn create_persistent_subscription(client: &Client) -> eventstore::Result<()> {
+async fn create_persistent_subscription(client: &Client) -> kurrentdb::Result<()> {
     // #region create-persistent-subscription-to-stream
     client
         .create_persistent_subscription("test-stream", "subscription-group", &Default::default())
@@ -18,7 +18,7 @@ async fn create_persistent_subscription(client: &Client) -> eventstore::Result<(
     Ok(())
 }
 
-async fn connect_to_persistent_subscription_to_stream(client: &Client) -> eventstore::Result<()> {
+async fn connect_to_persistent_subscription_to_stream(client: &Client) -> kurrentdb::Result<()> {
     // #region subscribe-to-persistent-subscription-to-stream
     let mut sub = client
         .subscribe_to_persistent_subscription(
@@ -36,7 +36,7 @@ async fn connect_to_persistent_subscription_to_stream(client: &Client) -> events
     // #endregion subscribe-to-persistent-subscription-to-stream
 }
 
-async fn connect_to_persistent_subscription_to_all(client: &Client) -> eventstore::Result<()> {
+async fn connect_to_persistent_subscription_to_all(client: &Client) -> kurrentdb::Result<()> {
     // #region subscribe-to-persistent-subscription-to-all
     let mut sub = client
         .subscribe_to_persistent_subscription_to_all("subscription-group", &Default::default())
@@ -50,7 +50,7 @@ async fn connect_to_persistent_subscription_to_all(client: &Client) -> eventstor
     // #endregion subscribe-to-persistent-subscription-to-all
 }
 
-async fn create_persistent_subscription_to_all(client: &Client) -> eventstore::Result<()> {
+async fn create_persistent_subscription_to_all(client: &Client) -> kurrentdb::Result<()> {
     // #region create-persistent-subscription-to-all
     let options = PersistentSubscriptionToAllOptions::default()
         .filter(SubscriptionFilter::on_stream_name().add_prefix("test"));
@@ -64,7 +64,7 @@ async fn create_persistent_subscription_to_all(client: &Client) -> eventstore::R
 
 async fn connect_to_persistent_subscription_with_manual_acks(
     client: &Client,
-) -> eventstore::Result<()> {
+) -> kurrentdb::Result<()> {
     // #region subscribe-to-persistent-subscription-with-manual-acks
     let mut sub = client
         .subscribe_to_persistent_subscription(
@@ -82,7 +82,7 @@ async fn connect_to_persistent_subscription_with_manual_acks(
     // #endregion subscribe-to-persistent-subscription-with-manual-acks
 }
 
-async fn update_persistent_subscription(client: &Client) -> eventstore::Result<()> {
+async fn update_persistent_subscription(client: &Client) -> kurrentdb::Result<()> {
     // #region update-persistent-subscription
     let options = PersistentSubscriptionOptions::default()
         .resolve_link_tos(true)
@@ -96,7 +96,7 @@ async fn update_persistent_subscription(client: &Client) -> eventstore::Result<(
     Ok(())
 }
 
-async fn delete_persistent_subscription(client: &Client) -> eventstore::Result<()> {
+async fn delete_persistent_subscription(client: &Client) -> kurrentdb::Result<()> {
     // #region delete-persistent-subscription
     client
         .delete_persistent_subscription("test-stream", "subscription-group", &Default::default())
@@ -106,7 +106,7 @@ async fn delete_persistent_subscription(client: &Client) -> eventstore::Result<(
     Ok(())
 }
 
-async fn get_persistent_subscription_to_stream_info(client: &Client) -> eventstore::Result<()> {
+async fn get_persistent_subscription_to_stream_info(client: &Client) -> kurrentdb::Result<()> {
     // #region get-persistent-subscription-to-stream-info
     let info = client
         .get_persistent_subscription_info("test-stream", "subscription-group", &Default::default())
@@ -120,7 +120,7 @@ async fn get_persistent_subscription_to_stream_info(client: &Client) -> eventsto
     Ok(())
 }
 
-async fn get_persistent_subscription_to_all_info(client: &Client) -> eventstore::Result<()> {
+async fn get_persistent_subscription_to_all_info(client: &Client) -> kurrentdb::Result<()> {
     // #region get-persistent-subscription-to-all-info
     let info = client
         .get_persistent_subscription_info_to_all("subscription-group", &Default::default())
@@ -134,7 +134,7 @@ async fn get_persistent_subscription_to_all_info(client: &Client) -> eventstore:
     Ok(())
 }
 
-async fn replay_parked_to_stream(client: &Client) -> eventstore::Result<()> {
+async fn replay_parked_to_stream(client: &Client) -> kurrentdb::Result<()> {
     // #region replay-parked-of-persistent-subscription-to-stream
     let options = ReplayParkedMessagesOptions::default().stop_at(10);
     client
@@ -144,7 +144,7 @@ async fn replay_parked_to_stream(client: &Client) -> eventstore::Result<()> {
     Ok(())
 }
 
-async fn replay_parked_to_all(client: &Client) -> eventstore::Result<()> {
+async fn replay_parked_to_all(client: &Client) -> kurrentdb::Result<()> {
     // #region replay-parked-of-persistent-subscription-to-all
     let options = ReplayParkedMessagesOptions::default().stop_at(10);
     client
@@ -154,7 +154,7 @@ async fn replay_parked_to_all(client: &Client) -> eventstore::Result<()> {
     Ok(())
 }
 
-async fn list_persistent_subscription_to_stream(client: &Client) -> eventstore::Result<()> {
+async fn list_persistent_subscription_to_stream(client: &Client) -> kurrentdb::Result<()> {
     // #region list-persistent-subscriptions-to-stream
     let subscriptions = client
         .list_persistent_subscriptions_for_stream("test-stream", &Default::default())
@@ -170,7 +170,7 @@ async fn list_persistent_subscription_to_stream(client: &Client) -> eventstore::
     Ok(())
 }
 
-async fn list_persistent_subscription_to_all(client: &Client) -> eventstore::Result<()> {
+async fn list_persistent_subscription_to_all(client: &Client) -> kurrentdb::Result<()> {
     // #region list-persistent-subscriptions-to-all
     let subscriptions = client
         .list_persistent_subscriptions_to_all(&Default::default())
@@ -186,7 +186,7 @@ async fn list_persistent_subscription_to_all(client: &Client) -> eventstore::Res
     Ok(())
 }
 
-async fn list_all_persistent_subscription(client: &Client) -> eventstore::Result<()> {
+async fn list_all_persistent_subscription(client: &Client) -> kurrentdb::Result<()> {
     // #region list-persistent-subscriptions
     let subscriptions = client
         .list_all_persistent_subscriptions(&Default::default())
@@ -202,7 +202,7 @@ async fn list_all_persistent_subscription(client: &Client) -> eventstore::Result
     Ok(())
 }
 
-async fn restart_persistent_subscription_subsystem(client: &Client) -> eventstore::Result<()> {
+async fn restart_persistent_subscription_subsystem(client: &Client) -> kurrentdb::Result<()> {
     // #region restart-persistent-subscription-subsystem
     client
         .restart_persistent_subscription_subsystem(&Default::default())

examples/quickstart.rs

@@ -4,7 +4,7 @@
 #![allow(unused_variables)]
 #![allow(unused_must_use)]
 
-use eventstore::{
+use kurrentdb::{
     AppendToStreamOptions, Client, Credentials, EventData, ExpectedRevision, ReadStreamOptions,
 };
 use serde::{Deserialize, Serialize};

examples/reading_events.rs

@@ -3,7 +3,7 @@
 #![allow(unused_results)]
 #![allow(unused_variables)]
 
-use eventstore::{
+use kurrentdb::{
     Client, Credentials, EventData, ExpectedRevision, Position, ReadAllOptions, ReadStreamOptions,
     StreamPosition,
 };

examples/server_side_filtering.rs

@@ -4,11 +4,11 @@
 #![allow(unused_variables)]
 #![allow(unreachable_code)]
 
-use eventstore::{
+use futures::TryStreamExt;
+use kurrentdb::{
     Client, Credentials, EventData, ExpectedRevision, SubscribeToAllOptions, SubscriptionEvent,
     SubscriptionFilter,
 };
-use futures::TryStreamExt;
 use serde::{Deserialize, Serialize};
 use std::error::Error;
 use uuid::Uuid;

examples/subscribing_to_stream.rs

@@ -4,11 +4,11 @@
 #![allow(unused_variables)]
 #![allow(unreachable_code)]
 
-use eventstore::{
+use futures::TryStreamExt;
+use kurrentdb::{
     Client, Credentials, EventData, ExpectedRevision, Position, RetryOptions, StreamPosition,
     SubscribeToAllOptions, SubscribeToStreamOptions, SubscriptionEvent, SubscriptionFilter,
 };
-use futures::TryStreamExt;
 use serde::{Deserialize, Serialize};
 use std::error::Error;
 use uuid::Uuid;

eventstore-extras/Cargo.toml → kurrentdb-extras/Cargo.toml

@@ -1,11 +1,11 @@
 [package]
-name = "eventstore-extras"
-version = "0.1.1"
-edition = "2021"
+name = "kurrentdb-extras"
+version = "0.1.0"
+edition = "2024"
 
 license = "MIT"
 
-description = "EventStoreDB gRPC client extra features"
+description = "KurrentDB gRPC client extra features"
 keywords = ["database", "eventsourcing", "eventstore", "eventstoredb", "grpc"]
 repository = "https://github.com/EventStore/EventStoreDB-Client-Rust"
 categories = ["database", "api-bindings"]
@@ -14,6 +14,6 @@ categories = ["database", "api-bindings"]
 
 [dependencies]
 # will move to version number once we got something stable.
-eventstore = { path = "../eventstore", version = ">=3" }
+kurrentdb = { path = "../kurrentdb", version = "1.0.0" }
 chrono = { version = "0.4", default-features = false }
 log = "0.4"

eventstore-extras/README.md → kurrentdb-extras/README.md

@@ -1,6 +1,6 @@
-# eventstore-extras
+# kurrent-extras
 
-EventStoreDB gRPC client extra features.
+KurrentDB gRPC client extra features.
 
 ## Features
 * Typeful stats data structures when reading from the stats gRPC endpoint.