# Stubs for cyclone (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

version: str

# Stubs for cyclone.httpclient (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from twisted.internet.protocol import Protocol

from twisted.internet.defer import Deferred

from typing import Any, Callable, Dict, List, Optional

ListType = list

DictType = dict

agent: Any

proxy_agent: Any

class StringProducer:

    body: Any = ...

    length: Any = ...

    def __init__(self, body: Any) -> None: ...

    def startProducing(self, consumer: Any): ...

    def pauseProducing(self) -> None: ...

    def stopProducing(self) -> None: ...

class Receiver(Protocol):

    finished: Any = ...

    data: Any = ...

    def __init__(self, finished: Any) -> None: ...

    def dataReceived(self, bytes: Any) -> None: ...

    def connectionLost(self, reason: Any) -> None: ...

class HTTPClient:

    url: Any = ...

    followRedirect: Any = ...

    maxRedirects: Any = ...

    headers: Any = ...

    body: Any = ...

    proxyConfig: Any = ...

    timeout: Any = ...

    agent: Any = ...

    method: Any = ...

    response: Any = ...

    body_producer: Any = ...

    def __init__(self, url: Any, *args: Any, **kwargs: Any) -> None: ...

    def fetch(self) -> None: ...

class FetchResponse:

    code: int

    phrase: bytes

    headers: Dict[bytes, List[bytes]]

    length: int

    body: bytes

def fetch(

        url: bytes,

        method: bytes=b'GET',

        followRedirect: bool = False,

        maxRedirects: int = 3,

        postdata: Optional[bytes]=None,

        headers: Optional[Dict[bytes, List[bytes]]]=None) -> Deferred[FetchResponse]: ...

class JsonRPC:

    def __init__(self, url: Any, *args: Any, **kwargs: Any) -> None: ...

    def __getattr__(self, attr: Any): ...

# Stubs for cyclone.web (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from twisted.internet import protocol

from typing import Any, Optional

class RequestHandler:

    SUPPORTED_METHODS: Any = ...

    serialize_lists: bool = ...

    no_keep_alive: bool = ...

    xsrf_cookie_name: str = ...

    application: Any = ...

    request: Any = ...

    path_args: Any = ...

    path_kwargs: Any = ...

    ui: Any = ...

    def __init__(self, application: Any, request: Any, **kwargs: Any) -> None: ...

    @property

    def settings(self): ...

    def default(self, *args: Any, **kwargs: Any) -> None: ...

    def prepare(self) -> None: ...

    def on_finish(self) -> None: ...

    def on_connection_close(self, *args: Any, **kwargs: Any) -> None: ...

    def clear(self) -> None: ...

    def set_default_headers(self) -> None: ...

    def set_status(self, status_code: Any, reason: Optional[Any] = ...) -> None: ...

    def get_status(self): ...

    def set_header(self, name: Any, value: Any) -> None: ...

    def add_header(self, name: Any, value: Any) -> None: ...

    def clear_header(self, name: Any) -> None: ...

    def get_argument(self, name: Any, default: Any = ..., strip: bool = ...): ...

    def get_arguments(self, name: Any, strip: bool = ...): ...

    def decode_argument(self, value: Any, name: Optional[Any] = ...): ...

    @property

    def cookies(self): ...

    def get_cookie(self, name: Any, default: Optional[Any] = ...): ...

    def set_cookie(self, name: Any, value: Any, domain: Optional[Any] = ..., expires: Optional[Any] = ..., path: str = ..., expires_days: Optional[Any] = ..., **kwargs: Any) -> None: ...

    def clear_cookie(self, name: Any, path: str = ..., domain: Optional[Any] = ...) -> None: ...

    def clear_all_cookies(self) -> None: ...

    def set_secure_cookie(self, name: Any, value: Any, expires_days: int = ..., **kwargs: Any) -> None: ...

    def create_signed_value(self, name: Any, value: Any): ...

    def get_secure_cookie(self, name: Any, value: Optional[Any] = ..., max_age_days: int = ...): ...

    def redirect(self, url: Any, permanent: bool = ..., status: Optional[Any] = ...) -> None: ...

    def write(self, chunk: Any) -> None: ...

    def render(self, template_name: Any, **kwargs: Any): ...

    def render_string(self, template_name: Any, **kwargs: Any): ...

    def get_template_namespace(self): ...

    def create_template_loader(self, template_path: Any): ...

    def flush(self, include_footers: bool = ...) -> None: ...

    def notifyFinish(self): ...

    def finish(self, chunk: Optional[Any] = ...) -> None: ...

    def send_error(self, status_code: int = ..., **kwargs: Any) -> None: ...

    def write_error(self, status_code: Any, **kwargs: Any) -> None: ...

    @property

    def locale(self): ...

    def get_user_locale(self) -> None: ...

    def get_browser_locale(self, default: str = ...): ...

    @property

    def current_user(self): ...

    def get_current_user(self) -> None: ...

    def get_login_url(self): ...

    def get_template_path(self): ...

    @property

    def xsrf_token(self): ...

    def check_xsrf_cookie(self) -> None: ...

    def xsrf_form_html(self): ...

    def static_url(self, path: Any, include_host: Optional[Any] = ...): ...

    def async_callback(self, callback: Any, *args: Any, **kwargs: Any): ...

    def require_setting(self, name: Any, feature: str = ...) -> None: ...

    def reverse_url(self, name: Any, *args: Any, **kwargs: Any): ...

    def compute_etag(self): ...

