def tx.queue.reserved

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

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

280def tx.queue.reserved(
281  queue: RequestQueue.Queue,
282  decision: QueueDecision
283) -> QueueReservation:
284  match decision:
285    case KeepHead{}: QueueKeep{queue}
286    case DispatchHead{}: QueueDispatch{queue}
287    case RejectHead{}: QueueReject{queue}
288    case ExpireHead{}: QueueExpire{queue}