Struct ProcessRecord 

pub struct ProcessRecord {

    pub id: String,
    pub registration_hash: String,
    pub input: Arc<ProcessInput>,
    pub disposition: RecoveryDisposition,
    pub identity: ProcessIdentity,
    pub event_types: Vec<ProcessEventType>,
    pub provenance: ProcessProvenance,
    pub env_ref: Option<ProcessExecutionEnvRef>,
    pub wake_target: Option<SessionScope>,
    pub created_at_ms: u64,
    pub updated_at_ms: u64,
    pub external_ref: Option<ProcessExternalRef>,
    pub first_started: Option<Box<ProcessStarted>>,
    pub abandon_request: Option<Box<AbandonRequest>>,
    pub wait: Option<WaitState>,
    pub status: ProcessStatus,
}

Durable process row. Session-visible addressability lives in ProcessHandleGrant, not in the process record.

Fields

id: String

registration_hash: String

input: Arc<ProcessInput>

disposition: RecoveryDisposition

Declared recovery contract. Required with no serde default: pre-column durable rows cannot deserialize and are handled by each store’s schema version bump (reject-and-recreate), never by an API/serde default.

identity: ProcessIdentity

event_types: Vec<ProcessEventType>

provenance: ProcessProvenance

env_ref: Option<ProcessExecutionEnvRef>

wake_target: Option<SessionScope>

created_at_ms: u64

updated_at_ms: u64

external_ref: Option<ProcessExternalRef>

first_started: Option<Box<ProcessStarted>>

Durable, lease-fenced execution-started fact (ADR 0019). None until a runner records it immediately before executing. Boxed so these usually-absent facts do not enlarge the pervasive ProcessRecord that flows through the runtime; serde treats Option<Box<T>> identically to Option<T>, so the persisted JSON is unchanged.

abandon_request: Option<Box<AbandonRequest>>

Pending Abandon Request the sweep reconciles once the lease lapses.

wait: Option<WaitState>

status: ProcessStatus

Implementations

impl ProcessRecord

pub fn from_registration(registration: ProcessRegistration) -> ProcessRecord

pub fn from_registration_with_clock( registration: ProcessRegistration, clock: &dyn Clock, ) -> ProcessRecord

pub fn from_prepared_registration( registration: ProcessRegistration, registration_hash: String, now_ms: u64, ) -> ProcessRecord

pub fn is_terminal(&self) -> bool

pub fn clear_wake_target_for_session(&mut self, session_id: &str) -> bool

pub fn clear_wake_target_for_session_with_clock( &mut self, session_id: &str, clock: &dyn Clock, ) -> bool

pub fn originator_scope_id(&self) -> String

Trait Implementations

impl Clone for ProcessRecord

fn clone(&self) -> ProcessRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcessRecord

fn deserialize<__D>( __deserializer: __D, ) -> Result<ProcessRecord, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProcessRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<ProcessRecord> for RemoteProcessStartResult

type Error = RemoteProtocolError

The type returned in the event of a conversion error.

fn try_from( value: ProcessRecord, ) -> Result<RemoteProcessStartResult, <RemoteProcessStartResult as TryFrom<ProcessRecord>>::Error>

Performs the conversion.

impl TryFrom<RemoteProcessRecord> for ProcessRecord

type Error = RemoteProtocolError

The type returned in the event of a conversion error.

fn try_from( value: RemoteProcessRecord, ) -> Result<ProcessRecord, <ProcessRecord as TryFrom<RemoteProcessRecord>>::Error>

Performs the conversion.

impl TryFrom<RemoteProcessStartResult> for ProcessRecord

type Error = RemoteProtocolError

The type returned in the event of a conversion error.

fn try_from( value: RemoteProcessStartResult, ) -> Result<ProcessRecord, <ProcessRecord as TryFrom<RemoteProcessStartResult>>::Error>

Performs the conversion.