Struct ProcessStarted 

pub struct ProcessStarted {
    pub owner: LeaseOwnerIdentity,
    pub started_at_ms: u64,
}

Durable “execution started” fact: which owner began executing the row and when. The runner writes it under its live lease immediately before executing so the sweep can distinguish an OwnerBound row that has started (never re-run) from one that has not (runnable by anyone). First-writer-wins.

Fields

owner: LeaseOwnerIdentity

started_at_ms: u64

Trait Implementations

impl Clone for ProcessStarted

fn clone(&self) -> ProcessStarted

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessStarted

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcessStarted

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ProcessStarted

impl From<ProcessStarted> for RemoteProcessStarted

fn from(value: ProcessStarted) -> RemoteProcessStarted

Converts to this type from the input type.

impl PartialEq for ProcessStarted

fn eq(&self, other: &ProcessStarted) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ProcessStarted

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 StructuralPartialEq for ProcessStarted

impl TryFrom<RemoteProcessStarted> for ProcessStarted

type Error = RemoteProtocolError

The type returned in the event of a conversion error.

fn try_from( value: RemoteProcessStarted, ) -> Result<ProcessStarted, <ProcessStarted as TryFrom<RemoteProcessStarted>>::Error>

Performs the conversion.