-record(boundary, {
    mode :: lightspeed@async@backpressure:adapter_mode(),
    max_in_flight :: integer(),
    max_queued :: integer(),
    cancellation_budget_ms :: integer()
}).