Struct AfterHookQueue 

pub struct AfterHookQueue<S: AuthSchema>(/* private fields */);

After-hooks recorded by writes inside an auth transaction.

Rollback drops the queue. After commit, run replays every event in operation order, invoking each registered hook per event; a hook error is returned to the caller after the auth writes have committed.

Implementations

impl<S: AuthSchema> AfterHookQueue<S>

pub const fn new() -> Self

pub async fn push(&self, event: AfterHook<S>)

pub async fn run<B: HookBackend>( self, hooks: &[Arc<dyn DatabaseHooks<S, B>>], ctx: &DatabaseHookContext<'_, B>, ) -> AuthResult<()>

Run every queued event against hooks, in order.

Errors

Returns the first hook error.

pub async fn run_with_policy<B: HookBackend>( self, hooks: &[Arc<dyn DatabaseHooks<S, B>>], ctx: &DatabaseHookContext<'_, B>, policy: AfterCommitErrorPolicy, ) -> AuthResult<()>

Run queued hooks, optionally reporting errors after durable commit.

Errors

Returns hook errors when propagation is selected.

Trait Implementations

impl<S: AuthSchema> Default for AfterHookQueue<S>

fn default() -> Self

Returns the “default value” for a type.