pub struct DispatcherConfig {
pub max_drain_per_cycle: usize,
pub idle_sleep: Duration,
pub spin_iterations: usize,
pub batch_by_source: bool,
pub max_batch_per_source: usize,
}Expand description
Configuration for the SubscriptionDispatcher.
Fields§
§max_drain_per_cycle: usizeMaximum notifications to drain per poll cycle.
idle_sleep: DurationIdle sleep duration when no notifications are available.
spin_iterations: usizeNumber of spin iterations before yielding on idle.
batch_by_source: boolWhether to batch notifications by source before dispatch.
max_batch_per_source: usizeMaximum batch size per source per cycle.
Trait Implementations§
Source§impl Clone for DispatcherConfig
impl Clone for DispatcherConfig
Source§fn clone(&self) -> DispatcherConfig
fn clone(&self) -> DispatcherConfig
Returns a duplicate of the value. Read more
1.0.0 · 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 DispatcherConfig
impl Debug for DispatcherConfig
Auto Trait Implementations§
impl Freeze for DispatcherConfig
impl RefUnwindSafe for DispatcherConfig
impl Send for DispatcherConfig
impl Sync for DispatcherConfig
impl Unpin for DispatcherConfig
impl UnwindSafe for DispatcherConfig
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
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> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.