module

LavinMQ::ProxyProtocol

https://raw.githubusercontent.com/haproxy/haproxy/master/doc/proxy-protocol.txt

Constants

HANDSHAKE_TIMEOUT = 15.seconds

Bound how long a pre-auth connection may keep the accept fiber (and its FD) parked while we wait for the first bytes. Without this the initial peek blocks forever on a peer that completes the handshake but sends nothing.

Class methods

parse(io : IO, timeout : Time::Span = HANDSHAKE_TIMEOUT) : ConnectionInfo | Nil
Source

Nested types