Struct InMemoryTaskQueue 

pub struct InMemoryTaskQueue<D, S>
where
    S: TaskSerializer,
{
    pub hashmap: Mutex<HashMap<TaskId, Vec<u8>>>,
    pub list: Mutex<VecDeque<TaskId>>,
    pub inflight: Mutex<HashMap<TaskId, ()>>,
    pub dlq: Mutex<HashMap<TaskId, Vec<u8>>>,
    /* private fields */
}

Fields

hashmap: Mutex<HashMap<TaskId, Vec<u8>>>

list: Mutex<VecDeque<TaskId>>

inflight: Mutex<HashMap<TaskId, ()>>

dlq: Mutex<HashMap<TaskId, Vec<u8>>>

Implementations

impl<D, S> InMemoryTaskQueue<D, S>

where S: TaskSerializer,

pub fn new() -> Self

Trait Implementations

impl<D, S> Debug for InMemoryTaskQueue<D, S>

where S: TaskSerializer,

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

Formats the value using the given formatter.

impl<D, S> Default for InMemoryTaskQueue<D, S>

where S: TaskSerializer,

fn default() -> Self

Returns the “default value” for a type.

impl<D, S> TaskQueue<D> for InMemoryTaskQueue<D, S>

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

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,

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

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

Move any tasks left in the in-flight set back to the queue. Called once at runtime startup to recover work owned by a previous process that crashed before acking. Returns the number of tasks recovered.