avro.ipc.HTTPTransceiver

All Samples(5) | Call(5) | Derive(0) | Import(0)

A simple HTTP-based transceiver implementation.
Useful for clients but not for servers

src/a/v/avro-1.7.4/src/avro/tool.py avro(Download)

def send_message(uri, proto, msg, datum):
  url_obj = urlparse.urlparse(uri)
  client = ipc.HTTPTransceiver(url_obj.hostname, url_obj.port)
  proto_json = file(proto, 'r').read()
  requestor = ipc.Requestor(protocol.parse(proto_json), client)

src/p/y/pyhbase-HEAD/pyhbase/connection.py pyhbase(Download)

      retry -= 1
      try:
        self.client = ipc.HTTPTransceiver(self.host, self.port)
        self.requestor = ipc.Requestor(PROTOCOL, self.client)
        return

src/p/y/PyHBase-0.1.0/pyhbase/connection.py PyHBase(Download)

      retry -= 1
      try:
        self.client = ipc.HTTPTransceiver(self.host, self.port)
        self.requestor = ipc.Requestor(PROTOCOL, self.client)
        return

src/a/v/avro-1.7.4/test/test_ipc.py avro(Download)

  def test_server_with_path(self):
    client_with_custom_path = ipc.HTTPTransceiver('dummyserver.net', 80, '/service/article')
    self.assertEqual('/service/article', client_with_custom_path.req_resource)
 
    client_with_default_path = ipc.HTTPTransceiver('dummyserver.net', 80)