chore(release): 0.1.2

CHANGELOG.md

@@ -6,20 +6,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
-## [0.1.3] - 2025-07-06
-
-### Added
-- do publish
-- allow readme
-
 ## [0.1.2] - 2025-07-04
 
 ### Added
 - update basic example with a more simple acquire and run function
 
-### Docs
-- update master
-
 ## [0.1.1] - 2025-07-04
 
 ### Added

Cargo.lock

@@ -645,7 +645,7 @@ dependencies = [
 
 [[package]]
 name = "noleader"
-version = "0.1.2"
+version = "0.1.0"
 dependencies = [
  "anyhow",
  "async-nats",

Cargo.toml

@@ -3,7 +3,7 @@ members = ["crates/*"]
 resolver = "2"
 
 [workspace.package]
-version = "0.1.3"
+version = "0.1.2"
 license = "MIT"
 
 [workspace.dependencies]

README.md

@@ -22,9 +22,9 @@ This library is still young and the API is subject to change.
 
 ## Intended use-case
 
-Noleader is not built for distributed consensus, or fast re-election procedures. It take upwards to a minute to get re-elected, state is the users responsibility to handle.
+Noleader is not built for distributed consensus, or fast re-election produces. It take upwards to a minute to get reelected, state is the users responsibility to handle.
 
-Noleader is pretty much just a distributed lock, intended for use-cases where the user wants to only have a single node scheduling work etc.
+Noleader is pretty much just a distributed lock, intended for use-cases where the use wants to only have a single node scheduling work etc.
 
 Good alternatives are:
 
@@ -71,40 +71,58 @@ async fn main() -> anyhow::Result<()> {
     // Ensure the KV bucket exists
     leader.create_bucket().await?;
 
-    // Attempts to acquire election loop, will call inner function if it wins, if it loses it will retry over again.
+    // Spawn the election loop
-    // Will block until either the inner function returns and error, or the election processes crashes, intended to allow the application to properly restart
+    tokio::spawn({
-    leader
+        let leader = leader.clone();
-        .acquire_and_run({
-            move |token| {
-                let leader_id = leader_id.clone();
-
         async move {
-                    loop {
+            leader
-                        if token.is_cancelled() {
+                .start(CancellationToken::default())
-                            return Ok(());
+                .await
+                .expect("leadership loop failed");
         }
+    });
 
-                        tracing::info!(leader_id, "do work as leader");
+    // Do work while we are the leader
+    leader
+        .do_while_leader(|cancel_token| async move {
+            loop {
+                if cancel_token.is_cancelled() {
+                    break;
+                }
+                tracing::info!("🔑 I am the leader—doing work");
                 tokio::time::sleep(std::time::Duration::from_secs(1)).await;
             }
-                }
+            Ok(())
-            }
         })
         .await?;
 
-
     Ok(())
 }
 ```
 
-## Examples
+## API Overview
 
-See the examples folder in ./crates/noleader/examples
+* **`Leader::new(bucket: &str, key: &str, client: async_nats::Client) -> Leader`**
+  Create a new election participant.
+* **`create_bucket(&self) -> anyhow::Result<()>`**
+  Ensures the KV bucket exists (no-op if already created).
+* **`start(&self, token: CancellationToken) -> anyhow::Result<()>`**
+  Begins the background leader-election loop; renews TTL on success or retries on failure.
+* **`do_while_leader<F, Fut>(&self, f: F) -> anyhow::Result<()>`**
+  Runs your closure as long as you hold leadership; cancels immediately on loss.
+* **`leader_id(&self) -> Uuid`**
+  Returns your unique candidate ID.
+* **`is_leader(&self) -> Status`**
+  Returns `Status::Leader` or `Status::Candidate`, taking shutdown into account.
 
-## Architecture
+### Types
-
-Noleader uses a simple election stealing 
 
+```rust
+pub enum Status {
+    Leader,
+    Candidate,
+}
+```
 
 ## License
 

crates/noleader/Cargo.toml

@@ -1,12 +1,7 @@
 [package]
 name = "noleader"
-edition = "2024"
+version = "0.1.0"
-readme = "../../README.md"
+edition = "2021"
-version.workspace = true
-license.workspace = true
-repository = "https://git.front.kjuulh.io/kjuulh/noleader"
-authors = ["kjuulh <contact@kasperhermansen.com>"]
-description = "A small leader election package using NATS keyvalue store as the distributed locking mechanism. Does not require a min / max set of nodes"
 
 [dependencies]
 anyhow.workspace = true