Struct CreateFlowProcedure

pub struct CreateFlowProcedure {
    pub context: DdlContext,
    pub data: CreateFlowData,
}

The procedure of flow creation.

Fields

context: DdlContext

data: CreateFlowData

Implementations

impl CreateFlowProcedure

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

Allocates the [FlowId].

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

Ensures all source tables exist and collects source table ids

impl CreateFlowProcedure

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

pub fn new( cluster_id: ClusterId, task: CreateFlowTask, query_context: QueryContext, context: DdlContext, ) -> Self

Returns a new CreateFlowProcedure.

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

Deserializes from json.

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

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

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

Creates flow metadata.

Abort(not-retry):

• Failed to create table metadata.

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

Trait Implementations

impl Procedure for CreateFlowProcedure

fn type_name(&self) -> &str

Type name of the procedure.

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.

fn recover(&mut self) -> Result<(), Error>

The hook is called after the procedure recovery.