pub struct DispatcherBuilder { /* private fields */ }Expand description
Builder for DequeDispatcher.
Implementations§
Source§impl DispatcherBuilder
impl DispatcherBuilder
Sourcepub fn with_chase_lev<P: AsRef<Path>>(
self,
path: P,
capacity: usize,
) -> Result<Self>
pub fn with_chase_lev<P: AsRef<Path>>( self, path: P, capacity: usize, ) -> Result<Self>
Create + attach a Chase-Lev deque at path with capacity
slots (round up to next power of two).
Sourcepub fn with_khpd<P: AsRef<Path>>(self, path: P, capacity: usize) -> Result<Self>
pub fn with_khpd<P: AsRef<Path>>(self, path: P, capacity: usize) -> Result<Self>
Create + attach a KHPD at path with capacity publication
lines.
Sourcepub fn with_loh<P: AsRef<Path>>(
self,
path: P,
capacity: usize,
flush_threshold: usize,
) -> Result<Self>
pub fn with_loh<P: AsRef<Path>>( self, path: P, capacity: usize, flush_threshold: usize, ) -> Result<Self>
Create + attach a LOH at path with capacity ring slots
and flush_threshold LIFO auto-flush threshold.
Sourcepub fn with_urd<P: AsRef<Path>>(
self,
path: P,
n_mailboxes: usize,
) -> Result<Self>
pub fn with_urd<P: AsRef<Path>>( self, path: P, n_mailboxes: usize, ) -> Result<Self>
Create + attach a URD at path with n_mailboxes mailboxes
(one per intended thief).
Sourcepub fn with_khl<P: AsRef<Path>>(self, path: P, capacity: usize) -> Result<Self>
pub fn with_khl<P: AsRef<Path>>(self, path: P, capacity: usize) -> Result<Self>
Create + attach a KHL (K-axis Hierarchical LCRQ - the
SubEtha-native hybrid) at path with capacity slots. Total
item capacity is capacity * 3.
Sourcepub fn build(self) -> DequeDispatcher
pub fn build(self) -> DequeDispatcher
Finalize the dispatcher.
Auto Trait Implementations§
impl !RefUnwindSafe for DispatcherBuilder
impl !UnwindSafe for DispatcherBuilder
impl Freeze for DispatcherBuilder
impl Send for DispatcherBuilder
impl Sync for DispatcherBuilder
impl Unpin for DispatcherBuilder
impl UnsafeUnpin for DispatcherBuilder
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