Struct BootFlowTaskManager 

pub struct BootFlowTaskManager { /* private fields */ }

A3S Boot-backed task manager for Flow scheduler and callback dispatch.

Boot owns queue processors, worker lifecycle, leasing, job state, and shutdown. Flow owns only task serialization and engine handling semantics.

Implementations

impl BootFlowTaskManager

pub fn new(engine: FlowEngine, queue: Arc<Queue>) -> Self

Creates a manager for one engine and Boot queue.

pub fn with_job_name(self, job_name: impl Into<String>) -> Result<Self>

Replaces the Boot processor job name.

pub fn with_task_policy(self, task_policy: BootFlowTaskPolicy) -> Result<Self>

Replaces and validates the shared task policy.

pub fn engine(&self) -> &FlowEngine

Returns the Flow engine used by the registered processor.

pub fn queue(&self) -> Arc<Queue>

Returns the backing Boot queue.

pub fn job_name(&self) -> &str

Returns the registered Boot job name.

pub fn task_policy(&self) -> &BootFlowTaskPolicy

Returns the shared Flow task policy.

pub fn job_options_for(&self, task: &FlowTask) -> QueueJobOptions

Build the concrete Boot options that this manager will use for task.

Hosts can add a caller-assigned job ID or other one-off Boot option and pass the result to Self::enqueue_with_options.

pub fn register(&self) -> Result<()>

Register the Flow task processor with the Boot queue.

The host still starts and stops the queue through QueueModule or the corresponding Queue::start and Queue::shutdown lifecycle calls.

pub async fn enqueue_with_receipt( &self, task: FlowTask, ) -> Result<QueueJobReceipt>

Enqueues one task and returns its Boot job receipt.

pub async fn enqueue_with_options( &self, task: FlowTask, options: QueueJobOptions, ) -> Result<QueueJobReceipt>

Enqueue one task with explicit typed A3S Boot job options.

This per-submission entrypoint supports caller-assigned job IDs and the complete QueueJobOptions surface. Scheduler dispatch through FlowTaskDispatcher uses this manager’s BootFlowTaskPolicy.

Trait Implementations

impl Clone for BootFlowTaskManager

fn clone(&self) -> BootFlowTaskManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BootFlowTaskManager

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

Formats the value using the given formatter.

impl FlowTaskDispatcher for BootFlowTaskManager

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,

Dispatches one Flow task to the configured execution route.

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

Return whether this dispatcher has an explicit compatible route.

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

Fail before dispatch when no compatible route is registered.

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.