def asynchronous(method: Any): ...

def removeslash(method: Any): ...

def addslash(method: Any): ...

class Application(protocol.ServerFactory):

    protocol: Any = ...

    transforms: Any = ...

    handlers: Any = ...

    named_handlers: Any = ...

    error_handler: Any = ...

    default_host: Any = ...

    settings: Any = ...

    ui_modules: Any = ...

    ui_methods: Any = ...

    def __init__(self, handlers: Optional[Any] = ..., default_host: str = ..., transforms: Optional[Any] = ..., error_handler: Optional[Any] = ..., **settings: Any) -> None: ...

    def add_handlers(self, host_pattern: Any, host_handlers: Any) -> None: ...

    def add_transform(self, transform_class: Any) -> None: ...

    def __call__(self, request: Any): ...

    def reverse_url(self, name: Any, *args: Any, **kwargs: Any): ...

    def log_request(self, handler: Any) -> None: ...

class HTTPError(Exception):

    status_code: Any = ...

    log_message: Any = ...

    args: Any = ...

    reason: Any = ...

    def __init__(self, status_code: Any, log_message: Optional[Any] = ..., *args: Any, **kwargs: Any) -> None: ...

class HTTPAuthenticationRequired(HTTPError):

    status_code: int = ...

    log_message: Any = ...

    auth_type: Any = ...

    kwargs: Any = ...

    def __init__(self, log_message: Optional[Any] = ..., auth_type: str = ..., realm: str = ..., **kwargs: Any) -> None: ...

class ErrorHandler(RequestHandler):

    def initialize(self, status_code: Any) -> None: ...

    def prepare(self) -> None: ...

    def check_xsrf_cookie(self) -> None: ...

class RedirectHandler(RequestHandler):

    def initialize(self, url: Any, permanent: bool = ...) -> None: ...

    def get(self) -> None: ...

class StaticFileHandler(RequestHandler):

    CACHE_MAX_AGE: Any = ...

    root: Any = ...

    default_filename: Any = ...

    def initialize(self, path: Any, default_filename: Optional[Any] = ...) -> None: ...

    @classmethod

    def reset(cls) -> None: ...

    def head(self, path: Any) -> None: ...

    def get(self, path: Any, include_body: bool = ...) -> None: ...

    def set_extra_headers(self, path: Any) -> None: ...

    def get_cache_time(self, path: Any, modified: Any, mime_type: Any): ...

    @classmethod

    def make_static_url(cls, settings: Any, path: Any): ...

    @classmethod

    def get_version(cls, settings: Any, path: Any): ...

    def parse_url_path(self, url_path: Any): ...

