Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Adding the --ssh option to StatsStreamer

  • Loading branch information...
commit a51b78d584932376b8be86d1aa681ea130cdd9d8 1 parent 5caf239
Nick Pellegrino authored
Showing with 3 additions and 3 deletions.
  1. +1 −1  circus/stats/__init__.py
  2. +2 −2 circus/stats/streamer.py
View
2  circus/stats/__init__.py
@@ -75,7 +75,7 @@ def main():
h.setFormatter(fmt)
logger.addHandler(h)
- stats = StatsStreamer(args.endpoint, args.pubsub, args.statspoint)
+ stats = StatsStreamer(args.endpoint, args.pubsub, args.statspoint, args.ssh)
try:
stats.start()
finally:
View
4 circus/stats/streamer.py
@@ -16,7 +16,7 @@
class StatsStreamer(object):
- def __init__(self, endpoint, pubsub_endoint, stats_endpoint, delay=1.):
+ def __init__(self, endpoint, pubsub_endoint, stats_endpoint, ssh_server, delay=1.):
self.topic = 'watcher.'
self.delay = delay
self.ctx = zmq.Context()
@@ -27,7 +27,7 @@ def __init__(self, endpoint, pubsub_endoint, stats_endpoint, delay=1.):
self.loop = ioloop.IOLoop.instance() # events coming from circusd
self.substream = zmqstream.ZMQStream(self.sub_socket, self.loop)
self.substream.on_recv(self.handle_recv)
- self.client = CircusClient(context=self.ctx, endpoint=endpoint)
+ self.client = CircusClient(context=self.ctx, endpoint=endpoint, ssh_server=ssh_server)
self.cmds = get_commands()
self._pids = defaultdict(list)
self._callbacks = dict()
Please sign in to comment.
Something went wrong with that request. Please try again.