RuntimeAdapter

mockforge_plugin_loader::runtime_adapter

Trait RuntimeAdapter 

Source 
pub trait RuntimeAdapter: Send + Sync {
    // Required methods
    fn runtime_type(&self) -> RuntimeType;
    fn initialize<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn call_auth<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        context: &'life1 PluginContext,
        request: &'life2 AuthRequest,
    ) -> Pin<Box<dyn Future<Output = Result<AuthResponse, PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn call_template_function<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        function_name: &'life1 str,
        args: &'life2 [Value],
        context: &'life3 ResolutionContext,
    ) -> Pin<Box<dyn Future<Output = Result<Value, PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn call_response_generator<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        context: &'life1 PluginContext,
        request: &'life2 ResponseRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ResponseData, PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn call_datasource_query<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query: &'life1 DataQuery,
        context: &'life2 PluginContext,
    ) -> Pin<Box<dyn Future<Output = Result<DataResult, PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn health_check<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<bool, PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn cleanup<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided method
    fn get_metrics(&self) -> HashMap<String, Value> { ... }
}
Expand description

Trait that all runtime adapters must implement

This allows different WASM runtimes and remote plugins to be used interchangeably

Required Methods§

Source

fn runtime_type(&self) -> RuntimeType

Get the runtime type

Source

fn initialize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Initialize the runtime (called once during plugin load)

Source

fn call_auth<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context: &'life1 PluginContext, request: &'life2 AuthRequest, ) -> Pin<Box<dyn Future<Output = Result<AuthResponse, PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Call authentication plugin

Source

fn call_template_function<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, function_name: &'life1 str, args: &'life2 [Value], context: &'life3 ResolutionContext, ) -> Pin<Box<dyn Future<Output = Result<Value, PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Call template function plugin

Source

fn call_response_generator<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context: &'life1 PluginContext, request: &'life2 ResponseRequest, ) -> Pin<Box<dyn Future<Output = Result<ResponseData, PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Call response generator plugin

Source

fn call_datasource_query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 DataQuery, context: &'life2 PluginContext, ) -> Pin<Box<dyn Future<Output = Result<DataResult, PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Call data source query plugin

Source

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Health check - returns true if the plugin is healthy

Source

fn cleanup<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Cleanup resources (called during plugin unload)

Provided Methods§

Source

fn get_metrics(&self) -> HashMap<String, Value>

Get runtime-specific metrics

Implementors§