class FallbackHandler(RequestHandler):

    fallback: Any = ...

    def initialize(self, fallback: Any) -> None: ...

    def prepare(self) -> None: ...

class OutputTransform:

    def __init__(self, request: Any) -> None: ...

    def transform_first_chunk(self, status_code: Any, headers: Any, chunk: Any, finishing: Any): ...

    def transform_chunk(self, chunk: Any, finishing: Any): ...

class GZipContentEncoding(OutputTransform):

    CONTENT_TYPES: Any = ...

    MIN_LENGTH: int = ...

    def __init__(self, request: Any) -> None: ...

    def transform_first_chunk(self, status_code: Any, headers: Any, chunk: Any, finishing: Any): ...

    def transform_chunk(self, chunk: Any, finishing: Any): ...

class ChunkedTransferEncoding(OutputTransform):

    def __init__(self, request: Any) -> None: ...

    def transform_first_chunk(self, status_code: Any, headers: Any, chunk: Any, finishing: Any): ...

    def transform_chunk(self, block: Any, finishing: Any): ...

def authenticated(method: Any): ...

class URLReverseError(Exception): ...

class URLSpec:

    regex: Any = ...

    handler_class: Any = ...

    kwargs: Any = ...

    name: Any = ...

    def __init__(self, pattern: Any, handler_class: Any, kwargs: Optional[Any] = ..., name: Optional[Any] = ...) -> None: ...

    def reverse(self, *args: Any, **kwargs: Any): ...

url = URLSpec

def create_signed_value(secret: Any, name: Any, value: Any): ...

def decode_signed_value(secret: Any, name: Any, value: Any, max_age_days: int = ...): ...

# Stubs for cyclone.websocket (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import cyclone.escape

import cyclone.web

from typing import Any

class _NotEnoughFrame(Exception): ...

class WebSocketHandler(cyclone.web.RequestHandler):

    application: Any = ...

    request: Any = ...

    transport: Any = ...

    ws_protocol: Any = ...

    def __init__(self, application: Any, request: Any, **kwargs: Any) -> None: ...

    def headersReceived(self) -> None: ...

    def connectionMade(self, *args: Any, **kwargs: Any) -> None: ...

    def connectionLost(self, reason: Any) -> None: ...

    def messageReceived(self, message: Any) -> None: ...

    def sendMessage(self, message: Any) -> None: ...

    def forbidConnection(self, message: Any): ...

class WebSocketProtocol:

    handler: Any = ...

    request: Any = ...

    transport: Any = ...

    def __init__(self, handler: Any) -> None: ...

    def acceptConnection(self) -> None: ...

    def rawDataReceived(self, data: Any) -> None: ...

    def sendMessage(self, message: Any) -> None: ...

class WebSocketProtocol17(WebSocketProtocol):

    def __init__(self, handler: Any) -> None: ...

    def acceptConnection(self) -> None: ...

    def rawDataReceived(self, data: Any) -> None: ...

    def sendMessage(self, message: Any, code: int = ...) -> None: ...

class WebSocketProtocol76(WebSocketProtocol):

    def __init__(self, handler: Any) -> None: ...

    def acceptConnection(self) -> None: ...

    def rawDataReceived(self, data: Any) -> None: ...

    def close(self) -> None: ...

    def sendMessage(self, message: Any) -> None: ...

class FrameDecodeError(Exception): ...

class Hixie76FrameDecoder:

    CLOSING_FRAME: Any = ...

    WAIT_FOR_FRAME_TYPE: int = ...

    INSIDE_FRAME: int = ...

    WAIT_FOR_CLOSE: int = ...

    def __init__(self) -> None: ...

    def feed(self, data: Any): ...

# Stubs for cycloneerr (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from .cycloneerr import PrettyErrorHandler

# Stubs for cycloneerr.cycloneerr (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any

