Struct 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 = Identity

Returns the final decoration of layers

type Codec = NoopCodec<Request<T, ()>>

Specifies the codec type used by the backend

fn poll(self, _worker: &Worker<Context>) -> Poller<Self::Stream>

Returns a poller that is ready for streaming

impl<T> Clone for MemoryStorage<T>

fn clone(&self) -> Self

Returns a duplicate 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 Context = ()

This stores more data about the Message, provided by the backend

type Error = ()

The error produced by the queue

type Compact = Message

The format that the storage persists the jobs usually Vec<u8>

async fn enqueue_request( &mut self, req: Request<Message, Self::Context>, ) -> Result<(), Self::Error>

Enqueues a Request constructed with customizations

async fn enqueue_raw_request( &mut self, _req: Request<Self::Compact, Self::Context>, ) -> Result<(), Self::Error>

Enqueues a request without forcing the type

async fn dequeue_request( &mut self, ) -> Result<Option<Request<Message, Self::Context>>, ()>

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

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

Returns the current size of the queue.

fn enqueue( &mut self, message: Message, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Enqueues a message to the queue.

fn dequeue( &mut self, ) -> impl Future<Output = Result<Option<Message>, Self::Error>> + Send

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