[−][src]Struct dbq::WorkerPoolConfig
Configuration options for creating a WorkerPool. See WorkerPool
documentation for examples
Methods
impl<H> WorkerPoolConfig<H>[src]
pub fn new<C: IntoConnectParams>(
queue: Queue,
db_connect_params: C,
handler: H
) -> Result<WorkerPoolConfig<H>>[src]
queue: Queue,
db_connect_params: C,
handler: H
) -> Result<WorkerPoolConfig<H>>
Createa a new WorkerPoolConfig that consumes work from the provided
queue and runs it on the provided Handler. By default, the number of
workers in the WorkerPool is configured to be the number of logical
cores
pub fn set_worker_poll_interval(&mut self, interval: Duration)[src]
Set the interval between polls for jobs to run.
pub fn set_num_workers(&mut self, size: usize)[src]
Set the configured number of workers in the WorkerPool
Trait Implementations
impl<H: Clone> Clone for WorkerPoolConfig<H>[src]
fn clone(&self) -> WorkerPoolConfig<H>[src]
default fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl<H> Send for WorkerPoolConfig<H> where
H: Send,
H: Send,
impl<H> Sync for WorkerPoolConfig<H> where
H: Sync,
H: Sync,
Blanket Implementations
impl<T, U> Into for T where
U: From<T>, [src]
U: From<T>,
impl<T> From for T[src]
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
impl<T, U> TryFrom for T where
U: Into<T>, [src]
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>[src]
impl<T> Borrow for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T, U> TryInto for T where
U: TryFrom<T>, [src]
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>[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Same for T
type Output = T
Should always be Self