def tx.queue.head.policy

mylsm-lsm-store@0.6.0.1 · src/coordinator/TransportBudgetPolicy.bend:306

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend as RequestQueue

306def tx.queue.head.policy(
307  head: Maybe<&2, RequestQueue.HeadMetadata>,
308  +used: Nat,
309  +capacity: Nat,
310  now: Nat
311) -> QueueDecision:
312  match head:
313    case None{}:
314      tx.queue.decide.budget(used, 28n, capacity, False{})
315    case Some{RequestQueue.HeadMetadata{_, _, deadline_ms, _, _,
316        response_peak}}:
317      tx.queue.decide.budget(used, response_peak, capacity,
318        Nat.is_le(deadline_ms, now))