TransportBudgetPolicy.tx.queue.head.policy: def of mylsm-lsm-store@0.6.0.1
Import: import mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy.bend as TransportBudgetPolicy
Lines 306-318 of mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy.bend: https://jend.leeeet.dev/read.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy.bend&start_line=306&end_line=318

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

def tx.queue.head.policy(
  head: Maybe<&2, RequestQueue.HeadMetadata>,
  +used: Nat,
  +capacity: Nat,
  now: Nat
) -> QueueDecision:
  match head:
    case None{}:
      tx.queue.decide.budget(used, 28n, capacity, False{})
    case Some{RequestQueue.HeadMetadata{_, _, deadline_ms, _, _,
        response_peak}}:
      tx.queue.decide.budget(used, response_peak, capacity,
        Nat.is_le(deadline_ms, now))

Uses (7):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Bool
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Maybe
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Nat
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Nat.is_le
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&name=HeadMetadata
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy.bend&name=QueueDecision
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy.bend&name=tx.queue.decide.budget