Struct MemorixTaskItem

pub struct MemorixTaskItem<K, P, E, D, EM, G> { /* private fields */ }

Implementations

impl<K: Serialize, P: Serialize + DeserializeOwned, E, D, EM, G> MemorixTaskItem<K, P, E, D, EM, G>

pub fn new( memorix_base: MemorixBase, id: String, options: Option<MemorixTaskOptions>, ) -> Result<Self, Box<dyn Error + Sync + Send>>

pub fn key(&self, key: &K) -> Result<String, Box<dyn Error + Sync + Send>>

impl<K: Serialize, P: Serialize + DeserializeOwned, E: CanTaskEnqueue, D, EM, G> MemorixTaskItem<K, P, E, D, EM, G>

pub async fn enqueue( &mut self, key: &K, payload: &P, ) -> Result<MemorixTaskItemEnqueue, Box<dyn Error + Sync + Send>>

impl<K: Serialize, P: Serialize + DeserializeOwned, E, D: CanTaskDequeue, EM, G> MemorixTaskItem<K, P, E, D, EM, G>

pub async fn dequeue( &self, key: &K, ) -> Result<impl Stream<Item = Result<P, Box<dyn Error + Sync + Send>>> + '_, Box<dyn Error + Sync + Send>>

impl<K: Serialize, P: Serialize + DeserializeOwned, E, D, EM: CanTaskEmpty, G> MemorixTaskItem<K, P, E, D, EM, G>

pub async fn empty( &mut self, key: &K, ) -> Result<(), Box<dyn Error + Sync + Send>>

impl<K: Serialize, P: Serialize + DeserializeOwned, E, D, EM, G: CanTaskGetLen> MemorixTaskItem<K, P, E, D, EM, G>

pub async fn get_len( &mut self, key: &K, ) -> Result<usize, Box<dyn Error + Sync + Send>>

Trait Implementations

impl<K, P, E, D, EM, G> Clone for MemorixTaskItem<K, P, E, D, EM, G>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.