chore(release): 0.1.2

CHANGELOG.md

@@ -11,9 +11,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### 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.1"
+version = "0.1.0"
 dependencies = [
  "anyhow",
  "async-nats",

README.md

@@ -71,28 +71,31 @@ 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.
-    // Will block until either the inner function returns and error, or the election processes crashes, intended to allow the application to properly restart
+    // Spawn the election loop
+    tokio::spawn({
+        let leader = leader.clone();
+        async move {
+            leader
+                .start(CancellationToken::default())
+                .await
+                .expect("leadership loop failed");
+        }
+    });
+
+    // Do work while we are the leader
     leader
-        .acquire_and_run({
-            move |token| {
-                let leader_id = leader_id.clone();
-
-                async move {
-                    loop {
-                        if token.is_cancelled() {
-                            return Ok(());
-                        }
-
-                        tracing::info!(leader_id, "do work as leader");
-                        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
-                    }
+        .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(())
 }
 ```

crates/noleader/Cargo.toml

@@ -1,12 +1,7 @@
 [package]
 name = "noleader"
-edition = "2024"
-readme = "../../README.md"
-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"
+version = "0.1.0"
+edition = "2021"
 
 [dependencies]
 anyhow.workspace = true

renovate.json

@@ -1,3 +0,0 @@
-{
-  "$schema": "https://docs.renovatebot.com/renovate-schema.json"
-}