Enum PendingState

pub enum PendingState {
    Locked {
        executor_id: ExecutorId,
        run_id: RunId,
        lock_expires_at: DateTime<Utc>,
    },
    PendingAt {
        scheduled_at: DateTime<Utc>,
    },
    BlockedByJoinSet {
        join_set_id: JoinSetId,
        lock_expires_at: DateTime<Utc>,
        closing: bool,
    },
    Finished {
        finished: PendingStateFinished,
    },
}

Variants

Locked

Fields

executor_id: ExecutorId

run_id: RunId

lock_expires_at: DateTime<Utc>

PendingAt

Fields

scheduled_at: DateTime<Utc>

BlockedByJoinSet

Caused by HistoryEvent::JoinNext

Fields

join_set_id: JoinSetId

lock_expires_at: DateTime<Utc>

See [HistoryEvent::JoinNext::lock_expires_at].

closing: bool

Blocked by closing of the join set

Finished

Fields

finished: PendingStateFinished

Implementations

impl PendingState

pub fn can_append_lock( &self, created_at: DateTime<Utc>, executor_id: ExecutorId, run_id: RunId, lock_expires_at: DateTime<Utc>, ) -> Result<LockKind, SpecificError>

pub fn is_finished(&self) -> bool

Trait Implementations

impl Clone for PendingState

fn clone(&self) -> PendingState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PendingState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PendingState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for PendingState

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

Formats the value using the given formatter.

impl PartialEq for PendingState

fn eq(&self, other: &PendingState) -> 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 PendingState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for PendingState

impl Eq for PendingState

impl StructuralPartialEq for PendingState