Config

Struct Config 

Source
pub struct Config {
    pub timeout: usize,
    pub redis_namespace: String,
    pub repeat_on_timeout: bool,
    pub retry_count_limit: u32,
    pub worker_count: usize,
    pub redis_url: String,
}
Expand description

Configuration options used throughout Robin.

The normal way to construct a Config is through the Default implementation. Afterwards you can tweak the values you need.

let mut config = Config::default();
config.worker_count = 10;

assert_eq!(config.worker_count, 10);
assert_eq!(config.timeout, 30);

Fields§

§timeout: usize

The number of seconds the worker will block while waiting for a new job to be enqueued. By default workers will retry after the timeout is hit, so you shouldn’t need to configure this.

§redis_namespace: String

Namespace used for all Redis values.

§repeat_on_timeout: bool

Whether or not to repeat looking for jobs when the timeout is hit. This defaults to true and should probably remain that way. This is used when testing Robin internally.

§retry_count_limit: u32

The maximum number of times a job will be retried. After that it will discarded.

§worker_count: usize

The number of worker threads to spawn. Each thread will have its own Redis connection, so make sure you have enough connections available. Defaults to the number of CPUs your machine has.

§redis_url: String

The URL that will be used to connect to Redis.

Trait Implementations§

Source§

impl Clone for Config

Source§

fn clone(&self) -> Config

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for Config

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for Config

Source§

fn default() -> Config

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl Freeze for Config

§

impl RefUnwindSafe for Config

§

impl Send for Config

§

impl Sync for Config

§

impl Unpin for Config

§

impl UnwindSafe for Config

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.