Expand description
§Tauri Queue
Tauri integration for the agent-queue background job processing system.
This crate provides a TauriEventEmitter that bridges job-queue events
to Tauri’s frontend event system, plus re-exports of all core job-queue types.
§Quick Start
- Define a job type implementing
JobHandler - Create a
QueueManagerwith aQueueConfig - Add jobs with
QueueManager::add() - Spawn the executor with
QueueManager::spawn()using aTauriEventEmitter
Modules§
Structs§
- Coalescing
Emitter - A throttled event emitter that coalesces rapid-fire events.
- Emitter
Config - Configuration for event emission backpressure and coalescing.
- JobCancelled
Event - Emitted when a job is cancelled.
- JobCompleted
Event - Emitted when a job completes successfully.
- JobContext
- Context provided to job handlers during execution.
- JobFailed
Event - Emitted when a job fails.
- JobProgress
Event - Emitted during job execution to report progress.
- JobResult
- Result returned by a job handler after execution.
- JobStarted
Event - Emitted when a job starts executing.
- Queue
Config - Configuration for the queue system.
- Queue
Config Builder - Builder for
QueueConfig. - Queue
Job - A generic queue job carrying a custom data payload.
- Queue
Manager - High-level queue manager providing the public API.
- Tauri
Event Emitter - Event emitter that bridges job-queue events to Tauri’s frontend event system.
- Trace
Ctx - In-process trace context for cross-crate correlation.
Enums§
- Drop
Policy - Policy for handling event overflow when the downstream consumer is slow.
- Queue
Error - Errors that can occur in the queue system.
- Queue
JobStatus - Job status lifecycle: Pending -> Processing -> Completed/Failed/Cancelled
- Queue
Priority - Priority levels for queue jobs.
Traits§
- JobHandler
- Trait that job types must implement to be processed by the queue.
- Queue
Event Emitter - Trait for emitting queue lifecycle events.
Functions§
- trace_
ctx_ from_ event_ trace_ id - Extract a canonical
TraceCtxfrom a legacytrace_idstring, if present.