Add .is_healthy() method to the Opsqueue Consumer client

libs/opsqueue_python/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "opsqueue_python"
-version = "0.31.0"
+version = "0.32.0"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

opsqueue/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "opsqueue"
-version = "0.31.0"
+version = "0.32.0"
 edition = "2021"
 description = "lightweight batch processing queue for heavy loads"
 repository = "https://github.com/channable/opsqueue"

opsqueue/src/consumer/client.rs

@@ -123,8 +123,7 @@ impl OuterClient {
     }
 
     async fn ensure_initialized(&self) {
-        let inner = self.0.load();
-        if inner.is_none() || inner.as_ref().is_some_and(|c| !c.is_healthy()) {
+        if !self.is_healthy() {
             let client = self.initialize().await;
             self.0.store(Some(Arc::new(client)));
         }
@@ -138,6 +137,14 @@ impl OuterClient {
         .await
         .expect("Infinite retries should never return Err")
     }
+
+    /// When `false` is returned, the next call to the client will attempt to restore the connection.
+    ///
+    /// This function can be used to propagate healthiness info to a consumer service.
+    pub fn is_healthy(&self) -> bool {
+        let inner = self.0.load();
+        inner.as_ref().is_some_and(|c| c.is_healthy())
+    }
 }
 
 // TOOD: Set max retries to `None`;