agentq 0.1.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
29
30
31

use std::error::Error;
use std::pin::Pin;

#[derive(Debug, Hash, PartialEq, Eq, Clone, Copy, strum::EnumCount)]
pub enum Priority {
    Low,
    Medium,
    High,
}

pub type Key = String;

pub type JobResult = Result<String, Box<dyn Error + Send + Sync>>;

pub type Func = Box<dyn FnOnce() -> Pin<Box<dyn Future<Output = JobResult> + Send>> + Send>;

pub struct Job {
    pub(crate) key: Key,
    pub(crate) priority: Priority,
    pub(crate) func: Func,
}

impl Job {
    pub fn new(key: Key, priority: Priority, func: Func) -> Job {
        Job {
            key,
            priority,
            func,
        }
    }
}