agentq 0.2.0

An embeddable job queue with idempotency keys, per-lane backpressure and bounded concurrency, for agent tool calls.
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

#![doc = include_str!("../docs/agentq.md")]

mod engine;
mod error;
mod event;
mod handle;
mod job;
mod queue;
mod recovery;
mod state;
mod store;
mod worker;
mod workflow;

pub use crate::engine::{EngineError, NonRetryable, WaitForInput, WorkflowEngine};
pub use crate::error::{JobLost, PushError, WaitError};
pub use crate::event::{ClaimResult, Event};
pub use crate::handle::{JobHandle, Outcome};
pub use crate::job::{Func, Job, JobResult, Key, Priority};
pub use crate::queue::{Accepted, LaneConfig, Queue, QueueBuilder};
pub use crate::recovery::recover;
pub use crate::state::State;
#[cfg(feature = "sqlite")]
pub use crate::store::SqliteStore;
pub use crate::store::{DurableStore, StoreError};
pub use crate::workflow::{
    Backoff, Execution, RetryPolicy, StepDef, StepFunc, StepStatus, Workflow,
};