Struct Middleware 

pub struct Middleware { /* private fields */ }

A registered set of hooks. A host builds this with the builder methods and passes it to crate::runtime::GraphDDBRuntime::use_middleware. Any subset of the 10 hook points may be set; unset points are simply skipped.

Implementations

impl Middleware

pub fn new() -> Self

A fresh empty middleware.

pub fn read_before( self, f: impl Fn(&mut ReadRequestCtx) -> Result<(), GraphDDBError> + Send + Sync + 'static, ) -> Self

Register R1 read.before (request entry; may mutate params, may error).

pub fn read_after( self, f: impl Fn(&ReadRequestCtx, Json) -> Json + Send + Sync + 'static, ) -> Self

Register R4 read.afterFetch (final result; onion-threaded, may replace).

pub fn read_on_error( self, f: impl Fn(&ReadRequestCtx, &GraphDDBError) -> Recovery + Send + Sync + 'static, ) -> Self

Register R5 read.onError (request-level recovery).

pub fn read_op_before( self, f: impl Fn(&mut ReadOpCtx) -> Result<(), GraphDDBError> + Send + Sync + 'static, ) -> Self

Register R2 read.op.before (physical op; may mutate the op, may error).

pub fn read_op_after( self, f: impl Fn(&ReadOpCtx, Vec<Json>) -> Vec<Json> + Send + Sync + 'static, ) -> Self

Register R3 read.op.afterFetch (raw items; onion-threaded, may replace).

pub fn read_op_on_error( self, f: impl Fn(&ReadOpCtx, &GraphDDBError) -> Option<Vec<Json>> + Send + Sync + 'static, ) -> Self

Register R5 (op-level) read.op.onError (recover with an item list).

pub fn write_before( self, f: impl Fn(&mut WriteCtx) -> Result<(), GraphDDBError> + Send + Sync + 'static, ) -> Self

Register W1 write.before (logical write; may mutate kind/input, may error).

pub fn write_after( self, f: impl Fn(&WriteCtx, &Json) + Send + Sync + 'static, ) -> Self

Register W2 write.after (committed change; observe-only).

pub fn write_on_error( self, f: impl Fn(&WriteCtx, &GraphDDBError) -> Recovery + Send + Sync + 'static, ) -> Self

Register W5 (logical-level) write.onError (recovery).

pub fn persist_before( self, f: impl Fn(&mut PersistCtx) -> Result<(), GraphDDBError> + Send + Sync + 'static, ) -> Self

Register W3 write.persist.before (composed batch; may mutate items, may error).

pub fn persist_after( self, f: impl Fn(&PersistCtx, &Json) + Send + Sync + 'static, ) -> Self

Register W4 write.persist.after (executor results; observe-only).

pub fn persist_on_error( self, f: impl Fn(&PersistCtx, &GraphDDBError) -> Recovery + Send + Sync + 'static, ) -> Self

Register W5 (persist-level) write.persist.onError (recovery).

Trait Implementations

impl Clone for Middleware

fn clone(&self) -> Middleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Middleware

fn default() -> Middleware

Returns the “default value” for a type.