Did I find the right examples for you? yes no

All Samples(16)  |  Call(16)  |  Derive(0)  |  Import(0)
A simple HTTP-based transceiver implementation.
Useful for clients but not for servers

src/a/v/avro-python3-1.7.6/avro/tests/sample_http_client.py   avro-python3(Download)
def make_requestor(server_host, server_port, protocol):
  client = ipc.HTTPTransceiver(SERVER_HOST, SERVER_PORT)
  return ipc.Requestor(protocol, client)
 
if __name__ == '__main__':

src/h/a/Hadoop-HEAD/avro-examples/python/ipc/test-client.py   Hadoop(Download)
    proto = protocol.parse(file('test-proto.avpr').read())
 
    client = ipc.HTTPTransceiver('localhost', 8080)
    requestor = ipc.Requestor(proto, client)
 

src/h/a/Hadoop-HEAD/avro-examples/python/ipc/ht-client.py   Hadoop(Download)
    def _request(self, msg, args):
        transceiver = ipc.HTTPTransceiver(self._host, self._port)
        requestor = ipc.Requestor(_PROTO, transceiver)
        response = requestor.request(msg, args)
        transceiver.close()

src/e/v/eventlet-avro-example-HEAD/client.py   eventlet-avro-example(Download)
 
    query = options.query
    client = avro.ipc.HTTPTransceiver(HOST, PORT)
 
    if options.echo:

src/h/u/hue-HEAD/desktop/core/ext-py/avro-1.7.6/src/avro/tool.py   hue(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/h/o/hortonworks-sandbox-HEAD/desktop/core/ext-py/avro-1.5.0/src/avro/tool.py   hortonworks-sandbox(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/a/v/avro-1.7.6/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/a/v/avro3k-1.7.7-SNAPSHOT/src/avro/tool.py   avro3k(Download)
def send_message(uri, proto, msg, datum):
  url_obj = urllib.parse.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/a/v/avro-rpc-quickstart-HEAD/src/main/python/send_message.py   avro-rpc-quickstart(Download)
 
    # client code - attach to the server and send a message
    client = ipc.HTTPTransceiver(server_addr[0], server_addr[1])
    requestor = ipc.Requestor(PROTOCOL, client)
 

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

  1 | 2  Next