Struct resolved_ts::Resolver

pub struct Resolver {
    region_id: u64,
    locks_by_key: HashMap<Arc<[u8]>, TimeStamp>,
    lock_ts_heap: BTreeMap<TimeStamp, HashSet<Arc<[u8]>>>,
    resolved_ts: TimeStamp,
    tracked_index: u64,
    read_progress: Option<Arc<RegionReadProgress>>,
    min_ts: TimeStamp,
}

Fields

region_id: u64

locks_by_key: HashMap<Arc<[u8]>, TimeStamp>

lock_ts_heap: BTreeMap<TimeStamp, HashSet<Arc<[u8]>>>

resolved_ts: TimeStamp

tracked_index: u64

read_progress: Option<Arc<RegionReadProgress>>

min_ts: TimeStamp

Implementations

impl Resolver

pub fn new(region_id: u64) -> Resolver

pub fn with_read_progress(
    region_id: u64,
    read_progress: Option<Arc<RegionReadProgress>>
) -> Resolver

pub fn resolved_ts(&self) -> TimeStamp

pub fn locks(&self) -> &BTreeMap<TimeStamp, HashSet<Arc<[u8]>>>

pub fn update_tracked_index(&mut self, index: u64)

pub fn track_lock(
    &mut self,
    start_ts: TimeStamp,
    key: Vec<u8>,
    index: Option<u64>
)

pub fn untrack_lock(&mut self, key: &[u8], index: Option<u64>)

pub fn resolve(&mut self, min_ts: TimeStamp) -> TimeStamp

Try to advance resolved ts.

min_ts advances the resolver even if there is no write. Return None means the resolver is not initialized.