Struct ClusterConfig

pub struct ClusterConfig {
    pub connection_timeout: u64,
    pub election_timeout: u64,
    pub update_interval: u64,
    pub max_node: NonZeroUsize,
    pub min_node: NonZeroUsize,
}

Expand description

Set cluster configurations

Fields§

§connection_timeout: u64

connection timeout in milliseconds between cluster nodes

§election_timeout: u64

Approximate interval in milliseconds between attempts to elect new leader node. Application will use a randomly chosen value between election_timeout and election_timeout*2

§update_interval: u64

Interval between discovery service call, in milliseconds

§max_node: NonZeroUsize

maximum number of allowed node in a cluster

§min_node: NonZeroUsize

minimum number of nodes required to create a cluster

Trait Implementations§

impl Default for ClusterConfig

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

impl Freeze for ClusterConfig

impl RefUnwindSafe for ClusterConfig

impl Send for ClusterConfig

impl Sync for ClusterConfig

impl Unpin for ClusterConfig

impl UnwindSafe for ClusterConfig

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

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

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

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

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more