pub struct ScheduledBatchSpec<'a> {
pub task_name: &'a str,
pub scheduled_at_ms: i64,
pub workflow: &'a WorkflowName,
pub version: DefinitionVersion,
pub tenant: &'a TenantId,
pub max_items: u32,
pub time_budget_ms: i64,
pub now_ms: i64,
}Expand description
业务作用:描述一次名义调度时刻批次的固定输入与有界预算。
Fields§
§task_name: &'a str调度任务稳定名称,参与业务幂等键派生。
scheduled_at_ms: i64名义调度时刻(epoch 毫秒),批次身份的一部分。
workflow: &'a WorkflowName目标 workflow 名称。
version: DefinitionVersion目标 definition 版本。
tenant: &'a TenantId租户身份。
max_items: u32单批次发起数量上限;未处理对象由下一次触发的重扫继续。
time_budget_ms: i64单批次时间预算(毫秒);超出即停止,不在进程内滞留。
now_ms: i64当前时刻(epoch 毫秒),由调用方注入统一时钟。
Trait Implementations§
Source§impl<'a> Clone for ScheduledBatchSpec<'a>
impl<'a> Clone for ScheduledBatchSpec<'a>
Auto Trait Implementations§
impl<'a> Forget for ScheduledBatchSpec<'a>
impl<'a> Freeze for ScheduledBatchSpec<'a>
impl<'a> Move for ScheduledBatchSpec<'a>
impl<'a> RefUnwindSafe for ScheduledBatchSpec<'a>
impl<'a> Send for ScheduledBatchSpec<'a>
impl<'a> Sync for ScheduledBatchSpec<'a>
impl<'a> Unpin for ScheduledBatchSpec<'a>
impl<'a> UnsafeUnpin for ScheduledBatchSpec<'a>
impl<'a> UnwindSafe for ScheduledBatchSpec<'a>
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