in zktraffic/omni/omni_sniffer.py [0:0]
def _get_sniffer_type(self, sniffer):
if isinstance(sniffer, Sniffer):
if sniffer._msg_cls == FLE.Message:
return 'fle'
elif sniffer._msg_cls == ZAB.QuorumPacket:
return 'zab'
else:
raise ValueError('Unknown sniffer msg cls %s' % sniffer._msg_cls)
else:
if isinstance(sniffer, ZKSniffer):
return 'zk'
raise ValueError('Unknown sniffer %s' % sniffer)