Struct PendingParams

pub struct PendingParams<'a> {
    pub group: &'a str,
    pub range: Range,
    pub idle: Option<Duration>,
    pub consumer: Option<&'a str>,
    pub count: usize,
}

Parameters to fetch pending messages (fetched, but not consumed).

Fields

group: &'a str

Group name.

This is used as identifier of group of pending messages.

When message is successfully read, it is moved inside this group.

At any point user can XACK to confirm message is consumed and delete it.

Otherwise fetch it again (in case of crash or something similar)

range: Range

Range parameter

idle: Option<Duration>

IDLE time filter.

When used, filters out messages whose idle time LESS THAN specified duration.

consumer: Option<&'a str>

Optional filter by consumer name

count: usize

Number of messages to pick.