Struct MemoryResultBackend 

pub struct MemoryResultBackend { /* private fields */ }

In-memory result backend for development and testing.

Stores task results in a HashMap protected by a std::sync::Mutex. This is cheap to construct and requires no external services, but results are lost when the process exits and the Mutex may become a bottleneck under very high concurrency. For production use, prefer RedisResultBackend (from kojin-redis) or PostgresResultBackend (from kojin-postgres).

Implementations

impl MemoryResultBackend

pub fn new() -> MemoryResultBackend

Create a new, empty in-memory result backend.

Trait Implementations

impl Debug for MemoryResultBackend

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

Formats the value using the given formatter.

impl Default for MemoryResultBackend

fn default() -> MemoryResultBackend

Returns the “default value” for a type.

impl ResultBackend for MemoryResultBackend

fn store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 TaskId, result: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, MemoryResultBackend: 'async_trait,

Store a task result.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryResultBackend: 'async_trait,

Get a stored result.

fn wait<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<Value, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryResultBackend: 'async_trait,

Wait for a result to be available, with timeout.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryResultBackend: 'async_trait,

Delete a stored result.

fn init_group<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, total: u32, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryResultBackend: 'async_trait,

Initialize a group with the expected total count.

fn complete_group_member<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, group_id: &'life1 str, _task_id: &'life2 TaskId, result: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<u32, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, MemoryResultBackend: 'async_trait,

Mark a group member as complete and return the number of completed members.

fn get_group_results<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>, KojinError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryResultBackend: 'async_trait,

Get all results for a group.