Struct splinter::peer::PeerManagerBuilder
source · [−]pub struct PeerManagerBuilder { /* private fields */ }
Implementations
sourceimpl PeerManagerBuilder
impl PeerManagerBuilder
Constructs new PeerManager
instances.
This builder is used to construct new PeerManager
instances. The PeerManager
requires
a Connector
to request connections from the ConnectionManageer
and the unique ID of the
node this PeerManager
is for. It also has several optional configuration values, such as
max_retry_attempts and retry_interval.
sourcepub fn with_connector(self, connector: Connector) -> Self
pub fn with_connector(self, connector: Connector) -> Self
Set the connector instance to use with the resulting PeerManager
.
This is the Connector
to the ConnectionManager
that will handle the connections
requested by the PeerManager
.
sourcepub fn with_max_retry_attempts(self, max_retry_attempts: u64) -> Self
pub fn with_max_retry_attempts(self, max_retry_attempts: u64) -> Self
Set the max_retry_attempts instance to use with the resulting PeerManager
.
The number of retry attempts for an active endpoint before the
PeerManager
will try other endpoints associated with a peer
sourcepub fn with_retry_interval(self, retry_interval: u64) -> Self
pub fn with_retry_interval(self, retry_interval: u64) -> Self
Set the retry_interval to use with the resulting PeerManager
.
How often (in seconds) the Pacemaker
should notify the PeerManager
to retry pending peers.
sourcepub fn with_retry_frequency(self, retry_frequency: u64) -> Self
pub fn with_retry_frequency(self, retry_frequency: u64) -> Self
Set the initial retry_frequency to use with the resulting PeerManager
.
How often (in seconds) the PeerManager
will wait before retrying a pending
peer’s endpoints
sourcepub fn with_max_retry_frequency(self, retry_frequency: u64) -> Self
pub fn with_max_retry_frequency(self, retry_frequency: u64) -> Self
Set the max_retry_frequency to use with the resulting PeerManager
.
The maximum time (in seconds) the PeerManager
will wait before retrying a pending
peer’s endpoints
sourcepub fn with_endpoint_retry_frequency(self, retry_frequency: u64) -> Self
pub fn with_endpoint_retry_frequency(self, retry_frequency: u64) -> Self
Set the initial endpoint_retry_frequency to use with the resulting PeerManager
.
How often (in seconds) the PeerManager
will wait before retrying a pending
requested endpoint that does not have an ID
sourcepub fn with_identity(self, identity: String) -> Self
pub fn with_identity(self, identity: String) -> Self
Set the identity to use with the resulting PeerManager
.
The unique ID of the node this PeerManager
belongs to.
sourcepub fn with_strict_ref_counts(self, strict_ref_counts: bool) -> Self
pub fn with_strict_ref_counts(self, strict_ref_counts: bool) -> Self
Set strict_ref_counts in the the resulting PeerManager
.
Determines whether or not to panic when attempting to remove a reference to a peer that is not referenced.
sourcepub fn start(&mut self) -> Result<PeerManager, PeerManagerError>
pub fn start(&mut self) -> Result<PeerManager, PeerManagerError>
Starts the PeerManager
Starts up a thread that will handle incoming requests to add, remove and get peers. Also
handles notifications from the ConnectionManager
.
Returns a PeerManagerConnector
that can be used to send requests to the PeerManager
.
Trait Implementations
sourceimpl Default for PeerManagerBuilder
impl Default for PeerManagerBuilder
sourcefn default() -> PeerManagerBuilder
fn default() -> PeerManagerBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl !RefUnwindSafe for PeerManagerBuilder
impl Send for PeerManagerBuilder
impl !Sync for PeerManagerBuilder
impl Unpin for PeerManagerBuilder
impl !UnwindSafe for PeerManagerBuilder
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<P, N> IntoBytes<P> for N where
P: Message + FromNative<N>,
impl<P, N> IntoBytes<P> for N where
P: Message + FromNative<N>,
fn into_bytes(self) -> Result<Vec<u8, Global>, ProtoConversionError>
sourceimpl<N, P> IntoNative<N> for P where
N: FromProto<P>,
impl<N, P> IntoNative<N> for P where
N: FromProto<P>,
fn into_native(self) -> Result<N, ProtoConversionError>
sourceimpl<N, P> IntoProto<P> for N where
P: FromNative<N>,
impl<N, P> IntoProto<P> for N where
P: FromNative<N>,
fn into_proto(self) -> Result<P, ProtoConversionError>
sourceimpl<T> IntoSql for T
impl<T> IntoSql for T
sourcefn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
fn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
Convert self
to an expression for Diesel’s query builder. Read more
sourcefn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
Convert &self
to an expression for Diesel’s query builder. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more