Struct CreateTableProcedure

pub struct CreateTableProcedure {
    pub context: DdlContext,
    pub creator: TableCreator,
}

Fields

context: DdlContext

creator: TableCreator

Implementations

impl CreateTableProcedure

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

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

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

fn table_info(&self) -> &RawTableInfo

pub(crate) fn table_id(&self) -> TableId

fn region_wal_options(&self) -> Result<&HashMap<RegionNumber, String>>

fn table_route(&self) -> Result<&PhysicalTableRouteValue>

pub fn set_allocated_metadata( &mut self, table_id: TableId, table_route: PhysicalTableRouteValue, region_wal_options: HashMap<RegionNumber, String>, )

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

On the prepare step, it performs:

• Checks whether the table exists.
• Allocates the table id.

Abort(non-retry):

• TableName exists and create_if_not_exists is false.
• Failed to allocate TableMetadata.

pub fn new_region_request_builder( &self, physical_table_id: Option<TableId>, ) -> Result<CreateRequestBuilder>

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

Creates regions on datanodes

Abort(non-retry):

• Failed to create CreateRequestBuilder.
• Failed to get the table route of physical table (for logical table).

Retry:

• If the underlying servers returns one of the following Code:
  • Code::Cancelled
  • Code::DeadlineExceeded
  • Code::Unavailable

async fn create_regions( &mut self, region_routes: &[RegionRoute], request_builder: CreateRequestBuilder, ) -> Result<Status>

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

Creates table metadata

Abort(not-retry):

• Failed to create table metadata.

Trait Implementations

impl Procedure for CreateTableProcedure

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<'life0, 'life1, 'async_trait>( &'life0 mut self, _: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Rollback the failed procedure.

fn rollback_supported(&self) -> bool

Indicates whether it supports rolling back the procedure.