Struct PgOutboxAuditSink 

pub struct PgOutboxAuditSink { /* private fields */ }

PostgreSQL 事务审计 sink；全部审计写固定进入底层 Outbox 绑定的 datasource。

Implementations

impl PgOutboxAuditSink

pub fn new() -> Self

业务作用：创建绑定默认 datasource 的审计适配器，不建立独立连接池。

参数说明: 无。

返回：审计事件固定写入默认 datasource Outbox 的轻量句柄。

pub fn with_datasource( datasource: impl AsRef<str>, ) -> Result<Self, OutboxStoreError>

业务作用：创建绑定命名 PostgreSQL datasource 的审计适配器。

参数说明：

• datasource：启动期已登记的稳定 datasource 名称。

返回：名称合法时返回固定绑定句柄；非法名称在网络 I/O 前失败。

pub fn datasource_ref(&self) -> &DatasourceRef

业务作用：读取审计事件最终写入的 PostgreSQL datasource 身份。

参数说明: 无。

返回：底层 Outbox 固定使用且不含连接信息的 qualifier。

Trait Implementations

impl Clone for PgOutboxAuditSink

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgOutboxAuditSink

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

Formats the value using the given formatter.

impl Default for PgOutboxAuditSink

fn default() -> Self

业务作用：创建绑定默认 PostgreSQL datasource 的审计适配器。

参数说明: 无。

返回：与 PgOutboxAuditSink::new 相同的轻量句柄。

impl TransactionalAuditSink for PgOutboxAuditSink

fn record_transactional<'life0, 'async_trait>( &'life0 self, event: AuditEvent, ) -> Pin<Box<dyn Future<Output = Result<(), AuditWriteError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

业务作用：在当前同源 PostgreSQL ambient transaction 内写入审计 Outbox 事实。

参数说明：

• event：已经完成 actor、资源、结局与脱敏 context 归因的业务审计事件。

返回：Outbox append 与 after-commit 登记成功时完成；事务、路由或数据库失败返回脱敏错误。