Struct ChangelogRowIdGenerator 

pub struct ChangelogRowIdGenerator {
    timestamp_mgr: TimestampManager,
    vnode_bit: u32,
    vnodes_sequence: HashMap<VirtualNode, u16>,
    vnodes: Bitmap,
}

ChangelogRowIdGenerator generates unique changelog row ids using snowflake algorithm. Unlike RowIdGenerator, it maintains a separate sequence for each vnode and generates row ids based on the input vnode.

Fields

timestamp_mgr: TimestampManager

Timestamp manager.

vnode_bit: u32

The number of bits used for vnode.

vnodes_sequence: HashMap<VirtualNode, u16>

Sequence for each vnode. Key is vnode index, value is sequence.

vnodes: Bitmap

Implementations

impl ChangelogRowIdGenerator

pub fn new(vnodes: Bitmap, vnode_count: usize) -> Self

Create a new ChangelogRowIdGenerator with given vnode count.

fn sequence_upper_bound(&self) -> u16

The upper bound of the sequence part for changelog, exclusive.

fn try_update_timestamp(&mut self)

fn next_changelog_row_id_in_current_timestamp( &mut self, vnode: &VirtualNode, ) -> Option<RowId>

pub fn next(&mut self, vnode: &VirtualNode) -> RowId

Trait Implementations

impl Debug for ChangelogRowIdGenerator

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

Formats the value using the given formatter.