pub struct ExecutionLog {
pub execution_id: ExecutionId,
pub events: Vec<ExecutionEvent>,
pub responses: Vec<JoinSetResponseEventOuter>,
pub next_version: Version,
pub pending_state: PendingState,
}
Expand description
Remote client representation of the execution journal.
Fields§
§execution_id: ExecutionId
§events: Vec<ExecutionEvent>
§responses: Vec<JoinSetResponseEventOuter>
§next_version: Version
§pending_state: PendingState
Implementations§
Source§impl ExecutionLog
impl ExecutionLog
pub fn can_be_retried_after( temporary_event_count: u32, max_retries: u32, retry_exp_backoff: Duration, ) -> Option<Duration>
pub fn compute_retry_duration_when_retrying_forever( temporary_event_count: u32, retry_exp_backoff: Duration, ) -> Duration
pub fn retry_exp_backoff(&self) -> Duration
pub fn max_retries(&self) -> u32
pub fn ffqn(&self) -> &FunctionFqn
pub fn parent(&self) -> Option<(ExecutionId, JoinSetId)>
pub fn last_event(&self) -> &ExecutionEvent
pub fn into_finished_result(self) -> Option<FinishedExecutionResult>
pub fn event_history(&self) -> impl Iterator<Item = HistoryEvent> + '_
pub fn join_set_requests( &self, join_set_id: JoinSetId, ) -> impl Iterator<Item = &JoinSetRequest>
Trait Implementations§
Source§impl Debug for ExecutionLog
impl Debug for ExecutionLog
Source§impl<'de> Deserialize<'de> for ExecutionLog
impl<'de> Deserialize<'de> for ExecutionLog
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for ExecutionLog
impl PartialEq for ExecutionLog
Source§impl Serialize for ExecutionLog
impl Serialize for ExecutionLog
impl Eq for ExecutionLog
impl StructuralPartialEq for ExecutionLog
Auto Trait Implementations§
impl Freeze for ExecutionLog
impl RefUnwindSafe for ExecutionLog
impl Send for ExecutionLog
impl Sync for ExecutionLog
impl Unpin for ExecutionLog
impl UnwindSafe for ExecutionLog
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more