Aster文档
搜索 Aster 文档
ESC
产品
版本

输入关键词开始搜索。

    文档目录

    ASTER LANE / 01

    Aster Lane 产品概览

    aster-lane 的优先级 Lane、类型化队列、Job Backend 和可靠性边界。

    aster-lane 是异步任务的优先级队列与调度库。当前版本为 0.5.1。它支持命名 Lane、每 Lane 并发限制、重试、超时、DLQ、事件和指标。

    Priority 决定下一个获准执行的等待项,不会中断已经运行的 Future。活动工作需要显式取消和结算合同。

    架构图Lane 的优先级准入与执行边界等待项按 Priority 和 FIFO 进入 Lane。Scheduler 只决定准入,活动工作需要显式取消和结算。持久 Job Backend 另外管理状态与租约。
    Lane 的优先级准入与执行边界任务按 Priority 和 FIFO 等待。Lane 按并发限制准入,Priority 不抢占活动 Future。事件与指标记录执行过程,Job Backend 管理持久状态与租约。状态与租约等待项Priority + FIFO命名 Lane并发 / Rate Limit / Boost活动 Command 或 Job显式取消与结算完成 / 失败 / 重试 / DLQEvent / Metrics / AlertJobQueueBackendLocal 或 Redis

    默认 Lane

    默认 Lane 的优先级与并发
    LanePriority最大并发典型用途
    system0 · 最高5系统级操作
    control13暂停与取消
    query210只读查询
    session35会话管理
    skill43工具执行
    prompt5 · 最低2模型生成

    相同 Priority 的任务保持 FIFO。自定义 Lane 可以替换或扩展默认配置。Rate Limit 在 Dequeue 时执行,不是在 Submit 时执行。

    两种队列入口

    Lane 的队列使用方式
    入口适用场景所有权
    QueueManager + Command需要 Scheduler 自动接纳和执行任务Manager 调度 Command 并返回 Oneshot 结果
    PriorityQueue<T>宿主事件循环决定何时执行宿主保留类型化值与执行时机
    JobQueueBackend通用 JSON Job、Worker 和持久后端Backend 管理 Job 状态、租约和结果

    PriorityQueue<T> 的 restore() 可以恢复准入失败的原始 FIFO 位置。ordered() 只提供队列视图,不修改顺序。

    Feature 与演进状态

    默认 feature 是 metrics、monitoring、telemetry 和 distributed。关闭默认 feature 可以只使用核心队列。redis-backend 是可选的多进程 Job Backend。

    Lane Scheduler 已提供完整的优先级和并发控制。通用 Job Runtime、Job 管理 API、Worker、Flow 和 Repeat 仍在持续演进,不能把所有后端能力视为同一发布承诺。

    PostgreSQL 与 NATS Job Backend 仍在计划中。

    文档入口

    实现依据