Enum SagaTransactionError 

pub enum SagaTransactionError {
    RollbackOnly,
    CommitRejected,
    CommitUncertain,
    RollbackFailed,
    Infrastructure,
}

业务作用：保留 Saga 本地事务的封闭失败阶段，使 transport 不解析错误文本决定 ACK。

CommitRejected/CommitUncertain/RollbackFailed 均禁止进入有界 DLT 预算： 前者需要原消息重试完成业务，后两者则无法声称数据库已回滚。

Variants

RollbackOnly

内层失败把事务标记为 rollback-only，最外层已确认回滚。

CommitRejected

数据库明确拒绝 COMMIT，事务未提交但原输入不得 ACK。

CommitUncertain

COMMIT 请求后无法确定是否已持久。

RollbackFailed

物理回滚失败，不能声称本次无副作用。

Infrastructure

事务开始前或执行内核的基础设施故障。

Implementations

impl SagaTransactionError

pub fn requires_unbounded_redelivery(self) -> bool

业务作用：判断该阶段是否必须保留原输入且不消耗 DLT 预算。

参数说明: 无。

返回：COMMIT 拒绝/不确定或回滚失败返回真；已确认回滚的其他基础故障返回假。

Trait Implementations

impl Clone for SagaTransactionError

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for SagaTransactionError

impl Debug for SagaTransactionError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for SagaTransactionError

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

业务作用：输出不含 SQL、连接串或 payload 的稳定事务阶段。

参数说明：

• formatter: 标准格式化输出目标。

返回：文本写入成功返回 Ok；格式化失败返回对应错误。

impl Eq for SagaTransactionError

impl Error for SagaTransactionError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl PartialEq for SagaTransactionError

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for SagaTransactionError