<gh_stars>0
import grpc
import random
import time

from absl import app
from absl import flags
from concurrent import futures

from lib import telemetry

FLAGS = flags.FLAGS

flags.DEFINE_integer('grpc_port', 50090, 'Port for gRPC services.')


def main(argv):
  server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
  telemetry.init('__test__', server)
  server.add_insecure_port('[::]:{0}'.format(FLAGS.grpc_port))
  server.start()

  print 'Running...'
  try:
    while True:
      telemetry.add_counter('counter1', random.randint(1, 10))
      time.sleep(1)
  except:
    server.stop(0)
    raise


if __name__ == '__main__':
  app.run(main)
import grpc
import random
import time

from absl import app
from absl import flags
from concurrent import futures

from lib import telemetry

FLAGS = flags.FLAGS

flags.DEFINE_integer('grpc_port', 50090, 'Port for gRPC services.')


def main(argv):
  server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
  telemetry.init('__test__', server)
  server.add_insecure_port('[::]:{0}'.format(FLAGS.grpc_port))
  server.start()

  print 'Running...'
  try:
    while True:
      telemetry.add_counter('counter1', random.randint(1, 10))
      time.sleep(1)
  except:
    server.stop(0)
    raise


if __name__ == '__main__':
  app.run(main)