Struct apalis::prelude::MemoryStorage

pub struct MemoryStorage<T> { /* private fields */ }

An example of the basics of a backend

Implementations

impl<T> MemoryStorage<T>

pub fn new() -> MemoryStorage<T>

Create a new in-memory storage

Trait Implementations

impl<T> Backend<Request<T>> for MemoryStorage<T>

where T: Send + 'static + Sync,

type Stream = BackendStream<Pin<Box<dyn Stream<Item = Result<Option<Request<T>>, Error>> + Send>>>

The stream to be produced by the backend

type Layer = ServiceBuilder<Identity>

Returns the final decoration of layers

fn common_layer( &self, _worker: WorkerId ) -> <MemoryStorage<T> as Backend<Request<T>>>::Layer

Allows the backend to decorate the service with Layer

fn poll( self, _worker: WorkerId ) -> Poller<<MemoryStorage<T> as Backend<Request<T>>>::Stream>

Returns a poller that is ready for streaming

impl<T> Clone for MemoryStorage<T>

fn clone(&self) -> MemoryStorage<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MemoryStorage<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Default for MemoryStorage<T>

fn default() -> MemoryStorage<T>

Returns the “default value” for a type.

impl<Message> MessageQueue<Message> for MemoryStorage<Message>

where Message: Send + 'static + Sync,

type Error = ()

The error produced by the queue

async fn enqueue( &self, message: Message ) -> Result<(), <MemoryStorage<Message> as MessageQueue<Message>>::Error>

Enqueues a message to the queue.

async fn dequeue(&self) -> Result<Option<Message>, ()>

Attempts to dequeue a message from the queue. Returns None if the queue is empty.

async fn size(&self) -> Result<usize, ()>

Returns the current size of the queue.