hive-weave.budget — io.github.hive-agi/hive-weave 0.2.5

Unit-agnostic budget gate. 1 permit = 1 unit; caller picks the unit (bytes/MiB/slots/etc). Saturation policy: block up to :timeout-ms, then (r/err :budget/timeout ...).

->deadline clj

(->deadline total-ms)

->workload clj

(->workload task)

Parse [k thunk cost] or [k thunk cost fallback] into a Workload.

await-outcome clj

(await-outcome submission deadline)

byte-budget-gate clj

(byte-budget-gate
  {:keys [capacity unit timeout-ms name fair?]
   :or {unit :mib timeout-ms 30000 name "byte-budget-gate" fair? true}})

Options: :capacity (required), :unit (default :mib), :timeout-ms (30000), :name ("byte-budget-gate"), :fair? (true).

byte-fork-join clj

(byte-fork-join {:keys [gate total-ms] :or {total-ms 30000}} & tasks)

Concurrent dispatch under one IBudgetGate. Tasks: [k thunk cost] or [k thunk cost fallback]. Returns {k result-or-fallback}.

Options: :gate (required), :total-ms (default 30000).

byte-gate-stats clj

(byte-gate-stats g)

cancel-if-timed-out clj

(cancel-if-timed-out submission outcome)

collect-submission clj

(collect-submission submission deadline)

IBudgetGate clj protocol

-acquire clj

(-acquire g cost timeout-ms)

Reserve cost units. Returns Result. On ok, caller MUST -release the same cost.

-release clj

(-release g cost)

Release cost units. Call exactly once per successful -acquire.

-stats clj

(-stats g)

Snapshot: {:name :capacity :unit :inflight :available :queued :admitted-total :rejected-total :timeout-ms}.

remaining-ms clj

(remaining-ms deadline)

resolve-outcome clj

(resolve-outcome {:keys [key fallback]} outcome)

Map an awaited outcome onto [key value-or-fallback]. Total fn.

submit-workload clj

(submit-workload gate workload)

with-budget clj

(with-budget g cost thunk)

(with-budget g cost timeout-ms thunk)

Acquire cost units, run thunk, release. Returns Result. Errors: :budget/over-capacity, :budget/timeout, :budget/execution-failed.

with-byte-budget clj

(with-byte-budget g cost thunk)