Struct HookedAdapter 

pub struct HookedAdapter<A = Arc<dyn DbAdapter>> { /* private fields */ }

Adapter wrapper that runs plugin database hooks for mutating operations.

Implementations

impl<A> HookedAdapter<A>

pub fn new(inner: A, hooks: Vec<PluginDatabaseHook>) -> HookedAdapter<A>

pub fn with_logger( inner: A, hooks: Vec<PluginDatabaseHook>, logger: Logger, ) -> HookedAdapter<A>

pub fn hooks(&self) -> &[PluginDatabaseHook]

Trait Implementations

impl<A> Clone for HookedAdapter<A>

where A: Clone,

fn clone(&self) -> HookedAdapter<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A> DbAdapter for HookedAdapter<A>

where A: DbAdapter,

fn id(&self) -> &str

fn capabilities(&self) -> AdapterCapabilities

fn create<'a>( &'a self, query: Create, ) -> Pin<Box<dyn Future<Output = Result<IndexMap<String, DbValue>, RustAuthError>> + Send + 'a>>

fn find_one<'a>( &'a self, query: FindOne, ) -> Pin<Box<dyn Future<Output = Result<Option<IndexMap<String, DbValue>>, RustAuthError>> + Send + 'a>>

fn find_many<'a>( &'a self, query: FindMany, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexMap<String, DbValue>>, RustAuthError>> + Send + 'a>>

fn count<'a>( &'a self, query: Count, ) -> Pin<Box<dyn Future<Output = Result<u64, RustAuthError>> + Send + 'a>>

fn update<'a>( &'a self, query: Update, ) -> Pin<Box<dyn Future<Output = Result<Option<IndexMap<String, DbValue>>, RustAuthError>> + Send + 'a>>

fn update_many<'a>( &'a self, query: UpdateMany, ) -> Pin<Box<dyn Future<Output = Result<u64, RustAuthError>> + Send + 'a>>

fn delete<'a>( &'a self, query: Delete, ) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'a>>

fn delete_many<'a>( &'a self, query: DeleteMany, ) -> Pin<Box<dyn Future<Output = Result<u64, RustAuthError>> + Send + 'a>>

fn transaction<'a>( &'a self, callback: Box<dyn for<'tx> FnOnce(Box<dyn DbAdapter + 'tx>) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'tx>> + Send + 'a>, ) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'a>>

fn create_schema<'a>( &'a self, schema: &'a DbSchema, file: Option<&'a str>, ) -> Pin<Box<dyn Future<Output = Result<Option<SchemaCreation>, RustAuthError>> + Send + 'a>>

fn run_migrations<'a>( &'a self, schema: &'a DbSchema, ) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'a>>

fn run_plugin_migrations<'a>( &'a self, _migrations: &'a [PluginMigration], ) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'a>>