Struct InMemoryFunctionStore 

pub struct InMemoryFunctionStore { /* private fields */ }

In-memory function store backed by a HashMap behind a Mutex.

Thread-safe via an Arc<Mutex<...>> interior; suitable for unit tests and local development scenarios that do not require persistence.

Implementations

impl InMemoryFunctionStore

pub fn new() -> Self

Create a new empty in-memory store.

Trait Implementations

impl Clone for InMemoryFunctionStore

fn clone(&self) -> InMemoryFunctionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryFunctionStore

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

Formats the value using the given formatter.

impl Default for InMemoryFunctionStore

fn default() -> Self

Returns the “default value” for a type.

impl FunctionStore for InMemoryFunctionStore

fn store_function<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, runtime: RuntimeType, bytecode: Bytes, ) -> Pin<Box<dyn Future<Output = Result<FunctionRecord>> + Send + 'async_trait>>

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

Store a new version of a function, bumping its version number.

fn get_function<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<FunctionRecord>>> + Send + 'async_trait>>

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

Retrieve the latest active version of a function by name.

fn list_functions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<FunctionRecord>>> + Send + 'async_trait>>

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

List all active function records.

fn delete_function<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Delete (deactivate) all versions of a function by name.