class PrettyErrorHandler:

    def get_error_html(self, status_code: Any, **kwargs: Any): ...

# Stubs for cycloneerr.setup (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

# Stubs for cycloneerr.tasks (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any

def release(ctx: Any) -> None: ...

# Stubs for greplin.scales (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import json

from collections import UserDict

from typing import Any, Optional

ID_KEY: str

NEXT_ID: Any

def statsId(obj: Any): ...

def init(obj: Any, context: Optional[Any] = ...): ...

def initChild(obj: Any, name: Any): ...

def initChildOfType(obj: Any, name: Any, subContext: Optional[Any] = ...): ...

def reset() -> None: ...

def getStats(): ...

def setCollapsed(path: Any): ...

class StatContainer(UserDict):

    def __init__(self) -> None: ...

    def setCollapsed(self, isCollapsed: Any) -> None: ...

    def isCollapsed(self): ...

class _Stats:

    stats: Any = ...

    parentMap: Any = ...

    containerMap: Any = ...

    subId: int = ...

    @classmethod

    def reset(cls) -> None: ...

    @classmethod

    def init(cls, obj: Any, context: Any): ...

    @classmethod

    def initChild(cls, obj: Any, name: Any, subContext: Any, parent: Optional[Any] = ...): ...

    @classmethod

    def getContainerForObject(cls, instanceId: Any): ...

    @classmethod

    def getStat(cls, obj: Any, name: Any): ...

    @classmethod

    def getAggregator(cls, instanceId: Any, name: Any): ...

    @classmethod

    def setCollapsed(cls, path: Any) -> None: ...

class Stat:

    def __init__(self, name: Any, value: str = ..., logger: Optional[Any] = ...) -> None: ...

    def getName(self): ...

    def __get__(self, instance: Any, _: Any): ...

    def __set__(self, instance: Any, value: Any) -> None: ...

    def updateItem(self, instance: Any, subKey: Any, value: Any) -> None: ...

    def logger(self, logger: Any): ...

class IntStat(Stat):

    def __init__(self, name: Any, value: int = ...) -> None: ...

class DoubleStat(Stat):

    def __init__(self, name: Any, value: float = ...) -> None: ...

class IntDict(UserDict):

    parent: Any = ...

    instance: Any = ...

    autoDelete: Any = ...

    def __init__(self, parent: Any, instance: Any, autoDelete: bool = ...) -> None: ...

    def __getitem__(self, item: Any): ...

    def __setitem__(self, key: Any, value: Any) -> None: ...

class IntDictStat(Stat):

    autoDelete: Any = ...

    def __init__(self, name: Any, autoDelete: bool = ...) -> None: ...

class StringDict(UserDict):

    parent: Any = ...

    instance: Any = ...

    def __init__(self, parent: Any, instance: Any) -> None: ...

    def __getitem__(self, item: Any): ...

    def __setitem__(self, key: Any, value: Any) -> None: ...

class StringDictStat(Stat): ...

class AggregationStat(Stat):

    def __init__(self, name: Any, value: Any) -> None: ...

    def update(self, instance: Any, oldValue: Any, newValue: Any) -> None: ...

class ChildAggregationStat(Stat):

    def __init__(self, name: Any, value: Any) -> None: ...

    def update(self, instance: Any, oldValue: Any, newValue: Any, subKey: Any) -> None: ...

class SumAggregationStat(AggregationStat):

    def __init__(self, name: Any) -> None: ...

    def update(self, instance: Any, oldValue: Any, newValue: Any) -> None: ...

class HistogramAggregationStat(AggregationStat):

    autoDelete: Any = ...

    def __init__(self, name: Any, autoDelete: bool = ...) -> None: ...

    def update(self, instance: Any, oldValue: Any, newValue: Any) -> None: ...

class IntDictSumAggregationStat(ChildAggregationStat):

    def __init__(self, name: Any) -> None: ...

    def update(self, instance: Any, oldValue: Any, newValue: Any, subKey: Any) -> None: ...

