pub struct NodeSessionConfig {
pub agent_role: String,
pub transport: NodeSessionTransport,
pub reconnect_min_backoff: Duration,
pub reconnect_max_backoff: Duration,
pub request_timeout: Duration,
pub command_buffer: usize,
}Expand description
Configuration for DCP node sessions maintained by a cluster-aware agent.
Fields§
§agent_role: StringRole that marks a member as running a DCP agent endpoint.
transport: NodeSessionTransportNode-to-node DCP transport.
reconnect_min_backoff: DurationInitial reconnect backoff.
reconnect_max_backoff: DurationMaximum reconnect backoff.
request_timeout: DurationDefault per-peer fan-out timeout.
command_buffer: usizeBounded per-session command queue capacity.
Trait Implementations§
Source§impl Clone for NodeSessionConfig
impl Clone for NodeSessionConfig
Source§fn clone(&self) -> NodeSessionConfig
fn clone(&self) -> NodeSessionConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for NodeSessionConfig
impl Debug for NodeSessionConfig
Auto Trait Implementations§
impl !RefUnwindSafe for NodeSessionConfig
impl !UnwindSafe for NodeSessionConfig
impl Freeze for NodeSessionConfig
impl Send for NodeSessionConfig
impl Sync for NodeSessionConfig
impl Unpin for NodeSessionConfig
impl UnsafeUnpin for NodeSessionConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage