Struct ScriptedCoordinator 

pub struct ScriptedCoordinator { /* 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

A SplitCoordinator whose events and outcomes are scripted by the paired CoordinatorScript. Build both with scripted_coordinator.

Trait Implementations

impl Debug for ScriptedCoordinator

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

Formats the value using the given formatter.

impl SplitCoordinator for ScriptedCoordinator

fn start( &mut self, planner: Box<dyn SplitPlanner>, ) -> Result<(), CoordinationError>

👎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

Join the job: verify the fingerprint, hand over this worker’s planner (used only if and while this instance is elected leader), and start the backend’s claim and renewal machinery. Called exactly once, before any other method.

fn set_waker(&mut self, waker: ControlWaker)

👎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

Hand the backend the handle it signals when it has events to deliver. Called once, before start.

fn poll(&mut self) -> Result<Vec<CoordinationEvent>, CoordinationError>

👎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

Ownership and job-state changes since the last call. Must not block; return whatever is pending, including nothing. The driver parks on the ControlWaker instead.

fn commit( &mut self, split: &SplitId, progress: &SplitProgress, ) -> Result<(), CoordinationError>

👎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

Fenced durable commit of one owned split’s progress. Ok means durable. Fenced means the split is no longer owned and nothing was written; stop the split and do not retry the write. Retryable means the write may or may not have been stored; either outcome is safe because a commit carries only acknowledged progress, and re-committing the merged progress later is idempotent.

fn commit_final( &mut self, commits: &[(SplitId, SplitProgress)], ) -> Vec<Result<(), CoordinationError>>

👎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

The last commit of a stop: one result per entry, in order, each with the meaning of a commit result.

fn fail( &mut self, split: &SplitId, epoch: LeaseEpoch, reason: &str, ) -> Result<(), CoordinationError>

👎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

Report an owned split as unprocessable by this tenancy: consumes one delivery attempt and releases it for another worker to retry. At the backend’s attempt cap the split is quarantined instead (CoordinationEvent::Quarantined). Use for poison input. For a transient local problem, release consumes no delivery attempts but may permanently leave the fleet when the last held split is handed back.

fn release(&mut self, splits: &[SplitId]) -> Result<(), CoordinationError>

👎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

Voluntarily hand back owned splits so peers claim them without waiting out a lease. Consumes no delivery attempts. Best-effort and idempotent; splits not released expire. Shutdown uses depart.

fn depart(&mut self, held: &[SplitId]) -> Result<(), CoordinationError>

👎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

Leave the job for good: hand back every held split, and any role or membership the backend keeps, so peers take over without waiting out a lease. The last call on a coordinator.

fn set_stop(&mut self, stop: StopSignal)

👎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

Hand the backend the run’s stop. While it is set, a command waiting on the store may return Retryable early and still land afterwards; commit_final ignores it. A coordinator that wraps another forwards it. The default ignores it.

fn release_drained( &mut self, splits: &[SplitId], ) -> Result<(), CoordinationError>

👎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

Release splits given up through a cooperative revocation. The owner has drained each split, committed its tail, and is handing it back. Semantically a release (attempt-free, best-effort, idempotent), but distinguished so a revocation-aware backend can record the drain as having completed and never mistake a single-split revocation for a departure from the fleet.

fn decline_revoke(&mut self, _split: &SplitId) -> Result<(), CoordinationError>

👎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

Decline a RevokeRequested the embedder cannot serve, because the source refused to stop the split’s intake or the split is not in a drainable state.