Struct InMemoryConnection

pub struct InMemoryConnection { /* private fields */ }

An in-memory implementation of Connection.

This implementation maintains a stable set of queues, and is cloneable. Each clone of the connection will maintain references to the same underlying queues.

use paladin::queue::{Connection, QueueOptions, in_memory::InMemoryConnection};
use paladin::serializer::Serializer;
use anyhow::Result;

#[tokio::main]
async fn main() -> Result<()> {
    let connection = InMemoryConnection::new(Serializer::default());
    // Declare a queue
    let handle = connection.declare_queue("my_queue", QueueOptions::default()).await?;

    // ...
    // Delete a queue
    connection.delete_queue("my_queue").await?;
     
    Ok(())
}

Implementations

impl InMemoryConnection

pub fn new(serializer: Serializer) -> Self

Trait Implementations

impl Clone for InMemoryConnection

fn clone(&self) -> InMemoryConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Connection for InMemoryConnection

type QueueHandle = InMemoryQueueHandle

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

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

Close the connection.

fn declare_queue<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, options: QueueOptions, ) -> Pin<Box<dyn Future<Output = Result<Self::QueueHandle>> + Send + 'async_trait>>

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

Declare a queue.

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

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

Delete the queue.