Struct CoordinatorScript 

pub struct CoordinatorScript { /* private fields */ }

👎Deprecated since 0.3.0:

removed in v0.4.0, where a work feed replaces split coordination; see https://github.com/spate-etl/spate/issues/1088

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 final_commits(&self) -> Vec<Vec<(SplitId, SplitProgress)>>

Each final commit batch the source sent, in order.

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

The last successful commit for split, if any.

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

Script the outcome of the next fail for split (repeat to script a sequence). Unscripted reports succeed. Every attempt is recorded by failed, refused or not.

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

Every fail report attempt so far, in order, with the epoch of the tenancy it reported.

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

Every released split so far, in release order.

pub fn departed(&self) -> bool

Whether depart ran. Its held splits are also in released.

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 to test a source’s planner and its driver choreography together.

Trait Implementations

impl Clone for CoordinatorScript

fn clone(&self) -> Self

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.