pub struct StartSagaRequest<'a> {
pub saga_id: &'a SagaId,
pub tenant: &'a TenantId,
pub workflow: &'a WorkflowName,
pub version: DefinitionVersion,
pub business_key: &'a BusinessKey,
pub deadline_at_ms: Option<i64>,
pub trigger_kind: TriggerKind,
pub trigger_id: &'a str,
pub first_command_payload: Option<Value>,
pub first_command_raw_payload: Option<SagaPayload>,
pub now_ms: i64,
}Expand description
业务作用:描述一次 Saga 创建请求。
Fields§
§saga_id: &'a SagaId实例身份,由调用方生成(如 UUID 文本)。
tenant: &'a TenantId规范化租户;无租户部署传固定 system tenant。
workflow: &'a WorkflowNameworkflow 名称,必须已在注册表注册。
version: DefinitionVersiondefinition 版本。
business_key: &'a BusinessKey业务幂等键。
deadline_at_ms: Option<i64>实例级业务 deadline(epoch 毫秒);为空则不设全局期限。
trigger_kind: TriggerKind初始 transition 的触发来源。
trigger_id: &'a str初始 transition 的触发身份(event id 或管理 operation id)。
first_command_payload: Option<Value>首步 execute 命令携带的业务输入;后续步骤由参与方本地事实解析。
first_command_raw_payload: Option<SagaPayload>原始首步正文;与兼容 JSON 输入互斥,媒体类型与 schema 纳入请求摘要。
now_ms: i64当前时刻(epoch 毫秒),由调用方注入统一时钟。
Trait Implementations§
Source§impl<'a> Clone for StartSagaRequest<'a>
impl<'a> Clone for StartSagaRequest<'a>
Auto Trait Implementations§
impl<'a> Freeze for StartSagaRequest<'a>
impl<'a> RefUnwindSafe for StartSagaRequest<'a>
impl<'a> Send for StartSagaRequest<'a>
impl<'a> Sync for StartSagaRequest<'a>
impl<'a> Unpin for StartSagaRequest<'a>
impl<'a> UnsafeUnpin for StartSagaRequest<'a>
impl<'a> UnwindSafe for StartSagaRequest<'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