Struct apalis_core::memory::MemoryStorage

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

An example of the basics of a backend

Implementations

impl<T> MemoryStorage<T>

pub fn new() -> Self

Create a new in-memory storage

Trait Implementations

impl<T: Send + 'static + Sync> Backend<Request<T>> for MemoryStorage<T>

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) -> Self::Layer

Allows the backend to decorate the service with Layer

fn poll(self, _worker: WorkerId) -> Poller<Self::Stream>

Returns a poller that is ready for streaming

impl<T> Clone for MemoryStorage<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MemoryStorage<T>

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

Formats the value using the given formatter.

impl<T> Default for MemoryStorage<T>

fn default() -> Self

Returns the “default value” for a type.

impl<Message: Send + 'static + Sync> MessageQueue<Message> for MemoryStorage<Message>

type Error = ()

The error produced by the queue

async fn enqueue(&self, message: Message) -> Result<(), Self::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.