Struct ManagerConfig

pub struct ManagerConfig {
    pub group: Cow<'static, str>,
    pub consumer: Cow<'static, str>,
    pub kind: ConsumerKind,
    pub poll_time: Duration,
    pub max_pending_time: Duration,
}

Manager configuration.

Fields

group: Cow<'static, str>

Group name

All tasks will belong to this group

consumer: Cow<'static, str>

Consumer name

All tasks managed will be claimed by this consumer

kind: ConsumerKind

Consumer kind

poll_time: Duration

Blocking time while awaiting for new messages.

max_pending_time: Duration

Duration for which tasks are allowed to remain in queue in order to retry it later.

Once tasks expires over this time, it shall be deleted from queue.

Trait Implementations

impl Clone for ManagerConfig

fn clone(&self) -> ManagerConfig

Returns a copy of the value.

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

Performs copy-assignment from source.