-record(message_metadata, {
    received_at_ms :: integer(),
    transport_latency_ms :: gleam@option:option(integer()),
    peer_address :: gleam@option:option(binary()),
    correlation_id :: gleam@option:option(binary())
}).