run_kv_v1_single_ring_supervised_until_stop

Function run_kv_v1_single_ring_supervised_until_stop 

Source
pub fn run_kv_v1_single_ring_supervised_until_stop(
    spec_path: &Path,
    lane_path: PathBuf,
    wait: WaitPreset,
    stop: Arc<AtomicBool>,
) -> Result<(), String>
Expand description

Run a long-lived v1 SingleRing runtime until stop is set.

Supervision policy (v1): if any stage thread exits unexpectedly, request stop and return an error after joining.