Struct RuntimeBuildTaskRouter 

pub struct RuntimeBuildTaskRouter { /* private fields */ }

Routes pinned Flow tasks to dispatchers serving exact runtime builds.

A route can point at an A3S Boot manager, a compatibility queue, or another host dispatcher. Register the same dispatcher under every build it can execute. Unpinned histories require a separate explicit route.

Implementations

impl RuntimeBuildTaskRouter

pub fn new() -> Self

Create a router with no pinned or legacy routes.

pub fn with_route( self, runtime_build_id: RuntimeBuildId, dispatcher: Arc<dyn FlowTaskDispatcher>, ) -> Result<Self>

Register the only dispatcher used for an exact runtime build.

pub fn with_unpinned_route( self, dispatcher: Arc<dyn FlowTaskDispatcher>, ) -> Result<Self>

Register the explicit dispatcher for legacy unpinned histories.

pub fn runtime_build_ids(&self) -> impl Iterator<Item = &RuntimeBuildId>

Iterate over the exact pinned build routes.

pub fn has_unpinned_route(&self) -> bool

Return whether a legacy unpinned route is registered.

pub async fn dispatch_for_run( &self, engine: &FlowEngine, run_id: &str, task: FlowTask, ) -> Result<()>

Resolve the persisted build for run_id, verify the task target, and dispatch it through the matching route.

Trait Implementations

impl Clone for RuntimeBuildTaskRouter

fn clone(&self) -> RuntimeBuildTaskRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeBuildTaskRouter

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

Formats the value using the given formatter.

impl Default for RuntimeBuildTaskRouter

fn default() -> RuntimeBuildTaskRouter

Returns the “default value” for a type.

impl FlowTaskDispatcher for RuntimeBuildTaskRouter

fn dispatch<'life0, 'async_trait>( &'life0 self, task: FlowTask, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn has_runtime_build_route( &self, required_build_id: Option<&RuntimeBuildId>, ) -> bool

Return whether this dispatcher has an explicit compatible route.

fn dispatch_for_runtime_build<'life0, 'life1, 'async_trait>( &'life0 self, required_build_id: Option<&'life1 RuntimeBuildId>, task: FlowTask, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Dispatch to a route that explicitly serves required_build_id.

fn ensure_runtime_build_route( &self, required_build_id: Option<&RuntimeBuildId>, ) -> Result<()>

Fail before dispatch when no compatible route is registered.