[−][src]Struct fibers_rpc::client::Options

pub struct Options {
    pub timeout: Option<Duration>,
    pub max_queue_len: Option<u64>,
    pub priority: u8,
    pub force_wakeup: bool,
}

Options for RPC.

Fields

timeout: Option<Duration>

The timeout of a RPC request.

The default value is None and it means there is no timeout.

This is no effect on notification RPC.

max_queue_len: Option<u64>

The allowable number of messages in the transmit queue.

If the current queue length exceeds this value, the new message will be discarded before sending.

The default value is None and it means there is no limitation.

priority: u8

The priority of the RPC invocation.

The lower the value, the higher the priority.

The default value is 128.

force_wakeup: bool

If it is true, RPC channel waiting for reconnecting will wake up immediately.

The default value is false.

Methods

impl Options[src]

pub const DEFAULT_PRIORITY: u8[src]

The default priority.

Trait Implementations

impl Clone for Options[src]

fn clone_from(&mut self, source: &Self)
1.0.0
[src]

Performs copy-assignment from source. Read more

impl Default for Options[src]

impl Debug for Options[src]

Auto Trait Implementations

impl Send for Options

impl Sync for Options

Blanket Implementations

impl<T, U> Into for T where
    U: From<T>, [src]

impl<T> ToOwned for T where
    T: Clone, [src]

type Owned = T

impl<T> From for T[src]

impl<T, U> TryFrom for T where
    U: Into<T>, [src]

type Error = !

🔬 This is a nightly-only experimental API. (try_from)

The type returned in the event of a conversion error.

impl<T> Borrow for T where
    T: ?Sized, [src]

impl<T, U> TryInto for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

🔬 This is a nightly-only experimental API. (try_from)

The type returned in the event of a conversion error.

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> BorrowMut for T where
    T: ?Sized, [src]

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized, [src]