Struct FakeAdapter 

pub struct FakeAdapter { /* private fields */ }

In-memory PartnerAdapter for tests: records sent messages, plays a scripted incoming queue, and can fail sends on demand.

Clone shares state; keep a clone (or a FakeRecorder) to inspect sends after moving the adapter into a PartnerRouter.

Implementations

impl FakeAdapter

pub fn scripted(queue: Vec<IncomingMessage>) -> Self

A fake that plays the given messages, in order, on receive; once the queue drains, further receives time out.

pub fn failing_send(reason: impl Into<String>) -> Self

A fake whose every send fails at the transport.

pub fn failing_receive(reason: impl Into<String>) -> Self

A fake whose every receive fails at the transport, so a mid-scenario receive transport failure is expressible.

pub fn recorder(&self) -> FakeRecorder

A handle onto this fake’s recorded sends.

Trait Implementations

impl Clone for FakeAdapter

fn clone(&self) -> FakeAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PartnerAdapter for FakeAdapter

fn send<'a>( &'a self, lane_key: &'a str, _target_uri: &'a str, msg: OutgoingMessage, ) -> BoxFuture<'a, Result<Option<Exchange>, TransportError>>

Send a message to the target URI, parking any roundtrip under the lane key, and return the synchronous reply when the adapter produces one: the context-stimulus direct: send returns the routed exchange (Ok(Some(..))) so an expectReply assertion can read it (rc-qvz6); partner and fake adapters answer Ok(None). Adapters without a client role keep the default (a transport failure naming the gap); the http partner is one such adapter — the router’s own client lane performs every http client-role send.

fn receive<'a>( &'a self, _lane_key: &'a str, source_uri: &'a str, deadline: Duration, ) -> BoxFuture<'a, Result<IncomingMessage, ReceiveError>>

Receive a message from the source URI before the deadline passes. Implementations must respect the deadline; they never hang past it.

fn bound_authority(&self) -> Option<String>

The host:port authority this adapter’s listener bound, when it owns one (the http partner); None otherwise. The router uses it to resolve declared and dynamic endpoint references to real wire addresses.

fn set_secret_query_keys(&self, keys: &[String])

Stores the query keys classified secret (ADR-0051 positive secret rule) for the adapter’s diagnostic redaction; the router fans the set out from the booted context’s component metadata. Default noop: adapters without wire-path diagnostics render nothing to redact.