Struct paladin::queue::in_memory::InMemoryQueue

pub struct InMemoryQueue { /* private fields */ }

An in-memory implementation of Queue.

use paladin::queue::{Queue, in_memory::InMemoryQueue};
use paladin::serializer::Serializer;
use anyhow::Result;

#[tokio::main]
async fn main() -> Result<()> {
    let queue = InMemoryQueue::new(Serializer::Cbor);
    let connection = queue.get_connection().await?;
     
    Ok(())
}

Implementations

impl InMemoryQueue

pub fn new(serializer: Serializer) -> Self

Create a new in-memory queue.

Trait Implementations

impl Queue for InMemoryQueue

type Connection = InMemoryConnection

The type of connection used to interact with the queue. Cloning operations should use a resource pool or connection manager to ensure cloning is cheap.

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

Establish a connection to the queue.