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) -> DocketResult<Self>

Creates a new Docket with the given settings.

pub fn memory() -> Self

Creates a Docket with memory backend (for testing).

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

Submits a task to the queue.

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

Submits a task with custom options.

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

Gets a task by ID.

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

Lists tasks with optional status filter.

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

Cancels a task.

pub fn stats(&self) -> DocketResult<QueueStats>

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) -> SharedDocket

Converts to a shared handle.

Trait Implementations

impl Debug for Docket

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

Formats the value using the given formatter.