Struct PoolOptions

Source

pub struct PoolOptions {
    pub link_selection: LinkSelection,
    pub station_discovery: StationDiscoveryOptions,
    pub respawn_delay: Duration,
    pub call_timeout: Duration,
    pub replication_factor: usize,
}

Expand description

Tunables for Pool. Defaults match every other port of this feature.

Fields§

§link_selection: LinkSelection§station_discovery: StationDiscoveryOptions§respawn_delay: Duration

Flat delay before redialing a link after it dies (or fails to dial in the first place). Default 1s — flat, not exponential, matching the reference and every other port in this SDK family except ts.

§call_timeout: Duration

Per-CALL timeout, passed through to Session::call. Default matches connection::DEFAULT_CALL_TIMEOUT.

§replication_factor: usize

How many currently-connected links a single publish fans out to. Partial success counts as success. Default 1, matching macula-ts and macula-dotnet’s own ReplicationFactor default.

PoolOptions

Struct PoolOptions Copy item path

Fields§

Trait Implementations§

impl Clone for PoolOptions

fn clone(&self) -> PoolOptions

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

impl Debug for PoolOptions

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

impl Default for PoolOptions

fn default() -> Self

Auto Trait Implementations§

impl Freeze for PoolOptions

impl RefUnwindSafe for PoolOptions

impl Send for PoolOptions

impl Sync for PoolOptions

impl Unpin for PoolOptions

impl UnsafeUnpin for PoolOptions

impl UnwindSafe for PoolOptions

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> NoneValue for Twhere T: Default,

type NoneType = T

fn null_value() -> T

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

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

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct PoolOptions

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

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> NoneValue for T
where T: Default,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,