pub struct LoadedGroup {
pub name: Vec<u8>,
pub last_delivered: (u64, u64),
pub consumers: Vec<(Vec<u8>, u64)>,
pub pel: Vec<LoadedPelEntry>,
}Expand description
One consumer group decoded into primitive tuples — the dump/load wire form shared by snapshot v4, AOF-rewrite filtering, and reshard’s in-memory redistribution.
Fields§
§name: Vec<u8>Group name.
last_delivered: (u64, u64)last_delivered_id as (ms, seq).
consumers: Vec<(Vec<u8>, u64)>(name, last_seen_ms) per known consumer. pel_count is
recomputed from pel on import.
pel: Vec<LoadedPelEntry>Every PEL row, including tombstones (entries XDEL’d while pending) — snapshot keeps those; AOF rewrite filters them.
Auto Trait Implementations§
impl Freeze for LoadedGroup
impl RefUnwindSafe for LoadedGroup
impl Send for LoadedGroup
impl Sync for LoadedGroup
impl Unpin for LoadedGroup
impl UnsafeUnpin for LoadedGroup
impl UnwindSafe for LoadedGroup
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more