Skip to main content

QueueBackend

shelly_data

Trait QueueBackend 

Source 
pub trait QueueBackend: Send + Sync {
    // Required methods
    fn enqueue(
        &self,
        topic: &str,
        payload: Value,
        scheduled_at_unix_ms: Option<u64>,
    ) -> AppServiceResult<QueueMessage>;
    fn dequeue(&self, topic: &str) -> AppServiceResult<Option<QueueMessage>>;
    fn len(&self, topic: &str) -> AppServiceResult<usize>;
}

Required Methods§

Source

fn enqueue( &self, topic: &str, payload: Value, scheduled_at_unix_ms: Option<u64>, ) -> AppServiceResult<QueueMessage>

Source

fn dequeue(&self, topic: &str) -> AppServiceResult<Option<QueueMessage>>

Source

fn len(&self, topic: &str) -> AppServiceResult<usize>

Implementors§