Struct tikv::server::lock_manager::deadlock::RoleChangeNotifier

pub(crate) struct RoleChangeNotifier {
    leader_region_id: Arc<Mutex<u64>>,
    scheduler: Scheduler,
}

RoleChangeNotifier observes region or role change events of raftstore. If the region is the leader region and the role of this node is changed, a ChangeRole task will be scheduled to the deadlock detector. It’s the only way to change the node from the leader of deadlock detector to follower, and vice versa.

Fields

leader_region_id: Arc<Mutex<u64>>

The id of the valid leader region.

scheduler: Scheduler

Implementations

impl RoleChangeNotifier

fn is_leader_region(region: &Region) -> bool

pub(crate) fn new(scheduler: Scheduler) -> Self

pub(crate) fn register(self, host: &mut CoprocessorHost<impl KvEngine>)

Trait Implementations

impl Clone for RoleChangeNotifier

fn clone(&self) -> RoleChangeNotifier

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Coprocessor for RoleChangeNotifier

pub fn start(&self)

pub fn stop(&self)

impl RegionChangeObserver for RoleChangeNotifier

fn on_region_changed(
    &self,
    ctx: &mut ObserverContext<'_>,
    event: RegionChangeEvent,
    role: StateRole
)

Hook to call when a region changed on this TiKV

impl RoleObserver for RoleChangeNotifier

fn on_role_change(&self, ctx: &mut ObserverContext<'_>, role: StateRole)

Hook to call when role of a peer changes.