Module: NATS::Protocol

Defined in:

lib/nats/io/parser.rb

Defined Under Namespace

Classes: Parser

Constant Summary

MSG =

/\AMSG\s+([^\s]+)\s+([^\s]+)\s+(([^\s]+)[^\S\r\n]+)?(\d+)\r\n/i

HMSG =

/\AHMSG\s+([^\s]+)\s+([^\s]+)\s+(([^\s]+)[^\S\r\n]+)?([\d]+)\s+(\d+)\r\n/i

OK =

/\A\+OK\s*\r\n/i

ERR =

/\A-ERR\s+('.+')?\r\n/i

PING =

/\APING\s*\r\n/i

PONG =

/\APONG\s*\r\n/i

INFO =

/\AINFO\s+([^\r\n]+)\r\n/i

UNKNOWN =

/\A(.*)\r\n/

AWAITING_CONTROL_LINE =

1

AWAITING_MSG_PAYLOAD =

2

CR_LF =

"\r\n"

CR_LF_SIZE =

CR_LF.bytesize

PING_REQUEST =

"PING#{CR_LF}".freeze

PONG_RESPONSE =

"PONG#{CR_LF}".freeze

SUB_OP =

"SUB"

EMPTY_MSG =

""