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".freeze)

CR_LF_SIZE =

(CR_LF.bytesize)

PING_REQUEST =

("PING#{CR_LF}".freeze)

PONG_RESPONSE =

("PONG#{CR_LF}".freeze)

SUB_OP =

('SUB'.freeze)

EMPTY_MSG =

(''.freeze)