class PmfStatDict(UserDict):

    class TimeManager:

        container: Any = ...

        msg99: Any = ...

        start: Any = ...

        def __init__(self, container: Any) -> None: ...

        def __enter__(self): ...

        def __exit__(self, *_: Any) -> None: ...

        def warn99(self, logger: Any, msg: Any, *args: Any) -> None: ...

        def discard(self) -> None: ...

        def __call__(self, func: Any): ...

    percentile99: Any = ...

    def __init__(self, sample: Optional[Any] = ...) -> None: ...

    def __getitem__(self, item: Any): ...

    def addValue(self, value: Any) -> None: ...

    def time(self): ...

class PmfStat(Stat):

    def __init__(self, name: Any, _: Optional[Any] = ...) -> None: ...

    def __set__(self, instance: Any, value: Any) -> None: ...

class NamedPmfDict(UserDict):

    def __init__(self) -> None: ...

    def __getitem__(self, item: Any): ...

    def __setitem__(self, key: Any, value: Any) -> None: ...

class NamedPmfDictStat(Stat): ...

class StateTimeStatDict(UserDict):

    parent: Any = ...

    instance: Any = ...

    def __init__(self, parent: Any, instance: Any) -> None: ...

    def __getitem__(self, item: Any): ...

    def incr(self, item: Any, value: Any) -> None: ...

    def acquire(self) -> None: ...

class StateTimeStat(Stat):

    state: int = ...

    time: Any = ...

    def __init__(self, name: Any, _: Optional[Any] = ...) -> None: ...

    def __set__(self, instance: Any, value: Any) -> None: ...

def filterCollapsedItems(data: Any): ...

class StatContainerEncoder(json.JSONEncoder):

    def default(self, obj: Any): ...

def dumpStatsTo(filename: Any) -> None: ...

def collection(path: Any, *stats: Any): ...

# Stubs for greplin.scales.aggregation (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any, Optional

class DefaultFormat:

    def getCount(self, data: Any): ...

    def getValue(self, data: Any): ...

class DirectFormat:

    def getCount(self, _: Any): ...

    def getValue(self, data: Any): ...

class TimerFormat:

    def getCount(self, data: Any): ...

    def getValue(self, data: Any): ...

class TimerMeanFormat:

    def getCount(self, data: Any): ...

    def getValue(self, data: Any): ...

class CounterFormat:

    def getCount(self, data: Any): ...

    def getValue(self, data: Any): ...

class MeterFormat:

    def getCount(self, data: Any): ...

    def getValue(self, data: Any): ...

class GaugeFormat:

    def getValue(self, data: Any): ...

class DataFormats:

    DEFAULT: Any = ...

    DIRECT: Any = ...

    TIMER: Any = ...

    TIMER_MEAN: Any = ...

    COUNTER: Any = ...

    METER: Any = ...

    GAUGE: Any = ...

class Aggregator:

    name: Any = ...

    def __init__(self, name: Optional[Any] = ..., dataFormat: Any = ...) -> None: ...

    def clone(self): ...

class Average(Aggregator):

    DEFAULT_NAME: str = ...

    def addValue(self, _: Any, value: Any) -> None: ...

    def result(self): ...

class Sum(Aggregator):

    DEFAULT_NAME: str = ...

    total: int = ...

    def addValue(self, _: Any, value: Any) -> None: ...

    def result(self): ...

class InverseMap(Aggregator):

    DEFAULT_NAME: str = ...

    def __init__(self, *args: Any, **kw: Any) -> None: ...

    def addValue(self, source: Any, data: Any) -> None: ...

    def result(self): ...

class Sorted(Aggregator):

    DEFAULT_NAME: str = ...

    def __init__(self, cmp: Optional[Any] = ..., key: Optional[Any] = ..., reverse: bool = ..., *args: Any, **kw: Any) -> None: ...

    def addValue(self, source: Any, data: Any) -> None: ...

    def result(self): ...

    def clone(self): ...

