a3s-lane 0.5.0

Lane-based priority command queue for async task scheduling with reliability, scalability, and observability features
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Generic job runtime primitives for distributed priority queues.
//!
//! The existing lane scheduler executes in-process [`Command`](crate::Command)
//! values. This module is the durable job-queue foundation: jobs are plain JSON
//! payloads with bulk submission, explicit lifecycle state, priority plus FIFO/LIFO
//! waiting ordering, delayed scheduling, token-owned worker leases, retries,
//! stalled-job recovery, management APIs, and local durable snapshot persistence.

mod backend;
mod local;
mod memory;
#[cfg(feature = "redis-backend")]
mod redis;
mod types;
mod worker;

pub use backend::JobQueueBackend;
pub use local::LocalJobQueue;
pub use memory::InMemoryJobQueue;
#[cfg(feature = "redis-backend")]
pub use redis::RedisJobQueue;
pub use types::{
    DeduplicationOptions, Job, JobEvent, JobFinishedResult, JobFlow, JobFlowChildValues,
    JobFlowDependencies, JobFlowDependencyCountOptions, JobFlowDependencyCounts,
    JobFlowDependencyKind, JobFlowDependencyPage, JobFlowDependencyPageCursor,
    JobFlowDependencyPageItem, JobFlowDependencyPageOptions, JobFlowDependencyPages,
    JobFlowDependencyPagesOptions, JobFlowDependencySelectedCounts, JobFlowDependencyValues,
    JobFlowIgnoredFailures, JobId, JobLeaseRenewal, JobListOptions, JobListPage, JobLockToken,
    JobLogEntry, JobLogPage, JobMetrics, JobMetricsMeta, JobOptions, JobPriority, JobPriorityCount,
    JobQueueSnapshot, JobQueueStats, JobRateLimit, JobRepeatEntry, JobRepeatListOptions,
    JobRepeatPage, JobRetention, JobSpec, JobState, JobStateCount, JobWorkerId, QueueName,
    RepeatOptions, RepeatSchedule, DEFAULT_JOB_EVENT_RETENTION, DEFAULT_JOB_METRICS_RETENTION,
    DEFAULT_JOB_PRIORITY, MAX_JOB_PRIORITY,
};
pub use worker::{
    job_processor_fn, JobContext, JobProcessor, JobProcessorFn, JobProcessorRouter, JobRunOutcome,
    JobWorker, JobWorkerConfig, JobWorkerHandle,
};

#[cfg(test)]
mod tests;