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__()