#FlowGate v0.1.0

#安装

moon add flowgate

#快速开始

let gate = @flowgate.new_builder()
  .global(100)          // 全局最大并发 100
  .per_key(10)          // 每个 key 最多 10
  .per_session(5)       // 每个 session 最多 5
  .queue_size(200)      // 等待队列 200（0 = 不排队）
  .on_block(fn(reason) { println("BLOCKED: " + reason) })
  .on_acquire(fn(key, session, msg) { /* 埋点 */ })
  .build()

match gate.acquire("tool-1", "user-abc") {
  Ok(msg) => { /* 执行业务 */; gate.release("tool-1", "user-abc") }
  Err(e)  => println(e)  // REJECTED 或 QUEUED
}

#快捷预设

let dev    = @flowgate.permissive_gate()  // 500 / 50 / 20
let prod   = @flowgate.default_gate()     // 100 / 10 / 5
let strict = @flowgate.strict_gate()      //  50 /  3 / 2

#API 参考

#三层限流示意

请求到达
  │
  ├─ 1. 全局上限检查  ← global_active >= max_global ? 拒绝/排队
  ├─ 2. 键上限检查    ← key "tool-a" active >= per_key ? 拒绝/排队
  ├─ 3. 会话上限检查  ← session "user-1" active >= per_session ? 拒绝/排队
  │
  └─ 全部通过 → 计数+1 → 返回 Ok

#相关文档

• GUIDE.md — 新手指南（3 分钟上手 + 常见场景）
• CONTRIBUTING.md — 开发者指南

#许可证