Struct InMemoryTaskQueue 

pub struct InMemoryTaskQueue<D> {
    pub hashmap: Mutex<HashMap<TaskId, String>>,
    pub list: Mutex<VecDeque<TaskId>>,
    pub dlq: Mutex<HashMap<TaskId, String>>,
    /* private fields */
}

Fields

hashmap: Mutex<HashMap<TaskId, String>>

list: Mutex<VecDeque<TaskId>>

dlq: Mutex<HashMap<TaskId, String>>

Implementations

impl<D> InMemoryTaskQueue<D>

pub fn new() -> Self

Trait Implementations

impl<D> Debug for InMemoryTaskQueue<D>

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

Formats the value using the given formatter.

impl<D> Default for InMemoryTaskQueue<D>

fn default() -> Self

Returns the “default value” for a type.

impl<D> TaskQueue<D> for InMemoryTaskQueue<D>

where D: Debug + Clone + Serialize + DeserializeOwned + Send + Sync + 'static,

fn push<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

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

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

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

fn ack<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

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

fn nack<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

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

fn set<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

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