contrib/zeromq/test-client.py

#!/usr/bin/env python
import sys
import time
import zmq
import TZmqClient
import thrift.protocol.TBinaryProtocol
import storage.ttypes
import storage.Storage


def main(args):
  endpoint = "tcp://127.0.0.1:9090"
  socktype = zmq.REQ
  incr = 0
  if len(args) > 1:
    incr = int(args[1])
    if incr:
      socktype = zmq.DOWNSTREAM
      endpoint = "tcp://127.0.0.1:9091"

  ctx = zmq.Context()
  transport = TZmqClient.TZmqClient(ctx, endpoint, socktype)
  protocol = thrift.protocol.TBinaryProtocol.TBinaryProtocolAccelerated(transport)
  client = storage.Storage.Client(protocol)
  transport.open()

  if incr:
    client.incr(incr)
    time.sleep(0.05)
  else:
    value = client.get()
    print value


if __name__ == "__main__":
  main(sys.argv)