Struct FlowDdlEvent 

pub(crate) struct FlowDdlEvent {
    event_type: &'static str,
    catalog_name: Option<String>,
    flow_name: Option<String>,
    flow_id: Option<u32>,
    payload: Option<FlowDdlPayload>,
}

A Flow DDL event with a schema shared by every lifecycle trigger.

Fields

event_type: &'static str

catalog_name: Option<String>

flow_name: Option<String>

flow_id: Option<u32>

payload: Option<FlowDdlPayload>

Implementations

impl FlowDdlEvent

pub(crate) fn create_submitted( catalog_name: &str, flow_name: &str, intent: CreateFlowEventIntent, ) -> Self

Builds the bounded event emitted when creating a Flow is submitted.

pub(crate) fn drop_submitted( catalog_name: &str, flow_name: &str, flow_id: u32, drop_if_exists: bool, ) -> Self

Builds the bounded event emitted when dropping a Flow is submitted.

pub(crate) fn create_lifecycle(catalog_name: &str, flow_name: &str) -> Self

Builds a Create Flow lifecycle event with its submitted locator.

pub(crate) fn create_succeeded( catalog_name: &str, flow_name: &str, flow_id: Option<u32>, ) -> Self

Builds a successful Create Flow event with its submitted locator and resolved ID.

pub(crate) fn drop_lifecycle( catalog_name: &str, flow_name: &str, flow_id: u32, ) -> Self

Builds a Drop Flow lifecycle event with its submitted locator.

fn lifecycle( event_type: &'static str, catalog_name: &str, flow_name: &str, ) -> Self

Trait Implementations

impl Debug for FlowDdlEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Event for FlowDdlEvent

fn event_type(&self) -> &str

Returns the type of the event.

fn json_payload(&self) -> Result<Value>

Returns the event payload as a structured JSON value. It will be encoded as JSONB when stored.

fn extra_schema(&self) -> Vec<ColumnSchema>

Add the extra schema to the event with the default schema.

fn extra_rows(&self) -> Result<Vec<Row>>

Add the extra rows to the event with the default row.

fn as_any(&self) -> &dyn Any

Returns the event as any type.

fn table_name(&self) -> &str

Returns the table name of the event.

fn timestamp(&self) -> Timestamp

Returns the timestamp of the event. Default to the current time.