Struct InProcessTasks 

pub struct InProcessTasks { /* private fields */ }

The open-source store: tasks held in this process, gone when it exits. Enough for one local server, where a reconnecting client reaches the same process.

Trait Implementations

impl Debug for InProcessTasks

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

Formats the value using the given formatter.

impl Default for InProcessTasks

fn default() -> Self

Returns the “default value” for a type.

impl TaskStore for InProcessTasks

async fn put(&self, task: StoredTask, expected: Option<u64>) -> Result<bool>

Writes task only if the stored task with its id is at version expected (None: no task with that id exists), atomically, and returns whether it wrote: false means another writer got there first and the kit reads again. In SQL, an insert or an UPDATE ... WHERE version = $expected. Keeps the task for at least TASK_TTL after task.updated_at.

async fn get(&self, id: &str) -> Result<Option<StoredTask>>

The task with id, if it is still kept. The kit checks the space.