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

All Samples(23)  |  Call(0)  |  Derive(12)  |  Import(11)
Base class to write plugins.

Options:

- **context** -- the ZMQ context to use
- **endpoint** -- the circusd ZMQ endpoint
- **pubsub_endpoint** -- the circusd ZMQ pub/sub endpoint
- **check_delay** -- the configured check delay
- **config** -- free config mapping

src/c/i/circus-0.10.0/circus/plugins/watchdog.py   circus(Download)
import zmq.utils.jsonapi as json
from zmq.utils.strtypes import u
from circus.plugins import CircusPlugin
from circus import logger
 
 
class WatchDog(CircusPlugin):

src/c/i/circus-0.10.0/circus/plugins/flapping.py   circus(Download)
from circus.fixed_threading import Timer
import time
 
from circus import logger
from circus.plugins import CircusPlugin
class Flapping(CircusPlugin):
    """ Plugin that controls the flapping and stops the watcher in case
        it happens too often.
 
    Plugin Options -- all of them can be overriden in the watcher options

src/c/i/circus-0.10.0/circus/plugins/command_reloader.py   circus(Download)
import os
 
from circus.plugins import CircusPlugin
from circus import logger
from zmq.eventloop import ioloop
 
 
class CommandReloader(CircusPlugin):

src/c/i/circus-HEAD/circus/plugins/watchdog.py   circus(Download)
 
from zmq.eventloop import ioloop
from circus.plugins import CircusPlugin
from circus import logger
 
 
class WatchDog(CircusPlugin):

src/c/i/circus-HEAD/circus/plugins/flapping.py   circus(Download)
from circus.fixed_threading import Timer
import time
 
from circus import logger
from circus.plugins import CircusPlugin
class Flapping(CircusPlugin):
    """ Plugin that controls the flapping and stops the watcher in case
        it happens too often.
 
    Plugin Options -- all of them can be overriden in the watcher options

src/c/i/circus-HEAD/circus/plugins/command_reloader.py   circus(Download)
import os
 
from circus.plugins import CircusPlugin
from circus import logger
from zmq.eventloop import ioloop
 
 
class CommandReloader(CircusPlugin):

src/c/i/circus-0.10.0/circus/plugins/statsd.py   circus(Download)
import socket
from zmq.eventloop import ioloop
from zmq.utils.strtypes import u
from circus.plugins import CircusPlugin
 
class StatsdEmitter(CircusPlugin):
    """Plugin that sends stuff to statsd
    """
    name = 'statsd'
    default_app_name = "app"

src/c/i/circus-HEAD/circus/plugins/statsd.py   circus(Download)
import socket
 
from zmq.eventloop import ioloop
 
from circus.plugins import CircusPlugin
class StatsdEmitter(CircusPlugin):
    """Plugin that sends stuff to statsd
    """
    name = 'statsd'
    default_app_name = "app"

src/t/s/tsuru-circus-0.6.4/tsuru/plugins/__init__.py   tsuru-circus(Download)
import re
 
from circus.plugins import CircusPlugin
from circus.client import CircusClient
 
class ApprcWatcher(CircusPlugin):
    name = "apprc_watcher"
 
    def __init__(self, *args, **config):
        super(ApprcWatcher, self).__init__(*args, **config)
class ProcfileWatcher(CircusPlugin):
    name = "procfile_watcher"
 
    def __init__(self, *args, **config):
        super(ProcfileWatcher, self).__init__(*args, **config)

src/c/i/circus-HEAD/circus/tests/test_arbiter.py   circus(Download)
from circus.arbiter import Arbiter
from circus.client import CircusClient
from circus.plugins import CircusPlugin
from circus.tests.support import TestCircus, async_poll_for, truncate_file
from circus.tests.support import EasyTestSuite, skipIf, get_ioloop
class Plugin(CircusPlugin):
    name = 'dummy'
 
    def __init__(self, *args, **kwargs):
        super(Plugin, self).__init__(*args, **kwargs)

  1 | 2  Next