Struct Flow 

pub struct Flow {

    pub id: Uuid,
    pub controller_id: String,
    pub goal: String,
    pub owner_session_key: String,
    pub requester_origin: String,
    pub current_step: String,
    pub state_json: Value,
    pub wait_json: Option<Value>,
    pub status: FlowStatus,
    pub cancel_requested: bool,
    pub revision: i64,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

A flow record as persisted in flows. state_json and wait_json carry arbitrary controller-specific payloads; the runtime treats them as opaque blobs and only mutates them through revision-checked APIs.

Fields

id: Uuid

controller_id: String

goal: String

owner_session_key: String

requester_origin: String

current_step: String

state_json: Value

wait_json: Option<Value>

status: FlowStatus

cancel_requested: bool

Sticky cancel intent. When true, the flow refuses any non-terminal transition until it reaches Cancelled. Survives restart.

revision: i64

created_at: DateTime<Utc>

updated_at: DateTime<Utc>

Implementations

impl Flow

pub fn transition_to(&mut self, next: FlowStatus) -> Result<(), FlowError>

Validate and apply a status transition. Does not persist — caller is responsible for FlowStore::update_with_revision. Mutates self so the caller can immediately persist the resulting state.

pub fn request_cancel(&mut self)

Mark a sticky cancel intent. Survives restart; subsequent transitions are restricted to Cancelled. Idempotent — calling on an already cancel-requested flow is a no-op.

Trait Implementations

impl Clone for Flow

fn clone(&self) -> Flow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Flow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Flow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Flow

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.