Struct SingBoxOutboundAdapter 

pub struct SingBoxOutboundAdapter { /* private fields */ }

CoreScope-aware outbound inventory and selector adapter.

The controller has no revision/CAS endpoint. This adapter therefore serializes its own operations, compares a fresh /proxies observation with the expected local revision immediately before writes, verifies the active scope/version around HTTP calls, and accepts a write only after readback.

The probe asks the engine’s own delay endpoint for the measured latency of one outbound and reports the engine’s typed answer: a measurement, the engine’s timeout, a typed failure or the unsupported capability. The driver never invents a measurement the engine did not publish.

Implementations

impl SingBoxOutboundAdapter

pub fn new( api: SingBoxClashApiClient, scope_source: Arc<dyn CoreScopeSource>, ) -> Self

Creates the outbound adapter over one API client and scope source.

Trait Implementations

impl OutboundPort for SingBoxOutboundAdapter

fn inventory<'life0, 'async_trait>( &'life0 self, scope: CoreScope, ) -> Pin<Box<dyn Future<Output = Result<OutboundInventorySnapshot, PortError>> + Send + 'async_trait>>

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

Reads the current outbound inventory for one scope.

fn observation<'life0, 'async_trait>( &'life0 self, scope: CoreScope, ) -> Pin<Box<dyn Future<Output = Result<OutboundObservationSnapshot, PortError>> + Send + 'async_trait>>

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

Read inventory and details from one adapter observation cycle where supported. The default composes narrow reads and validates their fence.

fn details<'life0, 'async_trait>( &'life0 self, scope: CoreScope, expected_revision: SnapshotRevision, ) -> Pin<Box<dyn Future<Output = Result<OutboundDetailsSnapshot, PortError>> + Send + 'async_trait>>

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

Read details for the same inventory revision observed by the caller. Implementations that do not expose neutral details fail closed.

fn select<'life0, 'async_trait>( &'life0 self, scope: CoreScope, expected_revision: SnapshotRevision, collection_id: OutboundId, outbound_id: OutboundId, ) -> Pin<Box<dyn Future<Output = Result<OutboundInventorySnapshot, PortError>> + Send + 'async_trait>>

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

Select one member of one collection and return the new inventory.

fn probe<'life0, 'async_trait>( &'life0 self, scope: CoreScope, expected_revision: SnapshotRevision, outbound_id: OutboundId, request: OutboundProbeRequest, ) -> Pin<Box<dyn Future<Output = Result<OutboundProbeSnapshot, PortError>> + Send + 'async_trait>>

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

Probe one outbound and return the fenced probe snapshot.