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.

An uninstalled consult is stated at ERROR before delegating to the worker path, never silently: a dispatch can only reach this seam from a live run, and a live run’s deploy is durable — so “nothing installed yet” is a boot-ordering defect, not an empty catalog. This exact silence was #266 Defect A: startup recovery replay re-dispatched adopted in-flight declared-body activities before install_engine_backed_seams filled this source, and every one fell through here to a queue with no pollers and parked forever. The fix (deferred startup recovery) removes the caller; this arm stays loud so any future pre-install dispatch path names itself in the log instead of stranding runs silently.

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.