pub struct TaskletJob { /* private fields */ }Expand description
A validated single-step job definition.
Implementations§
Source§impl TaskletJob
impl TaskletJob
Sourcepub fn new(
name: JobName,
step: TaskletStep,
revision: DefinitionRevision,
component_revision: &ComponentRevision,
) -> Result<Self, DefinitionError>
pub fn new( name: JobName, step: TaskletStep, revision: DefinitionRevision, component_revision: &ComponentRevision, ) -> Result<Self, DefinitionError>
Constructs a tasklet job with explicit restart-relevant revisions.
Applications that may durably restart a job should use this constructor and change the component revision whenever the tasklet’s durable behavior changes.
§Errors
Returns DefinitionError if the bounded canonical manifest cannot be
encoded.
Sourcepub fn with_listener(self, listener: Arc<dyn JobExecutionListener>) -> Self
pub fn with_listener(self, listener: Arc<dyn JobExecutionListener>) -> Self
Registers a job listener in deterministic before-order.
Sourcepub const fn step(&self) -> &TaskletStep
pub const fn step(&self) -> &TaskletStep
Borrows the sole step.
Sourcepub const fn definition_identity(&self) -> &DefinitionIdentity
pub const fn definition_identity(&self) -> &DefinitionIdentity
Borrows the exact restart-relevant definition identity.
Sourcepub const fn compiled_plan(&self) -> &CompiledExecutionPlan
pub const fn compiled_plan(&self) -> &CompiledExecutionPlan
Borrows the in-memory compatibility plan this wrapper lowers into.
The plan retains the wrapper’s original manifest bytes, format, and fingerprint. Its synthetic graph routes the framework’s own exit codes to terminals and records no durable flow decision.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for TaskletJob
impl !UnwindSafe for TaskletJob
impl Freeze for TaskletJob
impl Send for TaskletJob
impl Sync for TaskletJob
impl Unpin for TaskletJob
impl UnsafeUnpin for TaskletJob
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<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