Struct UdsRelay 

pub struct UdsRelay { /* private fields */ }

Console’s UDS client for one target.

Why: the dial half of ADR-0034’s relay. Since #5182 it can also START the target: with a supervisor attached it calls ensure_running before writing the frame, which is what lets the target stay non-resident. Without one it dials whatever is already at the path, which is what the tests and any externally-managed deployment want. What: a socket path, a timeout, and an optional supervisor. Cheap to clone; opens a fresh connection per delivery, matching every other UDS client in this workspace. Test: relay_* cases in webhook/tests.rs.

Implementations

impl UdsRelay

pub fn new(socket: impl Into<PathBuf>) -> Self

Target socket with DEFAULT_RELAY_TIMEOUT and no supervision.

pub fn with_supervisor( self, source: impl Into<String>, supervisor: SharedSupervisor, ) -> Self

Start the target on demand, under supervisor, keyed by source.

Test: relay_with_a_supervisor_still_acks_against_a_live_target, spawn_adopts_a_socket_that_is_already_served.

pub fn with_timeout(self, timeout: Duration) -> Self

Override the round-trip budget.

pub fn socket(&self) -> &Path

Socket this relay dials.

pub fn timeout(&self) -> Duration

Round-trip budget, which is also the sweep’s hands-off grace period for an entry the request path may still be relaying.

pub async fn deliver(&self, entry: &SpoolEntry) -> RelayOutcome

Send one delivery and classify the answer.

Why: the classification is the whole safety property. Anything other than an explicit "ack": true leaves the entry pending, so a target that accepts a connection and then crashes, or answers with an empty object, does not cause the delivery to be dropped.

What: dials through the hardened UDS entry point, writes one frame, reads one frame, and defers the ack decision to RelayResponse::is_ack so both halves of the contract agree on it. A JSON-RPC error or a non-ack result is RelayOutcome::Refused; any transport failure is RelayOutcome::Unreachable.

Never returns Err: every failure is a first-class outcome the caller must record durably, and an error return invites the let _ = ADR-0034 §2 forbids.

Test: relay_acked_response_is_the_only_ack, relay_treats_a_result_without_ack_as_refused, relay_treats_a_jsonrpc_error_as_refused, relay_reports_unreachable_when_no_listener_is_bound, relay_reports_unreachable_when_the_target_hangs_up_without_answering.

Trait Implementations

impl Clone for UdsRelay

fn clone(&self) -> UdsRelay

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UdsRelay

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

Formats the value using the given formatter.