Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(24)  |  Call(9)  |  Derive(2)  |  Import(13)
Class used to control a list of watchers.

Options:

- **watchers** -- a list of Watcher objects
- **endpoint** -- the controller ZMQ endpoint
- **pubsub_endpoint** -- the pubsub endpoint
- **statsd** -- If True, a circusd-stats process is run (default: False)
- **stats_endpoint** -- the stats endpoint.
- **statsd_close_outputs** -- if True sends the circusd-stats stdout/stderr(more...)

src/c/i/circus-HEAD/circus/tests/test_arbiter.py   circus(Download)
    from urlparse import urlparse  # NOQA
 
from circus.arbiter import Arbiter
from circus.client import CircusClient
from circus.plugins import CircusPlugin
    def test_start_watcher(self):
        watcher = MockWatcher(name='foo', cmd='serve', priority=1)
        arbiter = Arbiter([], None, None, check_delay=-1)
        yield arbiter.start_watcher(watcher)
        self.assertTrue(watcher.is_active())
 
    def test_start_watchers_with_autostart(self):
        watcher = MockWatcher(name='foo', cmd='serve', priority=1,
                              autostart=False)
        arbiter = Arbiter([], None, None, check_delay=-1)
    def test_add_watcher(self):
        controller = "tcp://127.0.0.1:%d" % get_available_port()
        sub = "tcp://127.0.0.1:%d" % get_available_port()
        arbiter = Arbiter([], controller, sub, loop=get_ioloop(),
                          check_delay=-1)
    def test_start_arbiter_with_autostart(self):
        arbiter = Arbiter([], DEFAULT_ENDPOINT_DEALER, DEFAULT_ENDPOINT_SUB,
                          loop=get_ioloop(),
                          check_delay=-1)
        arbiter.add_watcher('foo', 'sleep 5', autostart=False)

src/c/i/circus-0.10.0/circus/tests/test_arbiter.py   circus(Download)
    from urlparse import urlparse  # NOQA
 
from circus.arbiter import Arbiter
from circus.client import CircusClient
from circus.plugins import CircusPlugin
    def test_start_watcher(self):
        watcher = MockWatcher(name='foo', cmd='serve', priority=1)
        arbiter = Arbiter([], None, None, check_delay=-1)
        yield arbiter.start_watcher(watcher)
        self.assertTrue(watcher.is_active())
 
    def test_start_watchers_with_autostart(self):
        watcher = MockWatcher(name='foo', cmd='serve', priority=1,
                              autostart=False)
        arbiter = Arbiter([], None, None, check_delay=-1)
    def test_add_watcher(self):
        arbiter = Arbiter([], DEFAULT_ENDPOINT_DEALER, DEFAULT_ENDPOINT_SUB,
                          loop=tornado.ioloop.IOLoop.instance(),
                          check_delay=-1)
        arbiter.add_watcher('foo', 'sleep 5')
    def test_circushttpd(self):
        arbiter = Arbiter([], DEFAULT_ENDPOINT_DEALER, DEFAULT_ENDPOINT_SUB,
                          loop=tornado.ioloop.IOLoop.instance(),
                          check_delay=-1, httpd=True, debug=True)
        self.arbiters.append(arbiter)

src/c/i/circus-0.10.0/circus/__init__.py   circus(Download)
    def _get_arbiter_klass(self, background):
        if background:
            from circus.arbiter import ThreadedArbiter as Arbiter   # NOQA
        else:
            from circus.arbiter import Arbiter   # NOQA

src/c/i/circus-HEAD/circus/__init__.py   circus(Download)
    def _get_arbiter_klass(self, background):
        if background:
            from circus.arbiter import ThreadedArbiter as Arbiter   # NOQA
        else:
            from circus.arbiter import Arbiter   # NOQA

src/c/i/circus-0.10.0/circus/green/arbiter.py   circus(Download)
from circus.arbiter import Arbiter as _Arbiter
from circus.green.controller import Controller
 
from zmq.green.eventloop import ioloop
from zmq.green import Context
 
 
class Arbiter(_Arbiter):

src/c/i/circus-HEAD/circus/green/arbiter.py   circus(Download)
from circus.arbiter import Arbiter as _Arbiter
from circus.green.controller import Controller
 
from zmq.green.eventloop import ioloop
from zmq.green import Context
 
 
class Arbiter(_Arbiter):

src/c/i/circus-0.10.0/circus/circusd.py   circus(Download)
 
from circus import logger
from circus.arbiter import Arbiter
from circus.pidfile import Pidfile
from circus import __version__

src/c/i/circus-HEAD/circus/circusd.py   circus(Download)
 
from circus import logger
from circus.arbiter import Arbiter
from circus.pidfile import Pidfile
from circus import __version__

src/c/i/circus-HEAD/circus/tests/test_reloadconfig.py   circus(Download)
import os
import tornado
import tornado.testing
 
from circus.arbiter import Arbiter

src/c/i/circus-HEAD/circus/tests/test_config.py   circus(Download)
 
from circus import logger
from circus.arbiter import Arbiter
from circus.config import get_config
from circus.watcher import Watcher

  1 | 2  Next