Update supervisor config schema, docs, and validation tests

- Harmonize supervisor YAML config examples and configuration docs
- Extend config schema handling in src/config and src/spec
- Add/refresh config validation and docs sync tests

Author: developerworks

examples/config/split/supervisor.yaml

@@ -7,6 +7,8 @@ include:
 
 supervisor:
   strategy: OneForAll
+  control_channel_capacity: 256
+  event_channel_capacity: 256
 
 policy:
   child_restart_limit: 10

examples/config/supervisor.local.yaml

@@ -1,6 +1,8 @@
 supervisor:
   strategy: OneForAll
   escalation_policy: escalate_to_parent
+  control_channel_capacity: 256
+  event_channel_capacity: 256
   dynamic_supervisor:
     enabled: true
     child_limit: 16

examples/config/supervisor.template.yaml

@@ -8,9 +8,18 @@ supervisor:
   # Restart scope strategy for child failures.
   strategy: OneForAll
 
-  # Optional supervisor-level escalation policy.
+  # Optional fallback escalation policy used when child and group policies do
+  # not define a more specific policy.
   escalation_policy: escalate_to_parent
 
+  # Control command channel capacity.
+  # Recommended default: 256
+  control_channel_capacity: 256
+
+  # Event broadcast channel capacity.
+  # Recommended default: 256
+  event_channel_capacity: 256
+
   # Runtime dynamic child acceptance policy.
   dynamic_supervisor:
     enabled: true

examples/config/supervisor.yaml

@@ -1,6 +1,8 @@
 supervisor:
   strategy: OneForAll
   escalation_policy: escalate_to_parent
+  control_channel_capacity: 256
+  event_channel_capacity: 256
   dynamic_supervisor:
     enabled: true
     child_limit: 16

manual/en/configuration.md

@@ -105,6 +105,8 @@ IPC checks (when `dashboard.enabled = true`):
 supervisor:
   strategy: OneForAll
   escalation_policy: escalate_to_parent
+  control_channel_capacity: 256
+  event_channel_capacity: 256
   dynamic_supervisor:
     enabled: true
     child_limit: 16

manual/zh/configuration.md

@@ -105,6 +105,8 @@ IPC(进程间通信)检查(当 `dashboard.enabled = true` 时):
 supervisor:
   strategy: OneForAll
   escalation_policy: escalate_to_parent
+  control_channel_capacity: 256
+  event_channel_capacity: 256
   dynamic_supervisor:
     enabled: true
     child_limit: 16

src/config/configurable.rs

@@ -21,7 +21,9 @@ use crate::{
     },
     spec::{
         child_declaration::ChildrenConfigSection,
-        supervisor::{BackpressureConfig, EscalationPolicy, SupervisionStrategy},
+        supervisor::{
+            BackpressureConfig, EscalationPolicy, RECOMMENDED_CHANNEL_CAPACITY, SupervisionStrategy,
+        },
     },
 };
 
@@ -128,6 +130,20 @@ pub struct SupervisorRootConfig {
     #[schemars(!default)]
     #[serde(default)]
     pub escalation_policy: Option<EscalationPolicy>,
+    /// Control command channel capacity.
+    ///
+    /// Runtime capacity for queued supervisor control commands.
+    /// Recommended default: 256.
+    #[config(default = 256)]
+    #[serde(default = "default_channel_capacity")]
+    pub control_channel_capacity: usize,
+    /// Event broadcast channel capacity.
+    ///
+    /// Runtime capacity for supervisor event broadcast delivery.
+    /// Recommended default: 256.
+    #[config(default = 256)]
+    #[serde(default = "default_channel_capacity")]
+    pub event_channel_capacity: usize,
     /// Runtime dynamic child acceptance policy.
     #[config(nested)]
     #[serde(default)]
@@ -323,6 +339,11 @@ fn default_abort_wait_ms() -> u64 {
     1000
 }
 
+/// Returns the recommended channel capacity.
+fn default_channel_capacity() -> usize {
+    RECOMMENDED_CHANNEL_CAPACITY
+}
+
 /// Returns the default event journal capacity.
 fn default_event_journal_capacity() -> usize {
     256

src/config/state.rs

@@ -362,6 +362,8 @@ impl ConfigState {
     /// let yaml = r#"
     /// supervisor:
     ///   strategy: OneForAll
+    ///   control_channel_capacity: 256
+    ///   event_channel_capacity: 256
     /// policy:
     ///   child_restart_limit: 10
     ///   child_restart_window_ms: 60000
@@ -433,8 +435,8 @@ impl ConfigState {
         spec.config_version = self.config_version();
         spec.supervisor_failure_limit = self.policy.supervisor_failure_limit;
         spec.escalation_policy = self.supervisor.escalation_policy;
-        spec.control_channel_capacity = self.observability.event_journal_capacity;
-        spec.event_channel_capacity = self.observability.event_journal_capacity;
+        spec.control_channel_capacity = self.supervisor.control_channel_capacity;
+        spec.event_channel_capacity = self.supervisor.event_channel_capacity;
         spec.backpressure_config = self.backpressure.clone();
         let group_members = derive_group_members(&self.children);
         spec.group_configs = self
@@ -508,8 +510,10 @@ impl ConfigState {
     /// Returns a deterministic version string for diagnostics.
     fn config_version(&self) -> String {
         format!(
-            "supervisor-{:?}-policy-{}-{}-shutdown-{}-observe-{}-backpressure-{:?}-{}-{}",
+            "supervisor-{:?}-channels-{}-{}-policy-{}-{}-shutdown-{}-observe-{}-backpressure-{:?}-{}-{}",
             self.supervisor.strategy,
+            self.supervisor.control_channel_capacity,
+            self.supervisor.event_channel_capacity,
             self.policy.child_restart_limit,
             self.policy.supervisor_failure_limit,
             self.shutdown.graceful_timeout_ms,
@@ -662,6 +666,14 @@ fn validate_lower_policy(
 fn validate_supervisor_root(
     supervisor: &SupervisorRootConfig,
 ) -> Result<(), crate::error::types::SupervisorError> {
+    validate_positive(
+        supervisor.control_channel_capacity as u64,
+        "supervisor.control_channel_capacity",
+    )?;
+    validate_positive(
+        supervisor.event_channel_capacity as u64,
+        "supervisor.event_channel_capacity",
+    )?;
     if supervisor.dynamic_supervisor.child_limit == Some(0) {
         return Err(crate::error::types::SupervisorError::fatal_config(
             "supervisor.dynamic_supervisor.child_limit must be greater than zero",

src/config/tests/configurable_schema_test.rs

@@ -21,6 +21,8 @@ fn supervisor_config_generates_schema_for_all_public_fields() {
         "supervisor",
         "strategy",
         "escalation_policy",
+        "control_channel_capacity",
+        "event_channel_capacity",
         "dynamic_supervisor",
         "enabled",
         "child_limit",

src/config/tests/configurable_template_test.rs

@@ -99,6 +99,8 @@ fn generated_template_contains_all_runtime_tunables() {
     for field in [
         "strategy",
         "escalation_policy",
+        "control_channel_capacity",
+        "event_channel_capacity",
         "dynamic_supervisor",
         "enabled",
         "child_limit",
@@ -170,6 +172,8 @@ fn generated_template_writes_runtime_default_values() {
 
     for field in [
         "strategy: OneForAll",
+        "control_channel_capacity: 256",
+        "event_channel_capacity: 256",
         "child_restart_limit: 10",
         "child_restart_window_ms: 60000",
         "supervisor_failure_limit: 30",