Module: Avro::IPC

Defined in:: lib/avro/ipc.rb

Defined Under Namespace

Classes: AvroRemoteError, AvroRemoteException, ConnectionClosedError, ConnectionClosedException, FramedReader, FramedWriter, HTTPTransceiver, Requestor, Responder, SocketTransport

Constant Summary collapse

HANDSHAKE_REQUEST_SCHEMA =

Avro::Schema.parse <<-JSON
{
  "type": "record",
  "name": "HandshakeRequest", "namespace":"org.apache.avro.ipc",
  "fields": [
    {"name": "clientHash",
     "type": {"type": "fixed", "name": "MD5", "size": 16}},
    {"name": "clientProtocol", "type": ["null", "string"]},
    {"name": "serverHash", "type": "MD5"},
    {"name": "meta", "type": ["null", {"type": "map", "values": "bytes"}]}
  ]
}
JSON

HANDSHAKE_RESPONSE_SCHEMA =

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

HANDSHAKE_REQUESTOR_WRITER =

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

HANDSHAKE_REQUESTOR_READER =

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

HANDSHAKE_RESPONDER_WRITER =

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

HANDSHAKE_RESPONDER_READER =

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

META_SCHEMA =

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

META_WRITER =

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

META_READER =

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

SYSTEM_ERROR_SCHEMA =

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

REMOTE_HASHES = protocol cache

{}

REMOTE_PROTOCOLS =

{}

BUFFER_HEADER_LENGTH =

BUFFER_SIZE =