Struct JsonRpcConnectionOptions 

pub struct JsonRpcConnectionOptions {
    pub request_timeout: Option<Duration>,
    pub outbound_capacity: usize,
    pub observer: Option<Arc<dyn CorsaObserver>>,
}

Runtime policy applied to a JsonRpcConnection.

Fields

request_timeout: Option<Duration>

Maximum time to wait for a response before surfacing a timeout.

outbound_capacity: usize

Maximum number of queued outbound messages waiting on the writer thread.

observer: Option<Arc<dyn CorsaObserver>>

Optional observer for structured transport events.

Implementations

impl JsonRpcConnectionOptions

pub fn new() -> JsonRpcConnectionOptions

Creates the default production-oriented JSON-RPC transport policy.

pub fn with_request_timeout( self, timeout: Option<Duration>, ) -> JsonRpcConnectionOptions

Sets the per-request timeout.

pub fn with_outbound_capacity(self, capacity: usize) -> JsonRpcConnectionOptions

Sets the maximum number of queued outbound messages.

pub fn with_observer( self, observer: Arc<dyn CorsaObserver>, ) -> JsonRpcConnectionOptions

Sets the observer used for structured transport events.

pub fn with_observer_if_some( self, observer: Option<Arc<dyn CorsaObserver>>, ) -> JsonRpcConnectionOptions

Sets the observer when one is available.

Trait Implementations

impl Clone for JsonRpcConnectionOptions

fn clone(&self) -> JsonRpcConnectionOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonRpcConnectionOptions

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

Formats the value using the given formatter.

impl Default for JsonRpcConnectionOptions

fn default() -> JsonRpcConnectionOptions

Returns the “default value” for a type.