Struct DropTableProcedure

pub struct DropTableProcedure {
    pub context: DdlContext,
    pub data: DropTableData,
    pub(crate) dropping_regions: Vec<OperatingRegionGuard>,
    executor: DropTableExecutor,
}

Fields

context: DdlContext

The context of procedure runtime.

data: DropTableData

The serializable data.

dropping_regions: Vec<OperatingRegionGuard>

The guards of opening regions.

executor: DropTableExecutor

The drop table executor.

Implementations

impl DropTableProcedure

pub(crate) async fn fill_table_metadata(&mut self) -> Result<()>

Fetches the table info and physical table route.

impl DropTableProcedure

pub const TYPE_NAME: &'static str = "metasrv-procedure::DropTable"

pub fn new( cluster_id: ClusterId, task: DropTableTask, context: DdlContext, ) -> Self

pub fn from_json(json: &str, context: DdlContext) -> ProcedureResult<Self>

pub(crate) async fn on_prepare<'a>(&mut self) -> Result<Status>

fn register_dropping_regions(&mut self) -> Result<()>

Register dropping regions if doesn’t exist.

pub(crate) async fn on_delete_metadata(&mut self) -> Result<Status>

Removes the table metadata.

async fn on_broadcast(&mut self) -> Result<Status>

Broadcasts invalidate table cache instruction.

pub async fn on_datanode_drop_regions(&mut self) -> Result<Status>

async fn on_delete_metadata_tombstone(&mut self) -> Result<Status>

Deletes metadata tombstone.

Trait Implementations

impl Procedure for DropTableProcedure

fn type_name(&self) -> &str

Type name of the procedure.

fn recover(&mut self) -> ProcedureResult<()>

The hook is called after the procedure recovery.

fn execute<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ProcedureContext, ) -> Pin<Box<dyn Future<Output = ProcedureResult<Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute the procedure.

fn dump(&self) -> ProcedureResult<String>

Dump the state of the procedure to a string.

fn lock_key(&self) -> LockKey

Returns the [LockKey] that this procedure needs to acquire.

fn rollback_supported(&self) -> bool

Indicates whether it supports rolling back the procedure.

fn rollback<'life0, 'life1, 'async_trait>( &'life0 mut self, _: &'life1 ProcedureContext, ) -> Pin<Box<dyn Future<Output = ProcedureResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Rollback the failed procedure.