List of all items

Structs

• Queue
• QueueConfig
• iters::FetchIter
• iters::PendingIter
• manager::Manager
• manager::ManagerConfig
• manager::RunParams
• manager::dispatch::TaskResult
• types::Entry
• types::EntryValue
• types::FetchEntries
• types::FetchParams
• types::FetchResult
• types::GroupInfo
• types::PendingConsumerStat
• types::PendingEntry
• types::PendingParams
• types::PendingStats
• types::Range
• types::StreamId
• types::TimestampId

Enums

• manager::ConfigError
• manager::ConsumerKind
• manager::dispatch::TaskResultKind
• types::FetchType
• types::RangeIdx
• types::StreamIdParseError
• types::TrimMethod

Traits

• manager::dispatch::Dispatch

Functions

• manager::manage
• manager::trim_queue_task
• utils::queue_trim_consumed