Struct Docket 

pub struct Docket { /* private fields */ }

Docket distributed task queue.

The main entry point for submitting and managing distributed tasks.

Implementations

impl Docket

pub fn new(settings: DocketSettings) -> Result<Docket, DocketError>

Creates a new Docket with the given settings.

pub fn memory() -> Docket

Creates a Docket with memory backend (for testing).

pub fn submit( &self, task_type: impl Into<String>, params: Value, ) -> Result<TaskId, DocketError>

Submits a task to the queue.

pub fn submit_with_options( &self, task_type: impl Into<String>, params: Value, options: SubmitOptions, ) -> Result<TaskId, DocketError>

Submits a task with custom options.

pub fn get_task( &self, task_id: &TaskId, ) -> Result<Option<DocketTask>, DocketError>

Gets a task by ID.

pub fn list_tasks( &self, status: Option<TaskStatus>, limit: usize, ) -> Result<Vec<DocketTask>, DocketError>

Lists tasks with optional status filter.

pub fn cancel( &self, task_id: &TaskId, reason: Option<&str>, ) -> Result<(), DocketError>

Cancels a task.

pub fn stats(&self) -> Result<QueueStats, DocketError>

Returns queue statistics.

pub fn worker(&self) -> WorkerBuilder

Creates a worker builder.

pub fn settings(&self) -> &DocketSettings

Returns the settings.

pub fn into_shared(self) -> Arc<Docket>

Converts to a shared handle.

Trait Implementations

impl Debug for Docket

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

Formats the value using the given formatter.