class Highlight(Aggregator):

    value: Any = ...

    source: Any = ...

    fn: Any = ...

    def __init__(self, name: Any, fn: Any, dataFormat: Any = ...) -> None: ...

    def addValue(self, source: Any, value: Any) -> None: ...

    def result(self): ...

    def clone(self): ...

class Aggregation:

    def __init__(self, aggregators: Any) -> None: ...

    def addSource(self, source: Any, data: Any) -> None: ...

    def addJsonDirectory(self, directory: Any, test: Optional[Any] = ...) -> None: ...

    def result(self, root: Optional[Any] = ...): ...

class FileInclusionTest:

    ignoreByName: Any = ...

    maxAge: Any = ...

    def __init__(self, ignoreByName: Optional[Any] = ..., maxAge: Optional[Any] = ...) -> None: ...

    def __call__(self, _: Any, fullPath: Any): ...

# Stubs for greplin.scales.aggregation_test (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import unittest

class AggregationTest(unittest.TestCase):

    def testNoData(self) -> None: ...

    def testRegex(self) -> None: ...

# Stubs for greplin.scales.bottlehandler (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any

def bottlestats(server_name: Any, path: str = ...): ...

def register_stats_handler(app: Any, server_name: Any, prefix: str = ...) -> None: ...

# Stubs for greplin.scales.clock (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

class BasicClock:

    def time(self): ...

def getClock(): ...

# Stubs for greplin.scales.cyclonehandler (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import cyclone.web

from greplin.scales import tornadolike

class StatsHandler(tornadolike.Handler, cyclone.web.RequestHandler): ...

# Stubs for greplin.scales.formats (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any, Optional

OPERATORS: Any

OPERATOR: Any

def runQuery(statDict: Any, query: Any): ...

def htmlHeader(output: Any, path: Any, serverName: Any, query: Optional[Any] = ...) -> None: ...

def htmlFormat(output: Any, pathParts: Any = ..., statDict: Optional[Any] = ..., query: Optional[Any] = ...) -> None: ...

def jsonFormat(output: Any, statDict: Optional[Any] = ..., query: Optional[Any] = ..., pretty: bool = ...) -> None: ...

# Stubs for greplin.scales.formats_test (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import unittest

from typing import Any

class Root:

    def __init__(self) -> None: ...

    def getChild(self, name: Any, collapsed: Any): ...

class Child:

    countStat: Any = ...

    def __init__(self, name: Any, collapsed: Any) -> None: ...

class StatsTest(unittest.TestCase):

    def setUp(self) -> None: ...

    def testJsonCollapse(self) -> None: ...

class UnicodeFormatTest(unittest.TestCase):

    UNICODE_VALUE: Any = ...

    def testHtmlFormat(self) -> None: ...

    def testJsonFormat(self) -> None: ...

    def testJsonFormatBinaryGarbage(self) -> None: ...

# Stubs for greplin.scales.graphite (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

import threading

from typing import Any, Optional

log: Any

class GraphitePusher:

    rules: Any = ...

    pruneRules: Any = ...

    prefix: Any = ...

    graphite: Any = ...

    def __init__(self, host: Any, port: Any, prefix: Optional[Any] = ...) -> None: ...

    def push(self, statsDict: Optional[Any] = ..., prefix: Optional[Any] = ..., path: Optional[Any] = ...) -> None: ...

    def allow(self, rule: Any) -> None: ...

    def forbid(self, rule: Any) -> None: ...

    def prune(self, rule: Any) -> None: ...

class GraphitePeriodicPusher(threading.Thread, GraphitePusher):

    daemon: bool = ...

    period: Any = ...

    def __init__(self, host: Any, port: Any, prefix: Optional[Any] = ..., period: int = ...) -> None: ...

    def run(self) -> None: ...

# Stubs for greplin.scales.loop (Python 3)

#

# NOTE: This dynamically typed stub was automatically generated by stubgen.

from typing import Any

def installStatsLoop(statsFile: Any, statsDelay: Any) -> None: ...