Enum ExecutionEventInner

pub enum ExecutionEventInner {
    Created {
        ffqn: FunctionFqn,
        params: Params,
        parent: Option<(ExecutionId, JoinSetId)>,
        scheduled_at: DateTime<Utc>,
        retry_exp_backoff: Duration,
        max_retries: u32,
        component_id: ComponentId,
        metadata: ExecutionMetadata,
        scheduled_by: Option<ExecutionId>,
    },
    Locked {
        component_id: ComponentId,
        executor_id: ExecutorId,
        run_id: RunId,
        lock_expires_at: DateTime<Utc>,
    },
    Unlocked {
        backoff_expires_at: DateTime<Utc>,
        reason: StrVariant,
    },
    TemporarilyFailed {
        backoff_expires_at: DateTime<Utc>,
        reason: StrVariant,
        detail: Option<String>,
    },
    TemporarilyTimedOut {
        backoff_expires_at: DateTime<Utc>,
    },
    Finished {
        result: FinishedExecutionResult,
    },
    HistoryEvent {
        event: HistoryEvent,
    },
}

Variants

Created

Created by an external system or a scheduler when requesting a child execution or an executor when continuing as new FinishedExecutionError::ContinueAsNew,CancelledWithNew . The execution is PendingState::PendingAt(scheduled_at).

Fields

ffqn: FunctionFqn

params: Params

parent: Option<(ExecutionId, JoinSetId)>

scheduled_at: DateTime<Utc>

retry_exp_backoff: Duration

max_retries: u32

component_id: ComponentId

metadata: ExecutionMetadata

scheduled_by: Option<ExecutionId>

Locked

Fields

component_id: ComponentId

executor_id: ExecutorId

run_id: RunId

lock_expires_at: DateTime<Utc>

Unlocked

Returns execution to [PendingState::PendingNow] state without timing out. This can happen when the executor is running out of resources like [WorkerError::LimitReached] or when the executor is shutting down.

Fields

backoff_expires_at: DateTime<Utc>

reason: StrVariant

TemporarilyFailed

Fields

backoff_expires_at: DateTime<Utc>

reason: StrVariant

detail: Option<String>

TemporarilyTimedOut

Fields

backoff_expires_at: DateTime<Utc>

Finished

Fields

result: FinishedExecutionResult

HistoryEvent

Fields

event: HistoryEvent

Implementations

impl ExecutionEventInner

pub fn is_temporary_event(&self) -> bool

pub fn variant(&self) -> &'static str

pub fn join_set_id(&self) -> Option<JoinSetId>

Trait Implementations

impl<'arbitrary> Arbitrary<'arbitrary> for ExecutionEventInner

fn arbitrary(u: &mut Unstructured<'arbitrary>) -> Result<Self>

Generate an arbitrary value of Self from the given unstructured data.

fn arbitrary_take_rest(u: Unstructured<'arbitrary>) -> Result<Self>

Generate an arbitrary value of Self from the entirety of the given unstructured data.

fn size_hint(depth: usize) -> (usize, Option<usize>)

Get a size hint for how many bytes out of an Unstructured this type needs to construct itself.

fn try_size_hint( depth: usize, ) -> Result<(usize, Option<usize>), MaxRecursionReached>

Get a size hint for how many bytes out of an Unstructured this type needs to construct itself.

impl Clone for ExecutionEventInner

fn clone(&self) -> ExecutionEventInner

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionEventInner

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutionEventInner

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ExecutionEventInner

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

Formats the value using the given formatter.

impl<'_derivative_strum> From<&'_derivative_strum ExecutionEventInner> for &'static str

fn from(x: &'_derivative_strum ExecutionEventInner) -> &'static str

Converts to this type from the input type.

impl From<CreateRequest> for ExecutionEventInner

fn from(value: CreateRequest) -> Self

Converts to this type from the input type.

impl From<ExecutionEventInner> for &'static str

fn from(x: ExecutionEventInner) -> &'static str

Converts to this type from the input type.

impl PartialEq for ExecutionEventInner

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ExecutionEventInner

impl StructuralPartialEq for ExecutionEventInner