include/lightspeed@pipeline@operator_Drain.hrl

-record(drain, {reason :: binary()}).