Struct MemoryBackend 

pub struct MemoryBackend { /* private fields */ }

In-memory message backend for testing and development.

This backend stores messages in memory and provides a simple queue for testing worker implementations without external dependencies.

Example

use foxtive_worker::backends::MemoryBackend;

let backend = MemoryBackend::new();
backend.enqueue(serde_json::json!({"key": "value"}));

Implementations

impl MemoryBackend

pub fn new() -> Self

Create a new in-memory backend with the default source name.

pub fn with_source(source: impl Into<String>) -> Self

Create a new in-memory backend with a custom source name.

pub fn enqueue(&self, payload: Value) -> String

Enqueue a message for processing.

Arguments

• payload - The message payload

Returns

The message ID

pub fn enqueue_batch(&self, payloads: Vec<Value>) -> Vec<String>

Enqueue multiple messages.

pub fn queue_len(&self) -> usize

Get the number of messages currently in the queue.

pub fn unacked_count(&self) -> usize

Get the number of unacknowledged messages.

pub fn clear(&self)

Clear all messages from the queue.

Trait Implementations

impl Debug for MemoryBackend

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

Formats the value using the given formatter.

impl Default for MemoryBackend

fn default() -> Self

Returns the “default value” for a type.

impl MessageBackend for MemoryBackend

fn receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WorkerResult<ReceiveResult<Value>>> + Send + 'async_trait>>

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

Receive the next message with detailed status information.

fn ack<'life0, 'life1, 'async_trait>( &'life0 self, message_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = WorkerResult<()>> + Send + 'async_trait>>

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

Acknowledge a message by ID.

fn nack<'life0, 'life1, 'async_trait>( &'life0 self, message_id: &'life1 str, requeue: bool, ) -> Pin<Box<dyn Future<Output = WorkerResult<()>> + Send + 'async_trait>>

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

Negative acknowledge a message by ID.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WorkerResult<()>> + Send + 'async_trait>>

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

Perform a health check on the backend.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WorkerResult<()>> + Send + 'async_trait>>

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

Gracefully shutdown the backend.