#[non_exhaustive]pub struct ReclaimExecutionArgs {
pub execution_id: ExecutionId,
pub worker_id: WorkerId,
pub worker_instance_id: WorkerInstanceId,
pub lane_id: LaneId,
pub capability_hash: Option<String>,
pub lease_id: LeaseId,
pub lease_ttl_ms: u64,
pub attempt_id: AttemptId,
pub attempt_policy_json: String,
pub max_reclaim_count: Option<u32>,
pub old_worker_instance_id: WorkerInstanceId,
pub current_attempt_index: AttemptIndex,
}Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.execution_id: ExecutionId§worker_id: WorkerId§worker_instance_id: WorkerInstanceId§lane_id: LaneId§capability_hash: Option<String>§lease_id: LeaseId§lease_ttl_ms: u64§attempt_id: AttemptId§attempt_policy_json: StringJSON-encoded attempt policy for the reclaim attempt.
max_reclaim_count: Option<u32>Maximum reclaim count before terminal failure. None ⇒ backend
applies the Rust-surface default of 1000 per RFC-024 §4.6. The
Lua fallback remains 100 for pre-RFC ARGV-omitted call sites;
the two-default coexistence is explicit by design.
old_worker_instance_id: WorkerInstanceIdOld worker instance (for old_worker_leases key construction).
current_attempt_index: AttemptIndexCurrent attempt index (for old_attempt/old_stream_meta key construction).
Implementations§
Source§impl ReclaimExecutionArgs
impl ReclaimExecutionArgs
Sourcepub fn new(
execution_id: ExecutionId,
worker_id: WorkerId,
worker_instance_id: WorkerInstanceId,
lane_id: LaneId,
capability_hash: Option<String>,
lease_id: LeaseId,
lease_ttl_ms: u64,
attempt_id: AttemptId,
attempt_policy_json: String,
max_reclaim_count: Option<u32>,
old_worker_instance_id: WorkerInstanceId,
current_attempt_index: AttemptIndex,
) -> Self
pub fn new( execution_id: ExecutionId, worker_id: WorkerId, worker_instance_id: WorkerInstanceId, lane_id: LaneId, capability_hash: Option<String>, lease_id: LeaseId, lease_ttl_ms: u64, attempt_id: AttemptId, attempt_policy_json: String, max_reclaim_count: Option<u32>, old_worker_instance_id: WorkerInstanceId, current_attempt_index: AttemptIndex, ) -> Self
Construct a ReclaimExecutionArgs. Added alongside
#[non_exhaustive] per RFC-024 §3.2 +
feedback_non_exhaustive_needs_constructor.
Trait Implementations§
Source§impl Clone for ReclaimExecutionArgs
impl Clone for ReclaimExecutionArgs
Source§fn clone(&self) -> ReclaimExecutionArgs
fn clone(&self) -> ReclaimExecutionArgs
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ReclaimExecutionArgs
impl Debug for ReclaimExecutionArgs
Source§impl<'de> Deserialize<'de> for ReclaimExecutionArgs
impl<'de> Deserialize<'de> for ReclaimExecutionArgs
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
Auto Trait Implementations§
impl Freeze for ReclaimExecutionArgs
impl RefUnwindSafe for ReclaimExecutionArgs
impl Send for ReclaimExecutionArgs
impl Sync for ReclaimExecutionArgs
impl Unpin for ReclaimExecutionArgs
impl UnsafeUnpin for ReclaimExecutionArgs
impl UnwindSafe for ReclaimExecutionArgs
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