Struct DeclaredBodySource 

pub struct DeclaredBodySource { /* private fields */ }

Shared, install-once handle the dispatcher holds from construction and the boot path fills in once the engine exists.

Mirrors super::QueueDeclarationSource: the dispatcher is built before the engine, so the seam it consults is handed over afterwards through a clone of this handle rather than by rebuilding the dispatcher.

Implementations

impl DeclaredBodySource

pub fn install(&self, source: Arc<dyn DeclaredBodies>)

Install the reader. A second install is ignored and logged: the source is process-wide and must not silently change identity.

pub fn body_for( &self, task_queue: &str, action: &str, run: DispatchingRun<'_>, ) -> DeclaredBodyLookup

Look up the declared body, or DeclaredBodyLookup::None when no reader is installed yet — before the engine exists nothing has been deployed, so there is no body a dispatch could be missing.

Trait Implementations

impl Clone for DeclaredBodySource

fn clone(&self) -> DeclaredBodySource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeclaredBodySource

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

Formats the value using the given formatter.

impl Default for DeclaredBodySource

fn default() -> DeclaredBodySource

Returns the “default value” for a type.