Struct ConcreteQueryService 

pub struct ConcreteQueryService { /* private fields */ }

Delegated query service for resident workflow processes.

The engine resolves the live (workflow, run) handle; this service rejects suspended residency (AT-007: never resume a workflow solely to answer a query) and terminal runs, then dispatches run-exact through the AT QueryService over the engine’s query mailbox seam. Nothing on this path records events.

Implementations

impl ConcreteQueryService

pub fn new( mailbox_engine: Arc<dyn EngineHandle>, query_timeout: Duration, ) -> Self

Create a query service over the engine’s query mailbox seam with the engine-configured reply timeout.

Trait Implementations

impl QueryService for ConcreteQueryService

fn query<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 WorkflowHandle, name: String, ) -> Pin<Box<dyn Future<Output = Result<Payload, EngineError>> + Send + 'async_trait>>

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

Dispatch a named query to the already-resolved workflow target.