Struct CoordinatorScript 

pub struct CoordinatorScript { /* private fields */ }

Scripting and observation handle for a ScriptedCoordinator.

Events queued between two poll calls are delivered as one batch, matching the trait contract (“all pending events at once”) — queue a lose and a gain back to back to exercise same-batch interleavings.

Implementations

impl CoordinatorScript

pub fn gain( &self, split: SplitSpec, epoch: u64, progress: Option<SplitProgress>, )

Queue a CoordinationEvent::Gained for the next poll.

pub fn lose(&self, split: &SplitId)

Queue a CoordinationEvent::Lost for the next poll.

pub fn quarantine(&self, split: &SplitId, attempts: u32)

Queue a CoordinationEvent::Quarantined for the next poll.

pub fn all_complete(&self)

Queue CoordinationEvent::AllComplete for the next poll.

pub fn stalled(&self, completed: u64, quarantined: u64)

Queue CoordinationEvent::Stalled for the next poll.

pub fn fail_next_commit(&self, split: &SplitId, kind: CoordinationErrorKind)

Script the outcome of the next commit for split (repeat to script a sequence). Unscripted commits succeed and are recorded.

pub fn commits(&self) -> Vec<(SplitId, SplitProgress)>

Every successful commit so far, in order.

pub fn last_commit(&self, split: &SplitId) -> Option<SplitProgress>

The last successful commit for split, if any.

pub fn failed(&self) -> Vec<(SplitId, String)>

Every fail report so far, in order.

pub fn released(&self) -> Vec<SplitId>

Every released split so far, in release order.

pub fn started(&self) -> bool

Whether start ran.

pub fn take_planner(&self) -> Option<Box<dyn SplitPlanner>>

Take the planner captured at start: run it directly to inspect its plan, then feed the resulting splits back through gain — this is how a source tests its planner and its driver choreography together.

Trait Implementations

impl Clone for CoordinatorScript

fn clone(&self) -> CoordinatorScript

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CoordinatorScript

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.