def _query(zk):
     replies = fire(zk, cluster, "info")
     return (
         len(replies),
         [
             [key, "|", hints["ip"], "|", hints["public"], "|", str(hints["ports"][port])]
             for key, (_, hints, code) in sorted(replies.items())
             if code == 200 and port in hints["ports"]
         ],
     )

 def _query(zk):
     return fire(zk, token, 'log')

 def _query(zk):
     replies = fire(zk, self.cluster, 'info')
     return [(seq, hints['application'], hints['task']) for (seq, hints, _) in replies.values()]

 def _query(zk):
     replies = fire(zk, '*', 'info')
     return len(replies), {key: hints for key, (_, hints, code) in replies.items() if code == 200}

 def _query(zk):
     replies = fire(zk, self.cluster, 'info')
     return [(hints['process'], seq) for seq, hints, _ in replies.values() if hints['process'] in target]

 def _query(zk):
     replies = fire(zk, args.clusters, 'info')
     return len(replies), [[key, '|', hints['ip'], '|', hints['node'], '|', hints['process'], '|', hints['state']]
                           for key, (_, hints, code) in sorted(replies.items()) if code == 200]

 def _query(zk):
     replies = fire(zk, qualified, 'info')
     return [(hints['process'], seq) for seq, hints, _ in replies.values()
             if hints['application'] == application and hints['process'] in target]

 def _query(zk):
     replies = fire(zk, self.cluster, 'control/on', subset=self.indices, timeout=self.timeout)
     return len(replies), [seq for seq, (_, _, code) in replies.items() if code == 200]

 def _query(zk):
     replies = fire(zk, self.cluster, 'info', subset=self.indices)
     return [(hints['application'], hints['task']) for _, hints, _ in replies.values()]

 def _query(zk):
     replies = fire(zk, token, 'control/off')
     return len(replies), [pod for pod, (_, hints, code) in replies.items() if code == 200]

 def _query(zk):
     replies = fire(zk, token, 'control/signal', js=json.dumps(payload))
     return len(replies), {key: data for key, (_, data, code) in replies.items() if code == 200}

 def _query(zk):
     replies = fire(zk, self.cluster, 'info')
     return [hints['application'] for key, (_, hints, _) in replies.items() if hints['process'] == 'dead']

 def _query(zk):
     replies = fire(zk, token, 'log', subset=args.indices)
     return len(replies), {key: log for key, (_, log, code) in replies.items() if code == 200}

 def _query(zk):
     replies = fire(zk, token, ('log/app' if args.application else 'log'))
     return len(replies), {key: log for key, (_, log, code) in replies.items() if code == 200}

 def _query(zk):
     replies = fire(zk, token, 'info')
     return len(replies), \
            [[key, '|', hints['ip'], '|', hints['process'], '|', hints['state']] for key, (_, hints, code) in replies.items() if code == 200]

 def _query(zk):
     replies = fire(zk, '*', 'info')
     return len(replies), [hints['node'] for _, (_, hints, code) in replies.items() if code == 200]

 def _query(zk):
     responses = fire(zk, '*', 'info')
     return {key: hints['process'] for key, (_, hints, code) in responses.items() if code == 200}

 def _query(zk):
     replies = fire(zk, self.cluster, 'reset', subset=self.indices)
     return [seq for _, (seq, _, code) in replies.items() if code == 200]

 def _query(zk):
     replies = fire(zk, token, 'info')
     return len(replies), {key: hints['metrics'] for key, (index, hints, code) in replies.items() if code == 200 and 'metrics' in hints}

 def _query(zk):
     replies = fire(zk, qualified, 'info')
     return [(hints['process'], seq) for _, (seq, hints, code) in replies.items() if code == 200]