Module: Tros::IPC

Defined in:: lib/tros/ipc.rb

Defined Under Namespace

Classes: ConnectionClosedError, ConnectionClosedException, FramedReader, FramedWriter, HTTPTransceiver, Requestor, Responder, SocketTransport, TrosRemoteError, TrosRemoteException

Constant Summary collapse

HANDSHAKE_REQUEST_SCHEMA =

Tros::Schema.parse "{\n  \"type\": \"record\",\n  \"name\": \"HandshakeRequest\", \"namespace\":\"org.apache.tros.ipc\",\n  \"fields\": [\n    {\"name\": \"clientHash\",\n     \"type\": {\"type\": \"fixed\", \"name\": \"MD5\", \"size\": 16}},\n    {\"name\": \"clientProtocol\", \"type\": [\"null\", \"string\"]},\n    {\"name\": \"serverHash\", \"type\": \"MD5\"},\n    {\"name\": \"meta\", \"type\": [\"null\", {\"type\": \"map\", \"values\": \"bytes\"}]}\n  ]\n}\n"

HANDSHAKE_RESPONSE_SCHEMA =

Tros::Schema.parse "{\n  \"type\": \"record\",\n  \"name\": \"HandshakeResponse\", \"namespace\": \"org.apache.tros.ipc\",\n  \"fields\": [\n    {\"name\": \"match\",\n     \"type\": {\"type\": \"enum\", \"name\": \"HandshakeMatch\",\n              \"symbols\": [\"BOTH\", \"CLIENT\", \"NONE\"]}},\n    {\"name\": \"serverProtocol\", \"type\": [\"null\", \"string\"]},\n    {\"name\": \"serverHash\",\n     \"type\": [\"null\", {\"type\": \"fixed\", \"name\": \"MD5\", \"size\": 16}]},\n    {\"name\": \"meta\",\n     \"type\": [\"null\", {\"type\": \"map\", \"values\": \"bytes\"}]}\n  ]\n}\n"

HANDSHAKE_REQUESTOR_WRITER =

Tros::IO::DatumWriter.new(HANDSHAKE_REQUEST_SCHEMA)

HANDSHAKE_REQUESTOR_READER =

Tros::IO::DatumReader.new(HANDSHAKE_RESPONSE_SCHEMA)

HANDSHAKE_RESPONDER_WRITER =

Tros::IO::DatumWriter.new(HANDSHAKE_RESPONSE_SCHEMA)

HANDSHAKE_RESPONDER_READER =

Tros::IO::DatumReader.new(HANDSHAKE_REQUEST_SCHEMA)

META_SCHEMA =

Tros::Schema.parse('{"type": "map", "values": "bytes"}')

META_WRITER =

Tros::IO::DatumWriter.new(META_SCHEMA)

META_READER =

Tros::IO::DatumReader.new(META_SCHEMA)

SYSTEM_ERROR_SCHEMA =

Tros::Schema.parse('["string"]')

REMOTE_HASHES = protocol cache

{}

REMOTE_PROTOCOLS =

{}

BUFFER_HEADER_LENGTH =

BUFFER_SIZE =