Struct Context 

pub struct Context {
    persistent_ctx: Arc<PersistentContext>,
    volatile_ctx: VolatileContext,
    in_memory: KvBackendRef,
    table_metadata_manager: TableMetadataManagerRef,
    opening_region_keeper: MemoryRegionKeeperRef,
    region_failure_detector_controller: RegionFailureDetectorControllerRef,
    mailbox: MailboxRef,
    server_addr: String,
    cache_invalidator: CacheInvalidatorRef,
}

The context of procedure execution.

Fields

persistent_ctx: Arc<PersistentContext>

volatile_ctx: VolatileContext

in_memory: KvBackendRef

table_metadata_manager: TableMetadataManagerRef

opening_region_keeper: MemoryRegionKeeperRef

region_failure_detector_controller: RegionFailureDetectorControllerRef

mailbox: MailboxRef

server_addr: String

cache_invalidator: CacheInvalidatorRef

Implementations

impl Context

pub fn next_operation_timeout(&self) -> Option<Duration>

Returns the next operation’s timeout.

pub fn update_operations_elapsed(&mut self, instant: Instant)

Updates operations elapsed.

pub fn update_flush_leader_region_elapsed(&mut self, instant: Instant)

Updates the elapsed time of flushing leader region.

pub fn update_downgrade_leader_region_elapsed(&mut self, instant: Instant)

Updates the elapsed time of downgrading leader region.

pub fn update_open_candidate_region_elapsed(&mut self, instant: Instant)

Updates the elapsed time of open candidate region.

pub fn update_upgrade_candidate_region_elapsed(&mut self, instant: Instant)

Updates the elapsed time of upgrade candidate region.

pub fn server_addr(&self) -> &str

Returns address of meta server.

pub async fn get_table_route_value( &mut self, ) -> Result<&DeserializedValueWithBytes<TableRouteValue>>

Returns the table_route of VolatileContext if any. Otherwise, returns the value retrieved from remote.

Retry:

• Failed to retrieve the metadata of table.

pub async fn register_failure_detectors(&self)

Notifies the RegionSupervisor to register failure detectors of failed region.

The original failure detector was removed once the procedure was triggered. Now, we need to register the failure detector for the failed region again.

pub async fn deregister_failure_detectors(&self)

Notifies the RegionSupervisor to deregister failure detectors.

The original failure detectors won’t be removed once the procedure was triggered. We need to deregister the failure detectors for the original region if the procedure is finished.

pub async fn deregister_failure_detectors_for_candidate_region(&self)

Notifies the RegionSupervisor to deregister failure detectors for the candidate region on the destination peer.

The candidate region may be created on the destination peer, so we need to deregister the failure detectors for the candidate region if the procedure is aborted.

pub fn remove_table_route_value(&mut self) -> bool

Removes the table_route of VolatileContext, returns true if any.

pub async fn get_table_info_value( &mut self, ) -> Result<&DeserializedValueWithBytes<TableInfoValue>>

Returns the table_info of VolatileContext if any. Otherwise, returns the value retrieved from remote.

Retry:

• Failed to retrieve the metadata of table.

pub async fn get_from_peer_datanode_table_value( &mut self, ) -> Result<&DatanodeTableValue>

Returns the table_info of VolatileContext if any. Otherwise, returns the value retrieved from remote.

Retry:

• Failed to retrieve the metadata of datanode.

pub async fn fetch_replay_checkpoint( &self, topic: &str, ) -> Result<Option<ReplayCheckpoint>>

Fetches the replay checkpoint for the given topic.

pub fn region_id(&self) -> RegionId

Returns the RegionId.

pub async fn invalidate_table_cache(&self) -> Result<()>

Broadcasts the invalidate table cache message.

pub fn persistent_ctx(&self) -> Arc<PersistentContext>

Returns the PersistentContext of the procedure.