Struct FakeDispatcher 

pub struct FakeDispatcher { /* private fields */ }

An in-process Dispatcher that answers from an axum Router, so a module can be exercised through a sidecar mount without a network or a second Worker (ADR 0009). The conformance kit uses it to run the same assertions against both mounts (#64).

Also the failure fixture: unbound has no binding at all, and failing accepts the binding and then refuses to answer.

Implementations

impl FakeDispatcher

pub fn serving(binding: impl Into<String>, router: Router) -> Self

Serves router on binding.

pub fn unbound() -> Self

Has no bindings, so has() is always false: the “mounted but this deployment has no such binding” case.

pub fn failing(binding: impl Into<String>, reason: impl Into<String>) -> Self

Accepts binding and then fails to answer.

pub fn calls(&self) -> usize

How many dispatches were attempted. A forwarder must not retry, so a single request must leave this at one.

Trait Implementations

impl Clone for FakeDispatcher

fn clone(&self) -> FakeDispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Dispatcher for FakeDispatcher

fn has(&self, binding: &str) -> bool

Whether a binding of this name exists. Cheap; called per request before dispatching so a missing binding degrades one prefix rather than surfacing as a transport error.

fn dispatch<'life0, 'life1, 'async_trait>( &'life0 self, binding: &'life1 str, request: Request<Bytes>, ) -> Pin<Box<dyn Future<Output = Result<Response<Bytes>, DispatchError>> + Send + 'async_trait>>

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

Forward request to the bound Worker and return its response unaltered. Implementations must not retry: a sidecar call is inside the caller’s request, and a retry would double any side effect.