def tx.queue.decide

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

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

import Base

272def tx.queue.decide(policy: HeadPolicy) -> QueueDecision:
273  match policy:
274    case HeadPolicy{fits_total, fits_available, expired}:
275      match expired:
276        case True{}: ExpireHead{}
277        case False{}:
278          tx.queue.eligible(tx.decide(fits_total, fits_available))

Uses (5)

Used by (1)

mylsm-lsm-store@0.6.0.1/src/coordinator/TransportBudgetPolicy:tx.queue.reserve