fix(max)!: make max optional, change meaning of 0

Signed-off-by: Brooks Townsend <brooksmtownsend@gmail.com>

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "wasmcloud-control-interface"
-version = "0.29.0"
+version = "0.29.1"
 authors = ["wasmCloud Team"]
 edition = "2021"
 homepage = "https://wasmcloud.com"

src/lib.rs

@@ -296,8 +296,9 @@ impl<T: KvStore + Clone + Debug + Send + Sync> Client<T> {
         count: u16,
         annotations: Option<HashMap<String, String>>,
     ) -> Result<CtlOperationAck> {
-        self.scale_actor(host_id, actor_ref, count, annotations)
-            .await
+        // It makes no logical sense to start 0 actors, so we represent that as an unbounded max instead.
+        let max = if count == 0 { None } else { Some(count) };
+        self.scale_actor(host_id, actor_ref, max, annotations).await
     }
 
     /// Sends a request to the given host to scale a given actor. This returns an acknowledgement of
@@ -311,14 +312,15 @@ impl<T: KvStore + Clone + Debug + Send + Sync> Client<T> {
     /// # Arguments
     /// `host_id`: The ID of the host to scale the actor on
     /// `actor_ref`: The OCI reference of the actor to scale
-    /// `max_concurrent`: The maximum number of instances this actor can run concurrently. Setting this value to 0 means there is no maximum.
+    /// `max_concurrent`: The maximum number of requests this actor handle run concurrently. `None` represents an unbounded
+    /// level of concurrency while `0` will stop the actor.
     /// `annotations`: Optional annotations to apply to the actor
     #[instrument(level = "debug", skip_all)]
     pub async fn scale_actor(
         &self,
         host_id: &str,
         actor_ref: &str,
-        max_concurrent: u16,
+        max_concurrent: Option<u16>,
         annotations: Option<HashMap<String, String>>,
     ) -> Result<CtlOperationAck> {
         let subject =

src/types.rs

@@ -244,11 +244,11 @@ pub struct ScaleActorCommand {
     /// example, autonomous agents may wish to "tag" scale requests as part of a given deployment
     #[serde(default, skip_serializing_if = "Option::is_none")]
     pub annotations: Option<AnnotationMap>,
-    /// The maximum number of concurrent executing instances of this actor. If omitted or set to
-    /// zero there is no maximum.
+    /// The maximum number of concurrent executing instances of this actor. If set to `None` there
+    /// there is no maximum, while setting to `0` will stop the actor.
     // NOTE: renaming to `count` lets us remain backwards compatible for a few minor versions
     #[serde(default, alias = "count", rename = "count")]
-    pub max_concurrent: u16,
+    pub max_concurrent: Option<u16>,
     /// Host ID on which to scale this actor
     #[serde(default)]
     pub host_id: String,