def __init__()

in zktraffic/endpoints/endpoints_server.py [0:0]


  def __init__(
      self, iface, zkport, request_handler,
      reply_handler=None, event_handler=None, start_sniffer=True, sampling=1.0):
    config = SnifferConfig(iface=iface)
    config.zookeeper_port = zkport
    config.update_filter()
    config.sampling = sampling

    self._sniffer = Sniffer(config, request_handler, reply_handler, event_handler)

    if start_sniffer:  # pragma: no cover
      self._sniffer.start()

    super(EndpointsServer, self).__init__()