def tx.flight.reserved

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

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

101def tx.flight.reserved(
102  connection_id: U32,
103  request_bytes: Nat,
104  bound: BoundDecision,
105  request: Protocol.Request
106) -> InFlight:
107  match bound:
108    case Bounded{payload_limit, peak_bytes}:
109      ReservedRequest{DispatchReservation{connection_id, request_bytes,
110        payload_limit, peak_bytes}, request}
111    case _:
112      ReservedRequest{DispatchReservation{connection_id, request_bytes,
113        0, 28n}, request}