# HG changeset patch # User drewp@bigasterisk.com # Date 1649094990 25200 # Node ID e2d558d7a5111d3014fa967ec44edde31cada55b # Parent ffd7fd7bc0e67e88dc4817fe48eb8eaab4eab112 rm stubs dir diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/__init__.pyi diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/twisted/__init__.pyi diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/twisted/websocket.pyi --- a/stubs/autobahn/twisted/websocket.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,70 +0,0 @@ -# Stubs for autobahn.twisted.websocket (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import twisted.internet.protocol -from autobahn.websocket import protocol -from autobahn.websocket.interfaces import IWebSocketClientAgent -from typing import Any, Optional - -def create_client_agent(reactor: Any): ... - -class _TwistedWebSocketClientAgent(IWebSocketClientAgent): - def __init__(self, reactor: Any) -> None: ... - def open(self, transport_config: Any, options: Any, protocol_class: Optional[Any] = ...): ... - -class WebSocketAdapterProtocol(twisted.internet.protocol.Protocol): - peer: str = ... - log: Any = ... - def connectionMade(self) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - def dataReceived(self, data: Any) -> None: ... - def registerProducer(self, producer: Any, streaming: Any) -> None: ... - def unregisterProducer(self) -> None: ... - -class WebSocketServerProtocol(WebSocketAdapterProtocol, protocol.WebSocketServerProtocol): - log: Any = ... - def get_channel_id(self, channel_id_type: str = ...): ... - -class WebSocketClientProtocol(WebSocketAdapterProtocol, protocol.WebSocketClientProtocol): - log: Any = ... - def startTLS(self) -> None: ... - def get_channel_id(self, channel_id_type: str = ...): ... - -class WebSocketAdapterFactory: ... - -class WebSocketServerFactory(WebSocketAdapterFactory, protocol.WebSocketServerFactory, twisted.internet.protocol.ServerFactory): - reactor: Any = ... - def __init__(self, *args: Any, **kwargs: Any) -> None: ... - -class WebSocketClientFactory(WebSocketAdapterFactory, protocol.WebSocketClientFactory, twisted.internet.protocol.ClientFactory): - reactor: Any = ... - contextFactory: Any = ... - def __init__(self, *args: Any, **kwargs: Any) -> None: ... - -class WrappingWebSocketAdapter: - def onConnect(self, requestOrResponse: Any): ... - def onOpen(self) -> None: ... - def onMessage(self, payload: Any, isBinary: Any) -> None: ... - def onClose(self, wasClean: Any, code: Any, reason: Any) -> None: ... - def write(self, data: Any) -> None: ... - def writeSequence(self, data: Any) -> None: ... - def loseConnection(self) -> None: ... - def getPeer(self): ... - def getHost(self): ... - -class WrappingWebSocketServerProtocol(WrappingWebSocketAdapter, WebSocketServerProtocol): ... -class WrappingWebSocketClientProtocol(WrappingWebSocketAdapter, WebSocketClientProtocol): ... - -class WrappingWebSocketServerFactory(WebSocketServerFactory): - def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ... - def buildProtocol(self, addr: Any): ... - def startFactory(self) -> None: ... - def stopFactory(self) -> None: ... - -class WrappingWebSocketClientFactory(WebSocketClientFactory): - def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ... - def buildProtocol(self, addr: Any): ... - -def connectWS(factory: Any, contextFactory: Optional[Any] = ..., timeout: int = ..., bindAddress: Optional[Any] = ...): ... -def listenWS(factory: Any, contextFactory: Optional[Any] = ..., backlog: int = ..., interface: str = ...): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/util.pyi --- a/stubs/autobahn/util.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,56 +0,0 @@ -# Stubs for autobahn.util (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -def public(obj: Any): ... -def encode_truncate(text: Any, limit: Any, encoding: str = ..., return_encoded: bool = ...): ... -def xor(d1: Any, d2: Any): ... -def utcstr(ts: Optional[Any] = ...): ... -def utcnow(): ... - -class IdGenerator: - def __init__(self) -> None: ... - def next(self): ... - def __next__(self): ... - -def rid(): ... -def id(): ... -def newid(length: int = ...): ... -def generate_token(char_groups: Any, chars_per_group: Any, chars: Optional[Any] = ..., sep: Optional[Any] = ..., lower_case: bool = ...): ... -def generate_activation_code(): ... -def generate_user_password(): ... -def generate_serial_number(): ... -def rtime(): ... - -class Stopwatch: - def __init__(self, start: bool = ...) -> None: ... - def elapsed(self): ... - def pause(self): ... - def resume(self): ... - def stop(self): ... - -class Tracker: - tracker: Any = ... - tracked: Any = ... - def __init__(self, tracker: Any, tracked: Any) -> None: ... - def track(self, key: Any) -> None: ... - def diff(self, start_key: Any, end_key: Any, formatted: bool = ...): ... - def absolute(self, key: Any): ... - def __getitem__(self, key: Any): ... - def __iter__(self): ... - -class EqualityMixin: - def __eq__(self, other: Any): ... - def __ne__(self, other: Any): ... - -class ObservableMixin: - def set_valid_events(self, valid_events: Optional[Any] = ...) -> None: ... - def on(self, event: Any, handler: Any) -> None: ... - def off(self, event: Optional[Any] = ..., handler: Optional[Any] = ...) -> None: ... - def fire(self, event: Any, *args: Any, **kwargs: Any): ... - -class _LazyHexFormatter: - obj: Any = ... - def __init__(self, obj: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/__init__.pyi --- a/stubs/autobahn/websocket/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,6 +0,0 @@ -# Stubs for autobahn.websocket (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from autobahn.websocket.interfaces import IWebSocketChannel as IWebSocketChannel -from autobahn.websocket.types import ConnectionAccept as ConnectionAccept, ConnectionDeny as ConnectionDeny, ConnectionRequest as ConnectionRequest, ConnectionResponse as ConnectionResponse, IncomingMessage as IncomingMessage, Message as Message, OutgoingMessage as OutgoingMessage diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/compress.pyi --- a/stubs/autobahn/websocket/compress.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for autobahn.websocket.compress (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from autobahn.websocket.compress_base import PerMessageCompress as PerMessageCompress, PerMessageCompressOffer as PerMessageCompressOffer, PerMessageCompressOfferAccept as PerMessageCompressOfferAccept, PerMessageCompressResponse as PerMessageCompressResponse, PerMessageCompressResponseAccept as PerMessageCompressResponseAccept -from autobahn.websocket.compress_bzip2 import PerMessageBzip2 as PerMessageBzip2, PerMessageBzip2Offer as PerMessageBzip2Offer, PerMessageBzip2OfferAccept as PerMessageBzip2OfferAccept, PerMessageBzip2Response as PerMessageBzip2Response, PerMessageBzip2ResponseAccept as PerMessageBzip2ResponseAccept -from autobahn.websocket.compress_deflate import PerMessageDeflate as PerMessageDeflate, PerMessageDeflateOffer as PerMessageDeflateOffer, PerMessageDeflateOfferAccept as PerMessageDeflateOfferAccept, PerMessageDeflateResponse as PerMessageDeflateResponse, PerMessageDeflateResponseAccept as PerMessageDeflateResponseAccept -from typing import Any - -PERMESSAGE_COMPRESSION_EXTENSION: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/compress_base.pyi --- a/stubs/autobahn/websocket/compress_base.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,9 +0,0 @@ -# Stubs for autobahn.websocket.compress_base (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -class PerMessageCompressOffer: ... -class PerMessageCompressOfferAccept: ... -class PerMessageCompressResponse: ... -class PerMessageCompressResponseAccept: ... -class PerMessageCompress: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/compress_bzip2.pyi --- a/stubs/autobahn/websocket/compress_bzip2.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,58 +0,0 @@ -# Stubs for autobahn.websocket.compress_bzip2 (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from autobahn.websocket.compress_base import PerMessageCompress, PerMessageCompressOffer, PerMessageCompressOfferAccept, PerMessageCompressResponse, PerMessageCompressResponseAccept -from typing import Any, Optional - -class PerMessageBzip2Mixin: - EXTENSION_NAME: str = ... - COMPRESS_LEVEL_PERMISSIBLE_VALUES: Any = ... - -class PerMessageBzip2Offer(PerMessageCompressOffer, PerMessageBzip2Mixin): - @classmethod - def parse(cls, params: Any): ... - accept_max_compress_level: Any = ... - request_max_compress_level: Any = ... - def __init__(self, accept_max_compress_level: bool = ..., request_max_compress_level: int = ...) -> None: ... - def get_extension_string(self): ... - def __json__(self): ... - -class PerMessageBzip2OfferAccept(PerMessageCompressOfferAccept, PerMessageBzip2Mixin): - offer: Any = ... - request_max_compress_level: Any = ... - compress_level: Any = ... - def __init__(self, offer: Any, request_max_compress_level: int = ..., compress_level: Optional[Any] = ...) -> None: ... - def get_extension_string(self): ... - def __json__(self): ... - -class PerMessageBzip2Response(PerMessageCompressResponse, PerMessageBzip2Mixin): - @classmethod - def parse(cls, params: Any): ... - client_max_compress_level: Any = ... - server_max_compress_level: Any = ... - def __init__(self, client_max_compress_level: Any, server_max_compress_level: Any) -> None: ... - def __json__(self): ... - -class PerMessageBzip2ResponseAccept(PerMessageCompressResponseAccept, PerMessageBzip2Mixin): - response: Any = ... - compress_level: Any = ... - def __init__(self, response: Any, compress_level: Optional[Any] = ...) -> None: ... - def __json__(self): ... - -class PerMessageBzip2(PerMessageCompress, PerMessageBzip2Mixin): - DEFAULT_COMPRESS_LEVEL: int = ... - @classmethod - def create_from_response_accept(cls, is_server: Any, accept: Any): ... - @classmethod - def create_from_offer_accept(cls, is_server: Any, accept: Any): ... - server_max_compress_level: Any = ... - client_max_compress_level: Any = ... - def __init__(self, is_server: Any, server_max_compress_level: Any, client_max_compress_level: Any) -> None: ... - def __json__(self): ... - def start_compress_message(self) -> None: ... - def compress_message_data(self, data: Any): ... - def end_compress_message(self): ... - def start_decompress_message(self) -> None: ... - def decompress_message_data(self, data: Any): ... - def end_decompress_message(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/compress_deflate.pyi --- a/stubs/autobahn/websocket/compress_deflate.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,75 +0,0 @@ -# Stubs for autobahn.websocket.compress_deflate (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from autobahn.websocket.compress_base import PerMessageCompress, PerMessageCompressOffer, PerMessageCompressOfferAccept, PerMessageCompressResponse, PerMessageCompressResponseAccept -from typing import Any, Optional - -class PerMessageDeflateMixin: - EXTENSION_NAME: str = ... - WINDOW_SIZE_PERMISSIBLE_VALUES: Any = ... - MEM_LEVEL_PERMISSIBLE_VALUES: Any = ... - -class PerMessageDeflateOffer(PerMessageCompressOffer, PerMessageDeflateMixin): - @classmethod - def parse(cls, params: Any): ... - accept_no_context_takeover: Any = ... - accept_max_window_bits: Any = ... - request_no_context_takeover: Any = ... - request_max_window_bits: Any = ... - def __init__(self, accept_no_context_takeover: bool = ..., accept_max_window_bits: bool = ..., request_no_context_takeover: bool = ..., request_max_window_bits: int = ...) -> None: ... - def get_extension_string(self): ... - def __json__(self): ... - -class PerMessageDeflateOfferAccept(PerMessageCompressOfferAccept, PerMessageDeflateMixin): - offer: Any = ... - request_no_context_takeover: Any = ... - request_max_window_bits: Any = ... - no_context_takeover: Any = ... - window_bits: Any = ... - mem_level: Any = ... - max_message_size: Any = ... - def __init__(self, offer: Any, request_no_context_takeover: bool = ..., request_max_window_bits: int = ..., no_context_takeover: Optional[Any] = ..., window_bits: Optional[Any] = ..., mem_level: Optional[Any] = ..., max_message_size: Optional[Any] = ...) -> None: ... - def get_extension_string(self): ... - def __json__(self): ... - -class PerMessageDeflateResponse(PerMessageCompressResponse, PerMessageDeflateMixin): - @classmethod - def parse(cls, params: Any): ... - client_max_window_bits: Any = ... - client_no_context_takeover: Any = ... - server_max_window_bits: Any = ... - server_no_context_takeover: Any = ... - def __init__(self, client_max_window_bits: Any, client_no_context_takeover: Any, server_max_window_bits: Any, server_no_context_takeover: Any) -> None: ... - def __json__(self): ... - -class PerMessageDeflateResponseAccept(PerMessageCompressResponseAccept, PerMessageDeflateMixin): - response: Any = ... - no_context_takeover: Any = ... - window_bits: Any = ... - mem_level: Any = ... - max_message_size: Any = ... - def __init__(self, response: Any, no_context_takeover: Optional[Any] = ..., window_bits: Optional[Any] = ..., mem_level: Optional[Any] = ..., max_message_size: Optional[Any] = ...) -> None: ... - def __json__(self): ... - -class PerMessageDeflate(PerMessageCompress, PerMessageDeflateMixin): - DEFAULT_WINDOW_BITS: Any = ... - DEFAULT_MEM_LEVEL: int = ... - @classmethod - def create_from_response_accept(cls, is_server: Any, accept: Any): ... - @classmethod - def create_from_offer_accept(cls, is_server: Any, accept: Any): ... - server_no_context_takeover: Any = ... - client_no_context_takeover: Any = ... - server_max_window_bits: Any = ... - client_max_window_bits: Any = ... - mem_level: Any = ... - max_message_size: Any = ... - def __init__(self, is_server: Any, server_no_context_takeover: Any, client_no_context_takeover: Any, server_max_window_bits: Any, client_max_window_bits: Any, mem_level: Any, max_message_size: Optional[Any] = ...) -> None: ... - def __json__(self): ... - def start_compress_message(self) -> None: ... - def compress_message_data(self, data: Any): ... - def end_compress_message(self): ... - def start_decompress_message(self) -> None: ... - def decompress_message_data(self, data: Any): ... - def end_decompress_message(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/interfaces.pyi --- a/stubs/autobahn/websocket/interfaces.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,79 +0,0 @@ -# Stubs for autobahn.websocket.interfaces (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import abc -from typing import Any, Optional - -class IWebSocketClientAgent(metaclass=abc.ABCMeta): - def open(self, transport_config: Any, options: Any, protocol_class: Optional[Any] = ...) -> None: ... - -class IWebSocketServerChannelFactory(metaclass=abc.ABCMeta): - @abc.abstractmethod - def __init__(self, url: Optional[Any] = ..., protocols: Optional[Any] = ..., server: Optional[Any] = ..., headers: Optional[Any] = ..., externalPort: Optional[Any] = ...): ... - @abc.abstractmethod - def setSessionParameters(self, url: Optional[Any] = ..., protocols: Optional[Any] = ..., server: Optional[Any] = ..., headers: Optional[Any] = ..., externalPort: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def setProtocolOptions(self, versions: Optional[Any] = ..., webStatus: Optional[Any] = ..., utf8validateIncoming: Optional[Any] = ..., maskServerFrames: Optional[Any] = ..., requireMaskedClientFrames: Optional[Any] = ..., applyMask: Optional[Any] = ..., maxFramePayloadSize: Optional[Any] = ..., maxMessagePayloadSize: Optional[Any] = ..., autoFragmentSize: Optional[Any] = ..., failByDrop: Optional[Any] = ..., echoCloseCodeReason: Optional[Any] = ..., openHandshakeTimeout: Optional[Any] = ..., closeHandshakeTimeout: Optional[Any] = ..., tcpNoDelay: Optional[Any] = ..., perMessageCompressionAccept: Optional[Any] = ..., autoPingInterval: Optional[Any] = ..., autoPingTimeout: Optional[Any] = ..., autoPingSize: Optional[Any] = ..., serveFlashSocketPolicy: Optional[Any] = ..., flashSocketPolicy: Optional[Any] = ..., allowedOrigins: Optional[Any] = ..., allowNullOrigin: bool = ..., maxConnections: Optional[Any] = ..., trustXForwardedFor: int = ...) -> Any: ... - @abc.abstractmethod - def resetProtocolOptions(self) -> Any: ... - -class IWebSocketClientChannelFactory(metaclass=abc.ABCMeta): - @abc.abstractmethod - def __init__(self, url: Optional[Any] = ..., origin: Optional[Any] = ..., protocols: Optional[Any] = ..., useragent: Optional[Any] = ..., headers: Optional[Any] = ..., proxy: Optional[Any] = ...): ... - @abc.abstractmethod - def setSessionParameters(self, url: Optional[Any] = ..., origin: Optional[Any] = ..., protocols: Optional[Any] = ..., useragent: Optional[Any] = ..., headers: Optional[Any] = ..., proxy: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def setProtocolOptions(self, version: Optional[Any] = ..., utf8validateIncoming: Optional[Any] = ..., acceptMaskedServerFrames: Optional[Any] = ..., maskClientFrames: Optional[Any] = ..., applyMask: Optional[Any] = ..., maxFramePayloadSize: Optional[Any] = ..., maxMessagePayloadSize: Optional[Any] = ..., autoFragmentSize: Optional[Any] = ..., failByDrop: Optional[Any] = ..., echoCloseCodeReason: Optional[Any] = ..., serverConnectionDropTimeout: Optional[Any] = ..., openHandshakeTimeout: Optional[Any] = ..., closeHandshakeTimeout: Optional[Any] = ..., tcpNoDelay: Optional[Any] = ..., perMessageCompressionOffers: Optional[Any] = ..., perMessageCompressionAccept: Optional[Any] = ..., autoPingInterval: Optional[Any] = ..., autoPingTimeout: Optional[Any] = ..., autoPingSize: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def resetProtocolOptions(self) -> Any: ... - -class IWebSocketChannel(metaclass=abc.ABCMeta): - @abc.abstractmethod - def onConnect(self, request_or_response: Any) -> Any: ... - @abc.abstractmethod - def onConnecting(self, transport_details: Any) -> Any: ... - @abc.abstractmethod - def onOpen(self) -> Any: ... - @abc.abstractmethod - def sendMessage(self, payload: Any, isBinary: Any) -> Any: ... - @abc.abstractmethod - def onMessage(self, payload: Any, isBinary: Any) -> Any: ... - @abc.abstractmethod - def sendClose(self, code: Optional[Any] = ..., reason: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def onClose(self, wasClean: Any, code: Any, reason: Any) -> Any: ... - @abc.abstractmethod - def sendPing(self, payload: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def onPing(self, payload: Any) -> Any: ... - @abc.abstractmethod - def sendPong(self, payload: Optional[Any] = ...) -> Any: ... - @abc.abstractmethod - def onPong(self, payload: Any) -> Any: ... - -class IWebSocketChannelFrameApi(IWebSocketChannel, metaclass=abc.ABCMeta): - @abc.abstractmethod - def onMessageBegin(self, isBinary: Any) -> Any: ... - @abc.abstractmethod - def onMessageFrame(self, payload: Any) -> Any: ... - @abc.abstractmethod - def onMessageEnd(self) -> Any: ... - @abc.abstractmethod - def beginMessage(self, isBinary: bool = ..., doNotCompress: bool = ...) -> Any: ... - @abc.abstractmethod - def sendMessageFrame(self, payload: Any, sync: bool = ...) -> Any: ... - @abc.abstractmethod - def endMessage(self) -> Any: ... - -class IWebSocketChannelStreamingApi(IWebSocketChannelFrameApi, metaclass=abc.ABCMeta): - @abc.abstractmethod - def onMessageFrameBegin(self, length: Any) -> Any: ... - @abc.abstractmethod - def onMessageFrameData(self, payload: Any) -> Any: ... - @abc.abstractmethod - def onMessageFrameEnd(self) -> Any: ... - @abc.abstractmethod - def beginMessageFrame(self, length: Any) -> Any: ... - @abc.abstractmethod - def sendMessageFrameData(self, payload: Any, sync: bool = ...) -> Any: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/protocol.pyi --- a/stubs/autobahn/websocket/protocol.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,325 +0,0 @@ -# Stubs for autobahn.websocket.protocol (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from autobahn.util import ObservableMixin -from typing import Any, Optional - -xrange = range - -class TrafficStats: - def __init__(self) -> None: ... - outgoingOctetsWireLevel: int = ... - outgoingOctetsWebSocketLevel: int = ... - outgoingOctetsAppLevel: int = ... - outgoingWebSocketFrames: int = ... - outgoingWebSocketMessages: int = ... - incomingOctetsWireLevel: int = ... - incomingOctetsWebSocketLevel: int = ... - incomingOctetsAppLevel: int = ... - incomingWebSocketFrames: int = ... - incomingWebSocketMessages: int = ... - preopenOutgoingOctetsWireLevel: int = ... - preopenIncomingOctetsWireLevel: int = ... - def reset(self) -> None: ... - def __json__(self): ... - -class FrameHeader: - opcode: Any = ... - fin: Any = ... - rsv: Any = ... - length: Any = ... - mask: Any = ... - def __init__(self, opcode: Any, fin: Any, rsv: Any, length: Any, mask: Any) -> None: ... - -class Timings: - def __init__(self) -> None: ... - def track(self, key: Any) -> None: ... - def diff(self, startKey: Any, endKey: Any, formatted: bool = ...): ... - def __getitem__(self, key: Any): ... - def __iter__(self): ... - -class WebSocketProtocol(ObservableMixin): - peer: str = ... - SUPPORTED_SPEC_VERSIONS: Any = ... - SUPPORTED_PROTOCOL_VERSIONS: Any = ... - SPEC_TO_PROTOCOL_VERSION: Any = ... - PROTOCOL_TO_SPEC_VERSION: Any = ... - DEFAULT_SPEC_VERSION: int = ... - MESSAGE_TYPE_TEXT: int = ... - MESSAGE_TYPE_BINARY: int = ... - STATE_CLOSED: int = ... - STATE_CONNECTING: int = ... - STATE_CLOSING: int = ... - STATE_OPEN: int = ... - STATE_PROXY_CONNECTING: int = ... - SEND_STATE_GROUND: int = ... - SEND_STATE_MESSAGE_BEGIN: int = ... - SEND_STATE_INSIDE_MESSAGE: int = ... - SEND_STATE_INSIDE_MESSAGE_FRAME: int = ... - CLOSE_STATUS_CODE_NORMAL: int = ... - CLOSE_STATUS_CODE_GOING_AWAY: int = ... - CLOSE_STATUS_CODE_PROTOCOL_ERROR: int = ... - CLOSE_STATUS_CODE_UNSUPPORTED_DATA: int = ... - CLOSE_STATUS_CODE_RESERVED1: int = ... - CLOSE_STATUS_CODE_NULL: int = ... - CLOSE_STATUS_CODE_ABNORMAL_CLOSE: int = ... - CLOSE_STATUS_CODE_INVALID_PAYLOAD: int = ... - CLOSE_STATUS_CODE_POLICY_VIOLATION: int = ... - CLOSE_STATUS_CODE_MESSAGE_TOO_BIG: int = ... - CLOSE_STATUS_CODE_MANDATORY_EXTENSION: int = ... - CLOSE_STATUS_CODE_INTERNAL_ERROR: int = ... - CLOSE_STATUS_CODE_SERVICE_RESTART: int = ... - CLOSE_STATUS_CODE_TRY_AGAIN_LATER: int = ... - CLOSE_STATUS_CODE_UNASSIGNED1: int = ... - CLOSE_STATUS_CODE_TLS_HANDSHAKE_FAILED: int = ... - CLOSE_STATUS_CODES_ALLOWED: Any = ... - CONFIG_ATTRS_COMMON: Any = ... - CONFIG_ATTRS_SERVER: Any = ... - CONFIG_ATTRS_CLIENT: Any = ... - is_closed: Any = ... - is_open: Any = ... - def __init__(self) -> None: ... - def onOpen(self) -> None: ... - message_is_binary: Any = ... - message_data: Any = ... - message_data_total_length: int = ... - def onMessageBegin(self, isBinary: Any) -> None: ... - frame_length: Any = ... - frame_data: Any = ... - wasMaxMessagePayloadSizeExceeded: bool = ... - wasMaxFramePayloadSizeExceeded: bool = ... - def onMessageFrameBegin(self, length: Any) -> None: ... - def onMessageFrameData(self, payload: Any) -> None: ... - def onMessageFrameEnd(self) -> None: ... - def onMessageFrame(self, payload: Any) -> None: ... - def onMessageEnd(self) -> None: ... - def onMessage(self, payload: Any, isBinary: Any) -> None: ... - def onPing(self, payload: Any) -> None: ... - def onPong(self, payload: Any) -> None: ... - def onClose(self, wasClean: Any, code: Any, reason: Any) -> None: ... - remoteCloseCode: Any = ... - remoteCloseReason: Any = ... - closeHandshakeTimeoutCall: Any = ... - wasClean: bool = ... - serverConnectionDropTimeoutCall: Any = ... - def onCloseFrame(self, code: Any, reasonRaw: Any): ... - wasNotCleanReason: str = ... - wasServerConnectionDropTimeout: bool = ... - def onServerConnectionDropTimeout(self) -> None: ... - openHandshakeTimeoutCall: Any = ... - wasOpenHandshakeTimeout: bool = ... - def onOpenHandshakeTimeout(self) -> None: ... - wasCloseHandshakeTimeout: bool = ... - def onCloseHandshakeTimeout(self) -> None: ... - autoPingTimeoutCall: Any = ... - def onAutoPingTimeout(self) -> None: ... - droppedByMe: bool = ... - state: Any = ... - def dropConnection(self, abort: bool = ...) -> None: ... - trackTimings: Any = ... - trackedTimings: Any = ... - def setTrackTimings(self, enable: Any) -> None: ... - def logRxOctets(self, data: Any) -> None: ... - def logTxOctets(self, data: Any, sync: Any) -> None: ... - def logRxFrame(self, frameHeader: Any, payload: Any) -> None: ... - def logTxFrame(self, frameHeader: Any, payload: Any, repeatLength: Any, chopsize: Any, sync: Any) -> None: ... - def consumeData(self) -> None: ... - def processProxyConnect(self) -> None: ... - def processHandshake(self) -> None: ... - def sendData(self, data: Any, sync: bool = ..., chopsize: Optional[Any] = ...) -> None: ... - def sendPreparedMessage(self, preparedMsg: Any) -> None: ... - current_frame_masker: Any = ... - data: Any = ... - current_frame: Any = ... - def processData(self): ... - control_frame_data: Any = ... - inside_message: bool = ... - utf8validateIncomingCurrentMessage: bool = ... - utf8validateLast: Any = ... - def onFrameBegin(self) -> None: ... - def onFrameData(self, payload: Any): ... - def onFrameEnd(self): ... - autoPingPending: Any = ... - autoPingPendingCall: Any = ... - def processControlFrame(self): ... - def sendFrame(self, opcode: Any, payload: bytes = ..., fin: bool = ..., rsv: int = ..., mask: Optional[Any] = ..., payload_len: Optional[Any] = ..., chopsize: Optional[Any] = ..., sync: bool = ...) -> None: ... - def sendPing(self, payload: Optional[Any] = ...) -> None: ... - def sendPong(self, payload: Optional[Any] = ...) -> None: ... - closedByMe: Any = ... - localCloseCode: Any = ... - localCloseReason: Any = ... - def sendCloseFrame(self, code: Optional[Any] = ..., reasonUtf8: Optional[Any] = ..., isReply: bool = ...) -> None: ... - def sendClose(self, code: Optional[Any] = ..., reason: Optional[Any] = ...) -> None: ... - send_message_opcode: Any = ... - send_state: Any = ... - send_compressed: bool = ... - def beginMessage(self, isBinary: bool = ..., doNotCompress: bool = ...) -> None: ... - send_message_frame_length: Any = ... - send_message_frame_mask: Any = ... - send_message_frame_masker: Any = ... - def beginMessageFrame(self, length: Any) -> None: ... - def sendMessageFrameData(self, payload: Any, sync: bool = ...): ... - def endMessage(self) -> None: ... - def sendMessageFrame(self, payload: Any, sync: bool = ...) -> None: ... - def sendMessage(self, payload: Any, isBinary: bool = ..., fragmentSize: Optional[Any] = ..., sync: bool = ..., doNotCompress: bool = ...) -> None: ... - -class PreparedMessage: - payload: Any = ... - binary: Any = ... - doNotCompress: Any = ... - payloadHybi: Any = ... - def __init__(self, payload: Any, isBinary: Any, applyMask: Any, doNotCompress: Any) -> None: ... - -class WebSocketFactory: - def prepareMessage(self, payload: Any, isBinary: bool = ..., doNotCompress: bool = ...): ... - -class WebSocketServerProtocol(WebSocketProtocol): - log: Any = ... - CONFIG_ATTRS: Any = ... - def onConnect(self, request: Any) -> None: ... - def processProxyConnect(self) -> None: ... - http_request_data: Any = ... - peer: Any = ... - http_request_uri: Any = ... - http_request_path: Any = ... - http_request_params: Any = ... - http_request_host: Any = ... - websocket_version: Any = ... - websocket_protocols: Any = ... - websocket_origin: str = ... - websocket_extensions: Any = ... - data: Any = ... - wasServingFlashSocketPolicyFile: bool = ... - def processHandshake(self): ... - websocket_protocol_in_use: Any = ... - websocket_extensions_in_use: Any = ... - http_response_data: Any = ... - state: Any = ... - openHandshakeTimeoutCall: Any = ... - inside_message: bool = ... - current_frame: Any = ... - autoPingPendingCall: Any = ... - def succeedHandshake(self, res: Any): ... - wasNotCleanReason: Any = ... - def failHandshake(self, reason: Any, code: int = ..., responseHeaders: Optional[Any] = ...) -> None: ... - def sendHttpErrorResponse(self, code: Any, reason: Any, responseHeaders: Optional[Any] = ...) -> None: ... - def sendHtml(self, html: Any) -> None: ... - def sendRedirect(self, url: Any) -> None: ... - def sendServerStatus(self, redirectUrl: Optional[Any] = ..., redirectAfter: int = ...) -> None: ... - -class WebSocketServerFactory(WebSocketFactory): - log: Any = ... - protocol: Any = ... - isServer: bool = ... - logOctets: bool = ... - logFrames: bool = ... - trackTimings: bool = ... - countConnections: int = ... - def __init__(self, url: Optional[Any] = ..., protocols: Optional[Any] = ..., server: Any = ..., headers: Optional[Any] = ..., externalPort: Optional[Any] = ...) -> None: ... - url: Any = ... - isSecure: Any = ... - host: Any = ... - port: Any = ... - resource: Any = ... - path: Any = ... - params: Any = ... - protocols: Any = ... - server: Any = ... - headers: Any = ... - externalPort: Any = ... - def setSessionParameters(self, url: Optional[Any] = ..., protocols: Optional[Any] = ..., server: Optional[Any] = ..., headers: Optional[Any] = ..., externalPort: Optional[Any] = ...) -> None: ... - versions: Any = ... - webStatus: bool = ... - utf8validateIncoming: bool = ... - requireMaskedClientFrames: bool = ... - maskServerFrames: bool = ... - applyMask: bool = ... - maxFramePayloadSize: int = ... - maxMessagePayloadSize: int = ... - autoFragmentSize: int = ... - failByDrop: bool = ... - echoCloseCodeReason: bool = ... - openHandshakeTimeout: int = ... - closeHandshakeTimeout: int = ... - tcpNoDelay: bool = ... - serveFlashSocketPolicy: bool = ... - flashSocketPolicy: str = ... - perMessageCompressionAccept: Any = ... - autoPingInterval: int = ... - autoPingTimeout: int = ... - autoPingSize: int = ... - allowedOrigins: Any = ... - allowedOriginsPatterns: Any = ... - allowNullOrigin: bool = ... - maxConnections: int = ... - trustXForwardedFor: int = ... - def resetProtocolOptions(self) -> None: ... - def setProtocolOptions(self, versions: Optional[Any] = ..., webStatus: Optional[Any] = ..., utf8validateIncoming: Optional[Any] = ..., maskServerFrames: Optional[Any] = ..., requireMaskedClientFrames: Optional[Any] = ..., applyMask: Optional[Any] = ..., maxFramePayloadSize: Optional[Any] = ..., maxMessagePayloadSize: Optional[Any] = ..., autoFragmentSize: Optional[Any] = ..., failByDrop: Optional[Any] = ..., echoCloseCodeReason: Optional[Any] = ..., openHandshakeTimeout: Optional[Any] = ..., closeHandshakeTimeout: Optional[Any] = ..., tcpNoDelay: Optional[Any] = ..., perMessageCompressionAccept: Optional[Any] = ..., autoPingInterval: Optional[Any] = ..., autoPingTimeout: Optional[Any] = ..., autoPingSize: Optional[Any] = ..., serveFlashSocketPolicy: Optional[Any] = ..., flashSocketPolicy: Optional[Any] = ..., allowedOrigins: Optional[Any] = ..., allowNullOrigin: bool = ..., maxConnections: Optional[Any] = ..., trustXForwardedFor: Optional[Any] = ...) -> None: ... - def getConnectionCount(self): ... - -class WebSocketClientProtocol(WebSocketProtocol): - log: Any = ... - CONFIG_ATTRS: Any = ... - def onConnecting(self, transport_details: Any) -> None: ... - def onConnect(self, response: Any) -> None: ... - def startProxyConnect(self) -> None: ... - data: Any = ... - state: Any = ... - def processProxyConnect(self): ... - def failProxyConnect(self, reason: Any) -> None: ... - def startHandshake(self): ... - http_response_data: Any = ... - websocket_extensions_in_use: Any = ... - websocket_protocol_in_use: Any = ... - openHandshakeTimeoutCall: Any = ... - inside_message: bool = ... - current_frame: Any = ... - websocket_version: Any = ... - autoPingPendingCall: Any = ... - def processHandshake(self): ... - wasNotCleanReason: Any = ... - def failHandshake(self, reason: Any) -> None: ... - -class WebSocketClientFactory(WebSocketFactory): - log: Any = ... - protocol: Any = ... - isServer: bool = ... - logOctets: bool = ... - logFrames: bool = ... - trackTimings: bool = ... - def __init__(self, url: Optional[Any] = ..., origin: Optional[Any] = ..., protocols: Optional[Any] = ..., useragent: Any = ..., headers: Optional[Any] = ..., proxy: Optional[Any] = ...) -> None: ... - url: Any = ... - isSecure: Any = ... - host: Any = ... - port: Any = ... - resource: Any = ... - path: Any = ... - params: Any = ... - origin: Any = ... - protocols: Any = ... - useragent: Any = ... - headers: Any = ... - proxy: Any = ... - def setSessionParameters(self, url: Optional[Any] = ..., origin: Optional[Any] = ..., protocols: Optional[Any] = ..., useragent: Optional[Any] = ..., headers: Optional[Any] = ..., proxy: Optional[Any] = ...) -> None: ... - version: Any = ... - utf8validateIncoming: bool = ... - acceptMaskedServerFrames: bool = ... - maskClientFrames: bool = ... - applyMask: bool = ... - maxFramePayloadSize: int = ... - maxMessagePayloadSize: int = ... - autoFragmentSize: int = ... - failByDrop: bool = ... - echoCloseCodeReason: bool = ... - serverConnectionDropTimeout: int = ... - openHandshakeTimeout: int = ... - closeHandshakeTimeout: int = ... - tcpNoDelay: bool = ... - perMessageCompressionOffers: Any = ... - perMessageCompressionAccept: Any = ... - autoPingInterval: int = ... - autoPingTimeout: int = ... - autoPingSize: int = ... - def resetProtocolOptions(self) -> None: ... - def setProtocolOptions(self, version: Optional[Any] = ..., utf8validateIncoming: Optional[Any] = ..., acceptMaskedServerFrames: Optional[Any] = ..., maskClientFrames: Optional[Any] = ..., applyMask: Optional[Any] = ..., maxFramePayloadSize: Optional[Any] = ..., maxMessagePayloadSize: Optional[Any] = ..., autoFragmentSize: Optional[Any] = ..., failByDrop: Optional[Any] = ..., echoCloseCodeReason: Optional[Any] = ..., serverConnectionDropTimeout: Optional[Any] = ..., openHandshakeTimeout: Optional[Any] = ..., closeHandshakeTimeout: Optional[Any] = ..., tcpNoDelay: Optional[Any] = ..., perMessageCompressionOffers: Optional[Any] = ..., perMessageCompressionAccept: Optional[Any] = ..., autoPingInterval: Optional[Any] = ..., autoPingTimeout: Optional[Any] = ..., autoPingSize: Optional[Any] = ...) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/test/__init__.pyi --- a/stubs/autobahn/websocket/test/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,4 +0,0 @@ -# Stubs for autobahn.websocket.test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/test/test_websocket.pyi --- a/stubs/autobahn/websocket/test/test_websocket.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,34 +0,0 @@ -# Stubs for autobahn.websocket.test.test_websocket (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.trial import unittest -from typing import Any - -def create_client_frame(b64patch: Any, **kwargs: Any): ... - -mock_handshake_client: bytes -mock_handshake_server: bytes - -class TestDeflate(unittest.TestCase): - def test_max_size(self) -> None: ... - def test_no_max_size(self) -> None: ... - -class TestClient(unittest.TestCase): - factory: Any = ... - proto: Any = ... - transport: Any = ... - def setUp(self) -> None: ... - def tearDown(self) -> None: ... - def test_missing_reason_raw(self) -> None: ... - def test_unclean_timeout_client(self) -> None: ... - -class TestPing(unittest.TestCase): - factory: Any = ... - proto: Any = ... - transport: Any = ... - def setUp(self) -> None: ... - def tearDown(self) -> None: ... - def test_unclean_timeout(self) -> None: ... - def test_auto_pingpong_timeout(self) -> None: ... - def test_auto_ping_got_pong(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/test/test_websocket_url.pyi --- a/stubs/autobahn/websocket/test/test_websocket_url.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,38 +0,0 @@ -# Stubs for autobahn.websocket.test.test_websocket_url (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest - -class TestCreateWsUrl(unittest.TestCase): - def test_create_url01(self) -> None: ... - def test_create_url02(self) -> None: ... - def test_create_url03(self) -> None: ... - def test_create_url04(self) -> None: ... - def test_create_url05(self) -> None: ... - def test_create_url06(self) -> None: ... - def test_create_url07(self) -> None: ... - def test_create_url08(self) -> None: ... - def test_create_url09(self) -> None: ... - def test_create_url10(self) -> None: ... - def test_create_url11(self) -> None: ... - def test_create_url12(self) -> None: ... - def test_create_url13(self) -> None: ... - def test_create_url14(self) -> None: ... - def test_create_url15(self) -> None: ... - -class TestParseWsUrl(unittest.TestCase): - def test_parse_url01(self) -> None: ... - def test_parse_url02(self) -> None: ... - def test_parse_url03(self) -> None: ... - def test_parse_url04(self) -> None: ... - def test_parse_url05(self) -> None: ... - def test_parse_url06(self) -> None: ... - def test_parse_url07(self) -> None: ... - def test_parse_url08(self) -> None: ... - def test_parse_url09(self) -> None: ... - def test_parse_url10(self) -> None: ... - def test_parse_url11(self) -> None: ... - def test_parse_url12(self) -> None: ... - def test_parse_url13(self) -> None: ... - def test_parse_url14(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/types.pyi --- a/stubs/autobahn/websocket/types.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,80 +0,0 @@ -# Stubs for autobahn.websocket.types (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class ConnectionRequest: - peer: Any = ... - headers: Any = ... - host: Any = ... - path: Any = ... - params: Any = ... - version: Any = ... - origin: Any = ... - protocols: Any = ... - extensions: Any = ... - def __init__(self, peer: Any, headers: Any, host: Any, path: Any, params: Any, version: Any, origin: Any, protocols: Any, extensions: Any) -> None: ... - def __json__(self): ... - -class ConnectingRequest: - host: Any = ... - port: Any = ... - resource: Any = ... - headers: Any = ... - useragent: Any = ... - origin: Any = ... - protocols: Any = ... - def __init__(self, host: Optional[Any] = ..., port: Optional[Any] = ..., resource: Optional[Any] = ..., headers: Optional[Any] = ..., useragent: Optional[Any] = ..., origin: Optional[Any] = ..., protocols: Optional[Any] = ...) -> None: ... - def __json__(self): ... - -class TransportDetails: - peer: Any = ... - is_secure: Any = ... - secure_channel_id: Any = ... - def __init__(self, peer: Any, is_secure: Any, secure_channel_id: Any) -> None: ... - def __json__(self): ... - -class ConnectionResponse: - peer: Any = ... - headers: Any = ... - version: Any = ... - protocol: Any = ... - extensions: Any = ... - def __init__(self, peer: Any, headers: Any, version: Any, protocol: Any, extensions: Any) -> None: ... - def __json__(self): ... - -class ConnectionAccept: - subprotocol: Any = ... - headers: Any = ... - def __init__(self, subprotocol: Optional[Any] = ..., headers: Optional[Any] = ...) -> None: ... - -class ConnectionDeny(Exception): - BAD_REQUEST: int = ... - FORBIDDEN: int = ... - NOT_FOUND: int = ... - NOT_ACCEPTABLE: int = ... - REQUEST_TIMEOUT: int = ... - INTERNAL_SERVER_ERROR: int = ... - NOT_IMPLEMENTED: int = ... - SERVICE_UNAVAILABLE: int = ... - code: Any = ... - reason: Any = ... - def __init__(self, code: Any, reason: Optional[Any] = ...) -> None: ... - -class Message: ... - -class IncomingMessage(Message): - payload: Any = ... - is_binary: Any = ... - def __init__(self, payload: Any, is_binary: bool = ...) -> None: ... - -class OutgoingMessage(Message): - payload: Any = ... - is_binary: Any = ... - skip_compress: Any = ... - def __init__(self, payload: Any, is_binary: bool = ..., skip_compress: bool = ...) -> None: ... - -class Ping: - payload: Any = ... - def __init__(self, payload: Optional[Any] = ...) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/utf8validator.pyi --- a/stubs/autobahn/websocket/utf8validator.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,18 +0,0 @@ -# Stubs for autobahn.websocket.utf8validator (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any -from wsaccel.utf8validator import Utf8Validator as Utf8Validator - -class Utf8Validator: - def __init__(self) -> None: ... - def decode(self, b: Any): ... - def reset(self) -> None: ... - def validate(self, ba: Any): ... - -class Utf8Validator: - def __init__(self) -> None: ... - def decode(self, b: Any): ... - def reset(self) -> None: ... - def validate(self, ba: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/util.pyi --- a/stubs/autobahn/websocket/util.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for autobahn.websocket.util (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -def create_url(hostname: Any, port: Optional[Any] = ..., isSecure: bool = ..., path: Optional[Any] = ..., params: Optional[Any] = ...): ... -def parse_url(url: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/autobahn/websocket/xormasker.pyi --- a/stubs/autobahn/websocket/xormasker.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,27 +0,0 @@ -# Stubs for autobahn.websocket.xormasker (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional -from wsaccel.xormask import createXorMasker - -create_xor_masker = createXorMasker -xrange = range - -class XorMaskerNull: - def __init__(self, mask: Optional[Any] = ...) -> None: ... - def pointer(self): ... - def reset(self) -> None: ... - def process(self, data: Any): ... - -class XorMaskerSimple: - def __init__(self, mask: Any) -> None: ... - def pointer(self): ... - def reset(self) -> None: ... - def process(self, data: Any): ... - -class XorMaskerShifted1: - def __init__(self, mask: Any) -> None: ... - def pointer(self): ... - def reset(self) -> None: ... - def process(self, data: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/__init__.pyi --- a/stubs/cyclone/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,5 +0,0 @@ -# Stubs for cyclone (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -version: str diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/escape.pyi --- a/stubs/cyclone/escape.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1 +0,0 @@ - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/httpclient.pyi --- a/stubs/cyclone/httpclient.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,61 +0,0 @@ -# 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/httpserver.pyi --- a/stubs/cyclone/httpserver.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,43 +0,0 @@ -# Stubs for cyclone.httpserver (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.protocols import basic -from typing import Any, Dict, Optional - -class _BadRequestException(Exception): ... - -class HTTPConnection(basic.LineReceiver): - no_keep_alive: bool = ... - content_length: Any = ... - request_callback: Any = ... - xheaders: Any = ... - def connectionMade(self) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - def notifyFinish(self): ... - def lineReceived(self, line: Any) -> None: ... - def rawDataReceived(self, data: Any) -> None: ... - def write(self, chunk: Any) -> None: ... - def finish(self) -> None: ... - -class HTTPRequest: - method: str = ... - uri: str = ... - version: str = ... - headers: Dict[str, str] = ... - body: bytes = ... - remote_ip: str = ... - protocol: str = ... - host: str = ... - files: Any = ... - connection: HTTPConnection = ... - arguments: Any = ... - def __init__(self, method: Any, uri: Any, version: str = ..., headers: Optional[Any] = ..., body: Optional[Any] = ..., remote_ip: Optional[Any] = ..., protocol: Optional[Any] = ..., host: Optional[Any] = ..., files: Optional[Any] = ..., connection: Optional[Any] = ...) -> None: ... - def supports_http_1_1(self): ... - @property - def cookies(self): ... - def write(self, chunk: Any) -> None: ... - def finish(self) -> None: ... - def full_url(self): ... - def request_time(self): ... - def notifyFinish(self): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/web.pyi --- a/stubs/cyclone/web.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,173 +0,0 @@ -# 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, List, Optional -from .httpserver import HTTPRequest - -class RequestHandler: - SUPPORTED_METHODS: Any = ... - serialize_lists: bool = ... - no_keep_alive: bool = ... - xsrf_cookie_name: str = ... - application: Any = ... - request: HTTPRequest = ... - path_args: Any = ... - path_kwargs: Any = ... - ui: Any = ... - def __init__(self, application: Any, request: HTTPRequest, **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 = ...) -> str: ... - def get_arguments(self, name: Any, strip: bool = ...) -> List[str]: ... - 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 = ...): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/cyclone/websocket.pyi --- a/stubs/cyclone/websocket.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,54 +0,0 @@ -# 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, Dict, Union - -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: bytes) -> None: ... - def sendMessage(self, message: Union[str, Dict]) -> 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: Union[str, Dict]) -> None: ... - -class WebSocketProtocol17(WebSocketProtocol): - def __init__(self, handler: Any) -> None: ... - def acceptConnection(self) -> None: ... - def rawDataReceived(self, data: Any) -> None: ... - def sendMessage(self, message: Union[str, Dict], 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: Union[str, Dict]) -> 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/__init__.pyi --- a/stubs/greplin/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1 +0,0 @@ - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/__init__.pyi --- a/stubs/greplin/scales/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,151 +0,0 @@ -# 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 RecentFpsStat(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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/aggregation.pyi --- a/stubs/greplin/scales/aggregation.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,91 +0,0 @@ -# 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/aggregation_test.pyi --- a/stubs/greplin/scales/aggregation_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,9 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/bottlehandler.pyi --- a/stubs/greplin/scales/bottlehandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/clock.pyi --- a/stubs/greplin/scales/clock.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for greplin.scales.clock (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -class BasicClock: - def time(self): ... - -def getClock(): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/cyclonehandler.pyi --- a/stubs/greplin/scales/cyclonehandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/formats.pyi --- a/stubs/greplin/scales/formats.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,13 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/formats_test.pyi --- a/stubs/greplin/scales/formats_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,24 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/graphite.pyi --- a/stubs/greplin/scales/graphite.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,25 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/loop.pyi --- a/stubs/greplin/scales/loop.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,7 +0,0 @@ -# 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/meter.pyi --- a/stubs/greplin/scales/meter.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,28 +0,0 @@ -# Stubs for greplin.scales.meter (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from collections import UserDict -from greplin.scales import Stat -from typing import Any, Optional - -TICKERS: Any -TICKER_THREAD: Any - -class MeterStatDict(UserDict): - def __init__(self) -> None: ... - def __getitem__(self, item: Any): ... - def tick(self) -> None: ... - def mark(self, value: int = ...) -> None: ... - -class MeterStat(Stat): - def __init__(self, name: Any, _: Optional[Any] = ...) -> None: ... - def __set__(self, instance: Any, value: Any) -> None: ... - -class MeterDict(UserDict): - parent: Any = ... - instance: Any = ... - def __init__(self, parent: Any, instance: Any) -> None: ... - def __getitem__(self, item: Any): ... - -class MeterDictStat(Stat): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/samplestats.pyi --- a/stubs/greplin/scales/samplestats.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,47 +0,0 @@ -# Stubs for greplin.scales.samplestats (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .clock import getClock -from typing import Any - -class Sampler: - min: Any = ... - max: Any = ... - def __init__(self) -> None: ... - def __len__(self): ... - def samples(self): ... - def update(self, value: Any) -> None: ... - @property - def mean(self): ... - @property - def stddev(self): ... - def percentiles(self, percentiles: Any): ... - -class ExponentiallyDecayingReservoir(Sampler): - DEFAULT_SIZE: int = ... - DEFAULT_ALPHA: float = ... - DEFAULT_RESCALE_THRESHOLD: int = ... - values: Any = ... - alpha: Any = ... - size: Any = ... - clock: Any = ... - rescale_threshold: Any = ... - count: int = ... - startTime: Any = ... - nextScaleTime: Any = ... - def __init__(self, size: Any = ..., alpha: Any = ..., rescale_threshold: Any = ..., clock: Any = ...) -> None: ... - def __len__(self): ... - def clear(self) -> None: ... - def update(self, value: Any) -> None: ... - def samples(self): ... - -class UniformSample(Sampler): - sample: Any = ... - count: int = ... - def __init__(self) -> None: ... - def clear(self) -> None: ... - def __len__(self): ... - def update(self, value: Any) -> None: ... - def __iter__(self): ... - def samples(self): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/samplestats_test.pyi --- a/stubs/greplin/scales/samplestats_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,12 +0,0 @@ -# Stubs for greplin.scales.samplestats_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest - -class UniformSampleTest(unittest.TestCase): - def testGaussian(self) -> None: ... - -class ExponentiallyDecayingReservoirTest(unittest.TestCase): - def testGaussian(self) -> None: ... - def testWithRescale(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/scales_test.pyi --- a/stubs/greplin/scales/scales_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,55 +0,0 @@ -# Stubs for greplin.scales.scales_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest -from typing import Any - -class Root1: - stateStat: Any = ... - errorsStat: Any = ... - activeUrlsStat: Any = ... - def __init__(self) -> None: ... - def getChild(self, cls: Any, *args: Any): ... - -class Root2: - def __init__(self) -> None: ... - def getChild(self, cls: Any): ... - -class AggregatingRoot: - countStat: Any = ... - stateStat: Any = ... - errorsStat: Any = ... - def __init__(self) -> None: ... - def getChild(self, cls: Any, *args: Any): ... - -class AggregatingRootSubclass(AggregatingRoot): ... - -class TypedChild: - countStat: Any = ... - def __init__(self) -> None: ... - -class Child: - countStat: Any = ... - stateStat: Any = ... - errorsStat: Any = ... - def __init__(self, name: str = ...) -> None: ... - -class DynamicRoot: - value: int = ... - dynamicStat: Any = ... - def __init__(self) -> None: ... - -class StatsTest(unittest.TestCase): - def setUp(self) -> None: ... - def testChildTypeStats(self) -> None: ... - def testChildStats(self) -> None: ... - def testMultilevelChild(self) -> None: ... - def testStatSum(self) -> None: ... - def testStatSumWithSubclassRoot(self) -> None: ... - def helpTestStatSum(self, a: Any) -> None: ... - def testStatHistogram(self) -> None: ... - def testIntDictStats(self) -> None: ... - def testIntDictStatsAggregation(self) -> None: ... - def testDynamic(self) -> None: ... - def testCollection(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/timer.pyi --- a/stubs/greplin/scales/timer.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,7 +0,0 @@ -# Stubs for greplin.scales.timer (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def RepeatTimer(interval: Any, function: Any, iterations: int = ..., *args: Any, **kwargs: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/tornadolike.pyi --- a/stubs/greplin/scales/tornadolike.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for greplin.scales.tornadolike (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class Handler: - serverName: Any = ... - def initialize(self, serverName: Any) -> None: ... - def get(self, path: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/twistedweb.pyi --- a/stubs/greplin/scales/twistedweb.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,12 +0,0 @@ -# Stubs for greplin.scales.twistedweb (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.web import resource -from typing import Any - -class StatsResource(resource.Resource): - isLeaf: bool = ... - serverName: Any = ... - def __init__(self, serverName: Any) -> None: ... - def render_GET(self, request: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/util.pyi --- a/stubs/greplin/scales/util.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,50 +0,0 @@ -# Stubs for greplin.scales.util (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import threading -from typing import Any, Optional - -log: Any - -def lookup(source: Any, keys: Any, fallback: Optional[Any] = ...): ... - -class GraphiteReporter(threading.Thread): - sock: Any = ... - queue: Any = ... - maxQueueSize: Any = ... - daemon: bool = ... - def __init__(self, host: Any, port: Any, maxQueueSize: int = ...) -> None: ... - def run(self) -> None: ... - def connect(self) -> None: ... - def disconnect(self) -> None: ... - def log(self, name: Any, value: Any, valueType: Optional[Any] = ..., stamp: Optional[Any] = ...) -> None: ... - def enqueue(self, name: Any, value: Any, valueType: Optional[Any] = ..., stamp: Optional[Any] = ...) -> None: ... - def flush(self) -> None: ... - def shutdown(self) -> None: ... - -class AtomicValue: - lock: Any = ... - value: Any = ... - def __init__(self, val: Any) -> None: ... - def update(self, function: Any): ... - def getAndSet(self, newVal: Any): ... - def addAndGet(self, val: Any): ... - -class EWMA: - M1_ALPHA: Any = ... - M5_ALPHA: Any = ... - M15_ALPHA: Any = ... - TICK_RATE: int = ... - @classmethod - def oneMinute(cls): ... - @classmethod - def fiveMinute(cls): ... - @classmethod - def fifteenMinute(cls): ... - alpha: Any = ... - interval: Any = ... - rate: int = ... - def __init__(self, alpha: Any, interval: Any) -> None: ... - def update(self, val: Any) -> None: ... - def tick(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/greplin/scales/util_test.pyi --- a/stubs/greplin/scales/util_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for greplin.scales.util_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest - -class AtomicValueTest(unittest.TestCase): - def testUpdate(self) -> None: ... - def testGetAndSet(self) -> None: ... - def testAddAndGet(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/incremental/__init__.pyi --- a/stubs/incremental/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,29 +0,0 @@ -# Stubs for incremental (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from ._version import __version__ as __version__ -from typing import Any, Optional - -class _inf: - def __cmp__(self, other: Any): ... - -class IncomparableVersions(TypeError): ... - -class Version: - package: Any = ... - major: Any = ... - minor: Any = ... - micro: Any = ... - release_candidate: Any = ... - dev: Any = ... - def __init__(self, package: Any, major: Any, minor: Any, micro: Any, release_candidate: Optional[Any] = ..., prerelease: Optional[Any] = ..., dev: Optional[Any] = ...) -> None: ... - @property - def prerelease(self): ... - def public(self): ... - base: Any = ... - short: Any = ... - local: Any = ... - def __cmp__(self, other: Any): ... - -def getVersionString(version: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/incremental/_version.pyi --- a/stubs/incremental/_version.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,6 +0,0 @@ -# Stubs for incremental._version (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -# Names in __all__ with no definition: -__version__ = None diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/ipdb/__init__.pyi --- a/stubs/ipdb/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,6 +0,0 @@ -# Stubs for ipdb (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - - -def set_trace(): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/__init__.pyi --- a/stubs/rdflib/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,24 +0,0 @@ -# Stubs for rdflib (Python 3.4) -# -from typing import Tuple, Union - - -# this is the 1st way that worked. 'from rdflib.term import URIRef' did not work. -import rdflib.namespace as _n -Namespace = _n.Namespace - -RDF: Namespace -RDFS: Namespace -XSD: Namespace - -import rdflib.term as _t -URIRef = _t.URIRef -Literal = _t.Literal -BNode = _t.BNode - -import rdflib.graph as _g -ConjunctiveGraph = _g.ConjunctiveGraph -Graph = _g.Graph - -# not part of rdflib -StatementType = Tuple[Union[URIRef, BNode], URIRef, _t.Node, URIRef] diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/graph.pyi --- a/stubs/rdflib/graph.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,169 +0,0 @@ -# Stubs for rdflib.graph (Python 3.4) -# - - -from typing import Any, Optional, Tuple, Sequence, Iterable -from io import StringIO as BytesIO -from rdflib import StatementType -from rdflib.term import Node, URIRef - -# real Graph is a subclass of Node, but I have bugs where the context -# in a statement is the wrong one of Graph or URIRef, so I want that to be more clear. -class Graph: - context_aware = ... # type: Any - formula_aware = ... # type: Any - def __init__(self, store='', identifier: Optional[URIRef]=None, namespace_manager=None): ... - store = ... # type: Any - identifier: URIRef = ... - namespace_manager = ... # type: Any - def toPython(self): ... - def destroy(self, configuration): ... - def commit(self): ... - def rollback(self): ... - def open(self, configuration, create=False): ... - def close(self, commit_pending_transaction=False): ... - def add(self, xxx_todo_changeme): ... - def addN(self, quads: Iterable[StatementType]): ... - def remove(self, xxx_todo_changeme1): ... - def triples(self, xxx_todo_changeme2) -> Sequence[Tuple[Node, Node, Node]]: ... - def __getitem__(self, item): ... - def __len__(self) -> int: ... - def __iter__(self): ... - def __contains__(self, triple) -> bool: ... - def __hash__(self): ... - def md5_term_hash(self): ... - def __cmp__(self, other): ... - def __eq__(self, other): ... - def __lt__(self, other): ... - def __le__(self, other): ... - def __gt__(self, other): ... - def __ge__(self, other): ... - def __iadd__(self, other): ... - def __isub__(self, other): ... - def __add__(self, other): ... - def __mul__(self, other): ... - def __sub__(self, other): ... - def __xor__(self, other): ... - __or__ = ... # type: Any - __and__ = ... # type: Any - def set(self, triple): ... - def subjects(self, predicate=None, object=None) -> Sequence[Node]: ... - def predicates(self, subject=None, object=None) -> Sequence[Node]: ... - def objects(self, subject=None, predicate=None) -> Sequence[Node]: ... - def subject_predicates(self, object=None) -> Sequence[Tuple[Node, Node]]: ... - def subject_objects(self, predicate=None) -> Sequence[Tuple[Node, Node]]: ... - def predicate_objects(self, subject=None) -> Sequence[Tuple[Node, Node]]: ... - def triples_choices(self, xxx_todo_changeme3, context=None): ... - def value(self, subject=None, predicate=..., object=None, default=None, any=True) -> Optional[Node]: ... - def label(self, subject, default='') -> Optional[Node]: ... - def preferredLabel(self, subject, lang=None, default=None, labelProperties=...): ... - def comment(self, subject, default=''): ... - def items(self, list): ... - def transitiveClosure(self, func, arg, seen=None): ... - def transitive_objects(self, subject, property, remember=None): ... - def transitive_subjects(self, predicate, object, remember=None): ... - def seq(self, subject): ... - def qname(self, uri): ... - def compute_qname(self, uri, generate=True): ... - def bind(self, prefix, namespace, override=True): ... - def namespaces(self): ... - def absolutize(self, uri, defrag=1): ... - def serialize(self, destination=None, format='', base=None, encoding=None, **args): ... - def parse(self, source=None, publicID=None, format=None, location=None, file=None, data=None, **args): ... - def load(self, source, publicID=None, format=''): ... - def query(self, query_object, processor='', result='', initNs=None, initBindings=None, use_store_provided=True, **kwargs): ... - def update(self, update_object, processor='', initNs=..., initBindings=..., use_store_provided=True, **kwargs): ... - def n3(self): ... - def __reduce__(self): ... - def isomorphic(self, other): ... - def connected(self): ... - def all_nodes(self): ... - def resource(self, identifier): ... - def skolemize(self, new_graph=None, bnode=None): ... - def de_skolemize(self, new_graph=None, uriref=None): ... - -class ConjunctiveGraph(Graph): - context_aware = ... # type: Any - default_context = ... # type: Any - def __init__(self, store='', identifier=None): ... - def __contains__(self, triple_or_quad): ... - def add(self, xxx_todo_changeme4): ... - def addN(self, quads: Iterable[StatementType]): ... - def remove(self, xxx_todo_changeme5): ... - def triples(self, xxx_todo_changeme6, context=None): ... - def quads(self, pattern=None) -> Iterable[StatementType]: ... - def triples_choices(self, xxx_todo_changeme7): ... - def __len__(self): ... - def contexts(self, triple=None): ... - def get_context(self, identifier, quoted=False): ... - def remove_context(self, context): ... - def context_id(self, uri, context_id=None): ... - def parse(self, source=None, publicID=None, format='', location=None, file=None, data=None, **args): ... - def __reduce__(self): ... - -class Dataset(ConjunctiveGraph): - __doc__ = ... # type: Any - DEFAULT = ... # type: Any - graph_names = ... # type: Any - def __init__(self, store=''): ... - def graph(self, identifier=None): ... - def remove_graph(self, g): ... - def graphs(self, empty=True): ... - def add_quad(self, quad): ... - def remove_quad(self, xxx_todo_changeme8): ... - def quads(self, quad): ... - -class QuotedGraph(Graph): - def __init__(self, store, identifier): ... - def add(self, triple): ... - def addN(self, quads): ... - def n3(self): ... - def __reduce__(self): ... - -class GraphValue(QuotedGraph): - def __init__(self, store, identifier=None, graph=None): ... - def add(self, triple): ... - def remove(self, triple): ... - def __reduce__(self): ... - -class Seq: - def __init__(self, graph, subject): ... - def toPython(self): ... - def __iter__(self): ... - def __len__(self): ... - def __getitem__(self, index): ... - -class ModificationException(Exception): - def __init__(self): ... - -class UnSupportedAggregateOperation(Exception): - def __init__(self): ... - -class ReadOnlyGraphAggregate(ConjunctiveGraph): - graphs = ... # type: Any - def __init__(self, graphs, store=''): ... - def destroy(self, configuration): ... - def commit(self): ... - def rollback(self): ... - def open(self, configuration, create=False): ... - def close(self): ... - def add(self, xxx_todo_changeme12): ... - def addN(self, quads): ... - def remove(self, xxx_todo_changeme13): ... - def triples(self, xxx_todo_changeme14): ... - def __contains__(self, triple_or_quad): ... - def quads(self, xxx_todo_changeme15): ... - def __len__(self): ... - def __hash__(self): ... - def __cmp__(self, other): ... - def __iadd__(self, other): ... - def __isub__(self, other): ... - def triples_choices(self, xxx_todo_changeme16, context=None): ... - def qname(self, uri): ... - def compute_qname(self, uri, generate=True): ... - def bind(self, prefix, namespace, override=True): ... - def namespaces(self): ... - def absolutize(self, uri, defrag=1): ... - def parse(self, source, publicID=None, format='', **args): ... - def n3(self): ... - def __reduce__(self): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/namespace.pyi --- a/stubs/rdflib/namespace.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,60 +0,0 @@ -# Stubs for rdflib.namespace (Python 3.4) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class Namespace(str): - __doc__ = ... # type: Any - def __new__(cls, value): ... - @property - def title(self): ... - def term(self, name): ... - def __getitem__(self, key, default=None): ... - def __getattr__(self, name): ... - -class URIPattern(str): - __doc__ = ... # type: Any - def __new__(cls, value): ... - def __mod__(self, *args, **kwargs): ... - def format(self, *args, **kwargs): ... - -class ClosedNamespace: - uri = ... # type: Any - def __init__(self, uri, terms): ... - def term(self, name): ... - def __getitem__(self, key, default=None): ... - def __getattr__(self, name): ... - -class _RDFNamespace(ClosedNamespace): - def __init__(self): ... - def term(self, name): ... - -RDF = ... # type: Any -RDFS = ... # type: Any -OWL = ... # type: Any -XSD = ... # type: Any -SKOS = ... # type: Any -DOAP = ... # type: Any -FOAF = ... # type: Any -DC = ... # type: Any -DCTERMS = ... # type: Any -VOID = ... # type: Any - -class NamespaceManager: - graph = ... # type: Any - def __init__(self, graph): ... - def reset(self): ... - store = ... # type: Any - def qname(self, uri): ... - def normalizeUri(self, rdfTerm): ... - def compute_qname(self, uri, generate=True): ... - def bind(self, prefix, namespace, override=True): ... - def namespaces(self): ... - def absolutize(self, uri, defrag=1): ... - -def is_ncname(name): ... - -XMLNS = ... # type: Any - -def split_uri(uri): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/parser.pyi --- a/stubs/rdflib/parser.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,26 +0,0 @@ -# Stubs for rdflib.parser (Python 3.4) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any -from io import StringIO as BytesIO - -class Parser: - def __init__(self): ... - def parse(self, source, sink): ... - -class InputSource: # subclass of xmlreader - ... - - -class StringInputSource(InputSource): - def __init__(self, value, system_id=None): ... - -class URLInputSource(InputSource): - url = ... # type: Any - content_type = ... # type: Any - def __init__(self, system_id=None, format=None): ... - -class FileInputSource(InputSource): - file = ... # type: Any - def __init__(self, file): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/plugins/__init__.pyi --- a/stubs/rdflib/plugins/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1 +0,0 @@ - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/plugins/serializers/__init__.pyi --- a/stubs/rdflib/plugins/serializers/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1 +0,0 @@ - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/plugins/serializers/nt.pyi --- a/stubs/rdflib/plugins/serializers/nt.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,16 +0,0 @@ -# Stubs for rdflib.plugins.serializers.nt (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rdflib.serializer import Serializer -from typing import Any, Optional - -class NTSerializer(Serializer): - encoding: str = ... - def __init__(self, store: Any) -> None: ... - def serialize(self, stream: Any, base: Optional[Any] = ..., encoding: Optional[Any] = ..., **args: Any) -> None: ... - -class NT11Serializer(NTSerializer): - def __init__(self, store: Any) -> None: ... - -_quoteLiteral: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/plugins/serializers/turtle.pyi --- a/stubs/rdflib/plugins/serializers/turtle.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,60 +0,0 @@ -# Stubs for rdflib.plugins.serializers.turtle (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rdflib.serializer import Serializer -from typing import Any, Optional, Callable - -class RecursiveSerializer(Serializer): - topClasses: Any = ... - predicateOrder: Any = ... - maxDepth: int = ... - indentString: str = ... - stream: Any = ... - def __init__(self, store: Any) -> None: ... - def addNamespace(self, prefix: Any, uri: Any) -> None: ... - def checkSubject(self, subject: Any): ... - def isDone(self, subject: Any): ... - def orderSubjects(self): ... - def preprocess(self) -> None: ... - def preprocessTriple(self, xxx_todo_changeme: Any) -> None: ... - depth: int = ... - lists: Any = ... - namespaces: Any = ... - def reset(self) -> None: ... - def buildPredicateHash(self, subject: Any): ... - def sortProperties(self, properties: Any): ... - def subjectDone(self, subject: Any) -> None: ... - def indent(self, modifier: int = ...): ... - def write(self, text: Any) -> None: ... - -class TurtleSerializer(RecursiveSerializer): - short_name: str = ... - indentString: str = ... - keywords: Any = ... - stream: Any = ... - def __init__(self, store: Any) -> None: ... - def addNamespace(self, prefix: Any, namespace: Any): ... - def reset(self) -> None: ... - base: Any = ... - def serialize(self, stream: Any, base: Optional[Any] = ..., encoding: Optional[Any] = ..., spacious: Optional[Any] = ..., **args: Any) -> None: ... - def preprocessTriple(self, triple: Any) -> None: ... - def getQName(self, uri: Any, gen_prefix: bool = ...): ... - def startDocument(self) -> None: ... - def endDocument(self) -> None: ... - def statement(self, subject: Any): ... - def s_default(self, subject: Any): ... - def s_squared(self, subject: Any): ... - def path(self, node: Any, position: Any, newline: bool = ...) -> None: ... - def p_default(self, node: Any, position: Any, newline: bool = ...): ... - def label(self, node: Any, position: Any): ... - def p_squared(self, node: Any, position: Any, newline: bool = ...): ... - def isValidList(self, l: Any): ... - def doList(self, l: Any) -> None: ... - def predicateList(self, subject: Any, newline: bool = ...) -> None: ... - def verb(self, node: Any, newline: bool = ...) -> None: ... - def objectList(self, objects: Any) -> None: ... - -OBJECT: Any -VERB: Any -_GEN_QNAME_FOR_DT: Callable diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/serializer.pyi --- a/stubs/rdflib/serializer.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,3 +0,0 @@ -class Serializer: - ... - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/rdflib/term.pyi --- a/stubs/rdflib/term.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,75 +0,0 @@ -# Stubs for rdflib.term (Python 3) -# - -from typing import Any, Optional - -class Node: ... - -class Identifier(Node, str): - def __new__(cls, value: Any): ... - def eq(self, other: Any): ... - def neq(self, other: Any): ... - def __ne__(self, other: Any): ... - def __eq__(self, other: Any): ... - def __gt__(self, other: Any): ... - def __lt__(self, other: Any): ... - def __le__(self, other: Any): ... - def __ge__(self, other: Any): ... - def __hash__(self): ... - -class URIRef(Identifier): - def __new__(cls, value: Any, base: Optional[Any] = ...): ... - def toPython(self): ... - def n3(self, namespace_manager: Optional[Any] = ...): ... - def defrag(self): ... - def __reduce__(self): ... - def __getnewargs__(self): ... - def __add__(self, other: Any): ... - def __radd__(self, other: Any): ... - def __mod__(self, other: Any): ... - def md5_term_hash(self): ... - def de_skolemize(self): ... - -class BNode(Identifier): - def __new__(cls, value: Optional[Any] = ..., _sn_gen: Any = ..., _prefix: Any = ...): ... - def toPython(self): ... - def n3(self, namespace_manager: Optional[Any] = ...): ... - def __getnewargs__(self): ... - def __reduce__(self): ... - def md5_term_hash(self): ... - def skolemize(self, authority: str = ...): ... - -class Literal(Identifier): - _literal_n3: Any - def __new__(cls, lexical_or_value: Any, lang: Optional[Any] = ..., datatype: Optional[Any] = ..., normalize: Optional[Any] = ...): ... - def normalize(self): ... - @property - def value(self): ... - @property - def language(self): ... - @property - def datatype(self): ... - def __reduce__(self): ... - def __add__(self, val: Any): ... - def __bool__(self): ... - def __neg__(self): ... - def __pos__(self): ... - def __abs__(self): ... - def __invert__(self): ... - def __gt__(self, other: Any): ... - def __lt__(self, other: Any): ... - def __le__(self, other: Any): ... - def __ge__(self, other: Any): ... - def __hash__(self): ... - def __eq__(self, other: Any): ... - def eq(self, other: Any): ... - def neq(self, other: Any): ... - def n3(self, namespace_manager: Optional[Any] = ...): ... - def toPython(self): ... - def md5_term_hash(self): ... - -def bind(datatype: Any, pythontype: Any, constructor: Optional[Any] = ..., lexicalizer: Optional[Any] = ...) -> None: ... - -_PLAIN_LITERAL_TYPES: Any -_XSD_DOUBLE: Any -_XSD_DECIMAL: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/__init__.pyi --- a/stubs/scales/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,149 +0,0 @@ -# Stubs for 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/aggregation.pyi --- a/stubs/scales/aggregation.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,91 +0,0 @@ -# Stubs for 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/aggregation_test.pyi --- a/stubs/scales/aggregation_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,9 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/bottlehandler.pyi --- a/stubs/scales/bottlehandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/clock.pyi --- a/stubs/scales/clock.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for scales.clock (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -class BasicClock: - def time(self): ... - -def getClock(): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/cyclonehandler.pyi --- a/stubs/scales/cyclonehandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for 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): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/flaskhandler.pyi --- a/stubs/scales/flaskhandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,9 +0,0 @@ -# Stubs for scales.flaskhandler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def statsHandler(serverName: Any, path: str = ...): ... -def registerStatsHandler(app: Any, serverName: Any, prefix: str = ...) -> None: ... -def serveInBackground(port: Any, serverName: Any, prefix: str = ...): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/formats.pyi --- a/stubs/scales/formats.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,13 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/formats_test.pyi --- a/stubs/scales/formats_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,24 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/graphite.pyi --- a/stubs/scales/graphite.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,25 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/loop.pyi --- a/stubs/scales/loop.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,7 +0,0 @@ -# Stubs for 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: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/meter.pyi --- a/stubs/scales/meter.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,28 +0,0 @@ -# Stubs for scales.meter (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from collections import UserDict -from greplin.scales import Stat -from typing import Any, Optional - -TICKERS: Any -TICKER_THREAD: Any - -class MeterStatDict(UserDict): - def __init__(self) -> None: ... - def __getitem__(self, item: Any): ... - def tick(self) -> None: ... - def mark(self, value: int = ...) -> None: ... - -class MeterStat(Stat): - def __init__(self, name: Any, _: Optional[Any] = ...) -> None: ... - def __set__(self, instance: Any, value: Any) -> None: ... - -class MeterDict(UserDict): - parent: Any = ... - instance: Any = ... - def __init__(self, parent: Any, instance: Any) -> None: ... - def __getitem__(self, item: Any): ... - -class MeterDictStat(Stat): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/samplestats.pyi --- a/stubs/scales/samplestats.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,47 +0,0 @@ -# Stubs for scales.samplestats (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .clock import getClock -from typing import Any - -class Sampler: - min: Any = ... - max: Any = ... - def __init__(self) -> None: ... - def __len__(self): ... - def samples(self): ... - def update(self, value: Any) -> None: ... - @property - def mean(self): ... - @property - def stddev(self): ... - def percentiles(self, percentiles: Any): ... - -class ExponentiallyDecayingReservoir(Sampler): - DEFAULT_SIZE: int = ... - DEFAULT_ALPHA: float = ... - DEFAULT_RESCALE_THRESHOLD: int = ... - values: Any = ... - alpha: Any = ... - size: Any = ... - clock: Any = ... - rescale_threshold: Any = ... - count: int = ... - startTime: Any = ... - nextScaleTime: Any = ... - def __init__(self, size: Any = ..., alpha: Any = ..., rescale_threshold: Any = ..., clock: Any = ...) -> None: ... - def __len__(self): ... - def clear(self) -> None: ... - def update(self, value: Any) -> None: ... - def samples(self): ... - -class UniformSample(Sampler): - sample: Any = ... - count: int = ... - def __init__(self) -> None: ... - def clear(self) -> None: ... - def __len__(self): ... - def update(self, value: Any) -> None: ... - def __iter__(self): ... - def samples(self): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/samplestats_test.pyi --- a/stubs/scales/samplestats_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,12 +0,0 @@ -# Stubs for scales.samplestats_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest - -class UniformSampleTest(unittest.TestCase): - def testGaussian(self) -> None: ... - -class ExponentiallyDecayingReservoirTest(unittest.TestCase): - def testGaussian(self) -> None: ... - def testWithRescale(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/scales_test.pyi --- a/stubs/scales/scales_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,55 +0,0 @@ -# Stubs for scales.scales_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest -from typing import Any - -class Root1: - stateStat: Any = ... - errorsStat: Any = ... - activeUrlsStat: Any = ... - def __init__(self) -> None: ... - def getChild(self, cls: Any, *args: Any): ... - -class Root2: - def __init__(self) -> None: ... - def getChild(self, cls: Any): ... - -class AggregatingRoot: - countStat: Any = ... - stateStat: Any = ... - errorsStat: Any = ... - def __init__(self) -> None: ... - def getChild(self, cls: Any, *args: Any): ... - -class AggregatingRootSubclass(AggregatingRoot): ... - -class TypedChild: - countStat: Any = ... - def __init__(self) -> None: ... - -class Child: - countStat: Any = ... - stateStat: Any = ... - errorsStat: Any = ... - def __init__(self, name: str = ...) -> None: ... - -class DynamicRoot: - value: int = ... - dynamicStat: Any = ... - def __init__(self) -> None: ... - -class StatsTest(unittest.TestCase): - def setUp(self) -> None: ... - def testChildTypeStats(self) -> None: ... - def testChildStats(self) -> None: ... - def testMultilevelChild(self) -> None: ... - def testStatSum(self) -> None: ... - def testStatSumWithSubclassRoot(self) -> None: ... - def helpTestStatSum(self, a: Any) -> None: ... - def testStatHistogram(self) -> None: ... - def testIntDictStats(self) -> None: ... - def testIntDictStatsAggregation(self) -> None: ... - def testDynamic(self) -> None: ... - def testCollection(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/timer.pyi --- a/stubs/scales/timer.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,7 +0,0 @@ -# Stubs for scales.timer (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def RepeatTimer(interval: Any, function: Any, iterations: int = ..., *args: Any, **kwargs: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/tornadohandler.pyi --- a/stubs/scales/tornadohandler.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,8 +0,0 @@ -# Stubs for scales.tornadohandler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import tornado.web -from greplin.scales import tornadolike - -class StatsHandler(tornadolike.Handler, tornado.web.RequestHandler): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/tornadolike.pyi --- a/stubs/scales/tornadolike.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for scales.tornadolike (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class Handler: - serverName: Any = ... - def initialize(self, serverName: Any) -> None: ... - def get(self, path: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/twistedweb.pyi --- a/stubs/scales/twistedweb.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,12 +0,0 @@ -# Stubs for scales.twistedweb (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.web import resource -from typing import Any - -class StatsResource(resource.Resource): - isLeaf: bool = ... - serverName: Any = ... - def __init__(self, serverName: Any) -> None: ... - def render_GET(self, request: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/util.pyi --- a/stubs/scales/util.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,50 +0,0 @@ -# Stubs for scales.util (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import threading -from typing import Any, Optional - -log: Any - -def lookup(source: Any, keys: Any, fallback: Optional[Any] = ...): ... - -class GraphiteReporter(threading.Thread): - sock: Any = ... - queue: Any = ... - maxQueueSize: Any = ... - daemon: bool = ... - def __init__(self, host: Any, port: Any, maxQueueSize: int = ...) -> None: ... - def run(self) -> None: ... - def connect(self) -> None: ... - def disconnect(self) -> None: ... - def log(self, name: Any, value: Any, valueType: Optional[Any] = ..., stamp: Optional[Any] = ...) -> None: ... - def enqueue(self, name: Any, value: Any, valueType: Optional[Any] = ..., stamp: Optional[Any] = ...) -> None: ... - def flush(self) -> None: ... - def shutdown(self) -> None: ... - -class AtomicValue: - lock: Any = ... - value: Any = ... - def __init__(self, val: Any) -> None: ... - def update(self, function: Any): ... - def getAndSet(self, newVal: Any): ... - def addAndGet(self, val: Any): ... - -class EWMA: - M1_ALPHA: Any = ... - M5_ALPHA: Any = ... - M15_ALPHA: Any = ... - TICK_RATE: int = ... - @classmethod - def oneMinute(cls): ... - @classmethod - def fiveMinute(cls): ... - @classmethod - def fifteenMinute(cls): ... - alpha: Any = ... - interval: Any = ... - rate: int = ... - def __init__(self, alpha: Any, interval: Any) -> None: ... - def update(self, val: Any) -> None: ... - def tick(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/scales/util_test.pyi --- a/stubs/scales/util_test.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for scales.util_test (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import unittest - -class AtomicValueTest(unittest.TestCase): - def testUpdate(self) -> None: ... - def testGetAndSet(self) -> None: ... - def testAddAndGet(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/treq/__init__.pyi --- a/stubs/treq/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,6 +0,0 @@ -# Stubs for treq (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from treq.api import delete as delete, get as get, head as head, patch as patch, post as post, put as put, request as request -from treq.content import collect as collect, content as content, json_content as json_content, text_content as text_content diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/treq/api.pyi --- a/stubs/treq/api.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,15 +0,0 @@ -# Stubs for treq.api (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional, Union - -DataArg = Union[bytes] # str, file-like, IBodyProducer, or None - -def head(url: str, **kwargs: Any): ... -def get(url: str, headers: Optional[Any] = ..., **kwargs: Any): ... -def post(url: str, data: Optional[DataArg] = ..., **kwargs: Any): ... -def put(url: str, data: Optional[DataArg] = ..., **kwargs: Any): ... -def patch(url: str, data: Optional[DataArg] = ..., **kwargs: Any): ... -def delete(url: str, **kwargs: Any): ... -def request(method: str, url: str, **kwargs: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/treq/content.pyi --- a/stubs/treq/content.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,18 +0,0 @@ -# Stubs for treq.content (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.internet.protocol import Protocol -from typing import Any - -class _BodyCollector(Protocol): - finished: Any = ... - collector: Any = ... - def __init__(self, finished: Any, collector: Any) -> None: ... - def dataReceived(self, data: Any) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - -def collect(response: Any, collector: Any): ... -def content(response: Any): ... -def json_content(response: Any, **kwargs: Any): ... -def text_content(response: Any, encoding: str = ...): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/__init__.pyi --- a/stubs/twisted/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1 +0,0 @@ - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/__init__.pyi --- a/stubs/twisted/internet/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,30 +0,0 @@ -# Stubs for twisted.internet (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional -from .interfaces import IDelayedCall, IAddress, IListeningPort -import twisted.internet.protocol - -class ReactorType: # abridged - def listenTCP(self, port: int, factory: twisted.internet.protocol.ServerFactory, backlog: Optional[int] =50, interface: str = ...) -> IListeningPort: ... - def connectTCP(self, host :bytes, port: int, factory: twisted.internet.protocol.ClientFactory, timeout: Optional[float] = 30): ... - def seconds(self) -> None: ... - def callLater(self, delay: Any, callable: Any, *args: Any, **kw: Any) -> IDelayedCall: ... - def getDelayedCalls(self) -> None: ... - def callFromThread(self, callable: Any, *args: Any, **kw: Any) -> None: ... - def callInThread(self, callable: Any, *args: Any, **kwargs: Any) -> None: ... - running: Any = ... - def resolve(self, name: Any, timeout: int = ...) -> None: ... - def run(self) -> None: ... - def stop(self) -> None: ... - def crash(self) -> None: ... - def iterate(self, delay: int = ...) -> None: ... - def fireSystemEvent(self, eventType: Any) -> None: ... - def addSystemEventTrigger(self, phase: Any, eventType: Any, callable: Any, *args: Any, **kw: Any) -> None: ... - def removeSystemEventTrigger(self, triggerID: Any) -> None: ... - def callWhenRunning(self, callable: Any, *args: Any, **kw: Any) -> None: ... - - -reactor = ReactorType() - diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/abstract.pyi --- a/stubs/twisted/internet/abstract.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,51 +0,0 @@ -# Stubs for twisted.internet.abstract (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class _ConsumerMixin: - producer: Any = ... - producerPaused: bool = ... - streamingProducer: bool = ... - def startWriting(self) -> None: ... - def registerProducer(self, producer: Any, streaming: Any) -> None: ... - def unregisterProducer(self) -> None: ... - -class _LogOwner: - def logPrefix(self): ... - -class FileDescriptor(_ConsumerMixin, _LogOwner): - connected: int = ... - disconnected: int = ... - disconnecting: int = ... - dataBuffer: bytes = ... - offset: int = ... - SEND_LIMIT: Any = ... - reactor: Any = ... - def __init__(self, reactor: Optional[Any] = ...) -> None: ... - producer: Any = ... - def connectionLost(self, reason: Any) -> None: ... - def writeSomeData(self, data: Any) -> None: ... - def doRead(self) -> None: ... - producerPaused: bool = ... - def doWrite(self): ... - def writeConnectionLost(self, reason: Any) -> None: ... - def readConnectionLost(self, reason: Any) -> None: ... - def write(self, data: Any) -> None: ... - def writeSequence(self, iovec: Any) -> None: ... - def loseConnection(self, _connDone: Any = ...) -> None: ... - def loseWriteConnection(self) -> None: ... - def stopReading(self) -> None: ... - def stopWriting(self) -> None: ... - def startReading(self) -> None: ... - def startWriting(self) -> None: ... - bufferSize: Any = ... - def stopConsuming(self) -> None: ... - def resumeProducing(self) -> None: ... - def pauseProducing(self) -> None: ... - def stopProducing(self) -> None: ... - def fileno(self): ... - -def isIPAddress(addr: Any, family: Any = ...): ... -def isIPv6Address(addr: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/defer.pyi --- a/stubs/twisted/internet/defer.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,126 +0,0 @@ -# Stubs for twisted.internet.defer (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.python import lockfile -from typing import Any, Callable, Generic, Optional, TypeVar - -class AlreadyCalledError(Exception): ... -class CancelledError(Exception): ... -class TimeoutError(Exception): ... - -def succeed(result: Any): ... -def fail(result: Optional[Any] = ...): ... -def maybeDeferred(f: Any, *args: Any, **kw: Any): ... - -T = TypeVar('T') -class Deferred(Generic[T]): - called: bool = ... - paused: bool = ... - debug: bool = ... - callbacks: Any = ... - def __init__(self, canceller: Optional[Any] = ...) -> None: ... - def addCallbacks(self, - callback: Callable[[T], Any], - errback: Optional[Any] = ..., - callbackArgs: Optional[Any] = ..., - callbackKeywords: Optional[Any] = ..., - errbackArgs: Optional[Any] = ..., - errbackKeywords: Optional[Any] = ...): ... - def addCallback(self, callback: Callable[[T], Any], *args: Any, **kw: Any): ... - def addErrback(self, errback: Any, *args: Any, **kw: Any): ... - def addBoth(self, callback: Callable[[T], Any], *args: Any, **kw: Any): ... - def addTimeout(self, timeout: Any, clock: Any, onTimeoutCancel: Optional[Any] = ...): ... - def chainDeferred(self, d: Any): ... - def callback(self, result: T) -> None: ... - def errback(self, fail: Optional[Any] = ...) -> None: ... - def pause(self) -> None: ... - def unpause(self) -> None: ... - def cancel(self) -> None: ... - def __iter__(self): ... - def send(self, value: Optional[Any] = ...): ... - __await__: Any = ... - __next__: Any = ... - def asFuture(self, loop: Any): ... - @classmethod - def fromFuture(cls, future: Any): ... - -def ensureDeferred(coro: Any): ... - -class DebugInfo: - failResult: Any = ... - def __del__(self) -> None: ... - -class FirstError(Exception): - subFailure: Any = ... - index: Any = ... - def __init__(self, failure: Any, index: Any) -> None: ... - def __cmp__(self, other: Any): ... - -class DeferredList(Deferred): - fireOnOneCallback: bool = ... - fireOnOneErrback: bool = ... - resultList: Any = ... - consumeErrors: Any = ... - finishedCount: int = ... - def __init__(self, deferredList: Any, fireOnOneCallback: bool = ..., fireOnOneErrback: bool = ..., consumeErrors: bool = ...) -> None: ... - def cancel(self) -> None: ... - -def gatherResults(deferredList: Any, consumeErrors: bool = ...): ... - -SUCCESS: bool -FAILURE: bool - -class waitForDeferred: - d: Any = ... - def __init__(self, d: Any) -> None: ... - def getResult(self): ... - -def deferredGenerator(f: Any): ... - -class _DefGen_Return(BaseException): - value: Any = ... - def __init__(self, value: Any) -> None: ... - -def returnValue(val: Any) -> None: ... - -class _InternalInlineCallbacksCancelledError(Exception): ... - -def inlineCallbacks(f: Any): ... - -class _ConcurrencyPrimitive: - waiting: Any = ... - def __init__(self) -> None: ... - def run(*args: Any, **kwargs: Any): ... - -class DeferredLock(_ConcurrencyPrimitive): - locked: bool = ... - def acquire(self): ... - def release(self) -> None: ... - -class DeferredSemaphore(_ConcurrencyPrimitive): - tokens: Any = ... - limit: Any = ... - def __init__(self, tokens: Any) -> None: ... - def acquire(self): ... - def release(self) -> None: ... - -class QueueOverflow(Exception): ... -class QueueUnderflow(Exception): ... - -class DeferredQueue: - waiting: Any = ... - pending: Any = ... - size: Any = ... - backlog: Any = ... - def __init__(self, size: Optional[Any] = ..., backlog: Optional[Any] = ...) -> None: ... - def put(self, obj: Any) -> None: ... - def get(self): ... - -class AlreadyTryingToLockError(Exception): ... - -class DeferredFilesystemLock(lockfile.FilesystemLock): - def __init__(self, name: Any, scheduler: Optional[Any] = ...) -> None: ... - def deferUntilLocked(self, timeout: Optional[Any] = ...): ... - -def setDebugging(yes: bool) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/error.pyi --- a/stubs/twisted/internet/error.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,84 +0,0 @@ -# Stubs for twisted.internet.error (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class BindError(Exception): ... - -class CannotListenError(BindError): - interface: Any = ... - port: Any = ... - socketError: Any = ... - def __init__(self, interface: Any, port: Any, socketError: Any) -> None: ... - -class MulticastJoinError(Exception): ... -class MessageLengthError(Exception): ... -class DNSLookupError(IOError): ... -class ConnectInProgressError(Exception): ... - -class ConnectError(Exception): - osError: Any = ... - def __init__(self, osError: Optional[Any] = ..., string: str = ...) -> None: ... - -class ConnectBindError(ConnectError): ... -class UnknownHostError(ConnectError): ... -class NoRouteError(ConnectError): ... -class ConnectionRefusedError(ConnectError): ... -class TCPTimedOutError(ConnectError): ... -class BadFileError(ConnectError): ... -class ServiceNameUnknownError(ConnectError): ... -class UserError(ConnectError): ... -class TimeoutError(UserError): ... -class SSLError(ConnectError): ... -class VerifyError(Exception): ... -class PeerVerifyError(VerifyError): ... -class CertificateError(Exception): ... - -def getConnectError(e: Any): ... - -class ConnectionClosed(Exception): ... -class ConnectionLost(ConnectionClosed): ... -class ConnectionAborted(ConnectionLost): ... -class ConnectionDone(ConnectionClosed): ... -class FileDescriptorOverrun(ConnectionLost): ... -class ConnectionFdescWentAway(ConnectionLost): ... -class AlreadyCalled(ValueError): ... -class AlreadyCancelled(ValueError): ... - -class PotentialZombieWarning(Warning): - MESSAGE: str = ... - -class ProcessDone(ConnectionDone): - exitCode: int = ... - signal: Any = ... - status: Any = ... - def __init__(self, status: Any) -> None: ... - -class ProcessTerminated(ConnectionLost): - exitCode: Any = ... - signal: Any = ... - status: Any = ... - def __init__(self, exitCode: Optional[Any] = ..., signal: Optional[Any] = ..., status: Optional[Any] = ...) -> None: ... - -class ProcessExitedAlready(Exception): ... -class NotConnectingError(RuntimeError): ... -class NotListeningError(RuntimeError): ... -class ReactorNotRunning(RuntimeError): ... -class ReactorNotRestartable(RuntimeError): ... -class ReactorAlreadyRunning(RuntimeError): ... -class ReactorAlreadyInstalledError(AssertionError): ... - -class ConnectingCancelledError(Exception): - address: Any = ... - def __init__(self, address: Any) -> None: ... - -class NoProtocol(Exception): ... -class UnsupportedAddressFamily(Exception): ... -class UnsupportedSocketType(Exception): ... -class AlreadyListened(Exception): ... - -class InvalidAddressError(ValueError): - address: Any = ... - message: Any = ... - def __init__(self, address: Any, message: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/fdesc.pyi --- a/stubs/twisted/internet/fdesc.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for twisted.internet.fdesc (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def setNonBlocking(fd: Any) -> None: ... -def setBlocking(fd: Any) -> None: ... -def readFromFD(fd: Any, callback: Any): ... -def writeToFD(fd: Any, data: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/inotify.pyi --- a/stubs/twisted/internet/inotify.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,49 +0,0 @@ -# Stubs for twisted.internet.inotify (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.internet.abstract import FileDescriptor -from typing import Any, Optional - -IN_ACCESS: int -IN_MODIFY: int -IN_ATTRIB: int -IN_CLOSE_WRITE: int -IN_CLOSE_NOWRITE: int -IN_OPEN: int -IN_MOVED_FROM: int -IN_MOVED_TO: int -IN_CREATE: int -IN_DELETE: int -IN_DELETE_SELF: int -IN_MOVE_SELF: int -IN_UNMOUNT: int -IN_Q_OVERFLOW: int -IN_IGNORED: int -IN_ONLYDIR: int -IN_DONT_FOLLOW: int -IN_MASK_ADD: int -IN_ISDIR: int -IN_ONESHOT: int -IN_CLOSE: Any -IN_MOVED: Any -IN_CHANGED: Any -IN_WATCH_MASK: Any - -def humanReadableMask(mask: Any): ... - -class _Watch: - path: Any = ... - mask: Any = ... - autoAdd: Any = ... - callbacks: Any = ... - def __init__(self, path: Any, mask: Any = ..., autoAdd: bool = ..., callbacks: Optional[Any] = ...) -> None: ... - -class INotify(FileDescriptor): - connected: int = ... - def __init__(self, reactor: Optional[Any] = ...) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - def fileno(self): ... - def doRead(self) -> None: ... - def watch(self, path: Any, mask: Any = ..., autoAdd: bool = ..., callbacks: Optional[Any] = ..., recursive: bool = ...): ... - def ignore(self, path: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/interfaces.pyi --- a/stubs/twisted/internet/interfaces.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,20 +0,0 @@ -from typing import Any - -class IDelayedCall: - def getTime(self) -> Any: ... - def cancel(self) -> None: ... - def delay(self, secondsLater: Any) -> None: ... - def reset(self, secondsFromNow: Any) -> None: ... - def active(self) -> None: ... - - -class IAddress: # this is https://twistedmatrix.com/documents/current/api/twisted.internet.address.IPv4Address.html - type: str - host: str - port: int - -class IListeningPort: - def startListening(self): ... - def stopListening(self): ... # returns deferred - def getHost(self) -> IAddress: ... - _realPortNumber: int # from t.i.tcp.Port diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/protocol.pyi --- a/stubs/twisted/internet/protocol.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,138 +0,0 @@ -# Stubs for twisted.internet.protocol (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.python import components -from typing import Any, Optional - -class Factory: - protocol: Any = ... - numPorts: int = ... - noisy: bool = ... - @classmethod - def forProtocol(cls, protocol: Any, *args: Any, **kwargs: Any): ... - def logPrefix(self): ... - def doStart(self) -> None: ... - def doStop(self) -> None: ... - def startFactory(self) -> None: ... - def stopFactory(self) -> None: ... - def buildProtocol(self, addr: Any): ... - -class ClientFactory(Factory): - def startedConnecting(self, connector: Any) -> None: ... - def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ... - def clientConnectionLost(self, connector: Any, reason: Any) -> None: ... - -class _InstanceFactory(ClientFactory): - noisy: bool = ... - pending: Any = ... - reactor: Any = ... - instance: Any = ... - deferred: Any = ... - def __init__(self, reactor: Any, instance: Any, deferred: Any) -> None: ... - def buildProtocol(self, addr: Any): ... - def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ... - def fire(self, func: Any, value: Any) -> None: ... - -class ClientCreator: - reactor: Any = ... - protocolClass: Any = ... - args: Any = ... - kwargs: Any = ... - def __init__(self, reactor: Any, protocolClass: Any, *args: Any, **kwargs: Any) -> None: ... - def connectTCP(self, host: Any, port: Any, timeout: int = ..., bindAddress: Optional[Any] = ...): ... - def connectUNIX(self, address: Any, timeout: int = ..., checkPID: bool = ...): ... - def connectSSL(self, host: Any, port: Any, contextFactory: Any, timeout: int = ..., bindAddress: Optional[Any] = ...): ... - -class ReconnectingClientFactory(ClientFactory): - maxDelay: int = ... - initialDelay: float = ... - factor: float = ... - jitter: float = ... - delay: Any = ... - retries: int = ... - maxRetries: Any = ... - connector: Any = ... - clock: Any = ... - continueTrying: int = ... - def clientConnectionFailed(self, connector: Any, reason: Any) -> None: ... - def clientConnectionLost(self, connector: Any, unused_reason: Any) -> None: ... - def retry(self, connector: Optional[Any] = ...) -> None: ... - def stopTrying(self) -> None: ... - def resetDelay(self) -> None: ... - -class ServerFactory(Factory): ... - -class BaseProtocol: - connected: int = ... - transport: Any = ... - def makeConnection(self, transport: Any) -> None: ... - def connectionMade(self) -> None: ... - -connectionDone: Any - -class Protocol(BaseProtocol): - def logPrefix(self): ... - def dataReceived(self, data: Any) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - -class ProtocolToConsumerAdapter(components.Adapter): - def write(self, data: Any) -> None: ... - def registerProducer(self, producer: Any, streaming: Any) -> None: ... - def unregisterProducer(self) -> None: ... - -class ConsumerToProtocolAdapter(components.Adapter): - def dataReceived(self, data: Any) -> None: ... - def connectionLost(self, reason: Any) -> None: ... - def makeConnection(self, transport: Any) -> None: ... - def connectionMade(self) -> None: ... - -class ProcessProtocol(BaseProtocol): - def childDataReceived(self, childFD: Any, data: Any) -> None: ... - def outReceived(self, data: Any) -> None: ... - def errReceived(self, data: Any) -> None: ... - def childConnectionLost(self, childFD: Any) -> None: ... - def inConnectionLost(self) -> None: ... - def outConnectionLost(self) -> None: ... - def errConnectionLost(self) -> None: ... - def processExited(self, reason: Any) -> None: ... - def processEnded(self, reason: Any) -> None: ... - -class AbstractDatagramProtocol: - transport: Any = ... - numPorts: int = ... - noisy: bool = ... - def doStart(self) -> None: ... - def doStop(self) -> None: ... - def startProtocol(self) -> None: ... - def stopProtocol(self) -> None: ... - def makeConnection(self, transport: Any) -> None: ... -# def datagramReceived(self, datagram: Any, addr: Any) -> None: ... - -class DatagramProtocol(AbstractDatagramProtocol): - def logPrefix(self): ... - def connectionRefused(self) -> None: ... - -class ConnectedDatagramProtocol(DatagramProtocol): -# def datagramReceived(self, datagram: Any) -> None: ... - def connectionFailed(self, failure: Any) -> None: ... - -class FileWrapper: - closed: int = ... - disconnecting: int = ... - producer: Any = ... - streamingProducer: int = ... - file: Any = ... - def __init__(self, file: Any) -> None: ... - def write(self, data: Any) -> None: ... - def registerProducer(self, producer: Any, streaming: Any) -> None: ... - def unregisterProducer(self) -> None: ... - def stopConsuming(self) -> None: ... - def writeSequence(self, iovec: Any) -> None: ... - def loseConnection(self) -> None: ... - def getPeer(self): ... - def getHost(self): ... - def handleException(self) -> None: ... - def resumeProducing(self) -> None: ... - def pauseProducing(self) -> None: ... - def stopProducing(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/task.pyi --- a/stubs/twisted/internet/task.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,69 +0,0 @@ -# Stubs for twisted.internet.task (Python 3) -# - -from typing import Any, Optional - -__metaclass__ = type - -class LoopingCall: - call: Any = ... - running: bool = ... - interval: Any = ... - starttime: Any = ... - f: Any = ... - a: Any = ... - kw: Any = ... - clock: Any = ... - def __init__(self, f: Any, *a: Any, **kw: Any) -> None: ... - @property - def deferred(self): ... - withCount: Any = ... - def start(self, interval: Any, now: bool = ...): ... - def stop(self) -> None: ... - def reset(self) -> None: ... - def __call__(self) -> None: ... - -class SchedulerError(Exception): ... -class SchedulerStopped(SchedulerError): ... -class TaskFinished(SchedulerError): ... -class TaskDone(TaskFinished): ... -class TaskStopped(TaskFinished): ... -class TaskFailed(TaskFinished): ... -class NotPaused(SchedulerError): ... - -class _Timer: - MAX_SLICE: float = ... - end: Any = ... - def __init__(self) -> None: ... - def __call__(self): ... - -class CooperativeTask: - def __init__(self, iterator: Any, cooperator: Any) -> None: ... - def whenDone(self): ... - def pause(self) -> None: ... - def resume(self) -> None: ... - def stop(self) -> None: ... - -class Cooperator: - def __init__(self, terminationPredicateFactory: Any = ..., scheduler: Any = ..., started: bool = ...) -> None: ... - def coiterate(self, iterator: Any, doneDeferred: Optional[Any] = ...): ... - def cooperate(self, iterator: Any): ... - def start(self) -> None: ... - def stop(self) -> None: ... - @property - def running(self): ... - -def coiterate(iterator: Any): ... - -class Clock: - rightNow: float = ... - calls: Any = ... - def __init__(self) -> None: ... - def seconds(self): ... - def callLater(self, when: Any, what: Any, *a: Any, **kw: Any): ... - def getDelayedCalls(self): ... - def advance(self, amount: Any) -> None: ... - def pump(self, timings: Any) -> None: ... - -def deferLater(clock: Any, delay: Any, callable: Any, *args: Any, **kw: Any): ... -def react(main: Any, argv: Any = ..., _reactor: Optional[Any] = ...) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/threads.pyi --- a/stubs/twisted/internet/threads.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for twisted.internet.threads (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def deferToThreadPool(reactor: Any, threadpool: Any, f: Any, *args: Any, **kwargs: Any): ... -def deferToThread(f: Any, *args: Any, **kwargs: Any): ... -def callMultipleInThread(tupleList: Any) -> None: ... -def blockingCallFromThread(reactor: Any, f: Any, *a: Any, **kw: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/tksupport.pyi --- a/stubs/twisted/internet/tksupport.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,3 +0,0 @@ -from typing import Any - -def install(root: Any, ms: int=20): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/internet/utils.pyi --- a/stubs/twisted/internet/utils.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,43 +0,0 @@ -# Stubs for twisted.internet.utils (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.internet import protocol -from typing import Any, Optional - -class _UnexpectedErrorOutput(IOError): - processEnded: Any = ... - def __init__(self, text: Any, processEnded: Any) -> None: ... - -class _BackRelay(protocol.ProcessProtocol): - deferred: Any = ... - s: Any = ... - errReceived: Any = ... - def __init__(self, deferred: Any, errortoo: int = ...) -> None: ... - onProcessEnded: Any = ... - def errReceivedIsBad(self, text: Any) -> None: ... - def errReceivedIsGood(self, text: Any) -> None: ... - def outReceived(self, text: Any) -> None: ... - def processEnded(self, reason: Any) -> None: ... - -def getProcessOutput(executable: Any, args: Any = ..., env: Any = ..., path: Optional[Any] = ..., reactor: Optional[Any] = ..., errortoo: int = ...): ... - -class _ValueGetter(protocol.ProcessProtocol): - deferred: Any = ... - def __init__(self, deferred: Any) -> None: ... - def processEnded(self, reason: Any) -> None: ... - -def getProcessValue(executable: Any, args: Any = ..., env: Any = ..., path: Optional[Any] = ..., reactor: Optional[Any] = ...): ... - -class _EverythingGetter(protocol.ProcessProtocol): - deferred: Any = ... - outBuf: Any = ... - errBuf: Any = ... - outReceived: Any = ... - errReceived: Any = ... - def __init__(self, deferred: Any) -> None: ... - def processEnded(self, reason: Any) -> None: ... - -def getProcessOutputAndValue(executable: Any, args: Any = ..., env: Any = ..., path: Optional[Any] = ..., reactor: Optional[Any] = ...): ... -def runWithWarningsSuppressed(suppressedWarnings: Any, f: Any, *a: Any, **kw: Any): ... -def suppressWarnings(f: Any, *suppressedWarnings: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/protocols/__init__.py diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/protocols/basic.pyi --- a/stubs/twisted/protocols/basic.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,87 +0,0 @@ -# Stubs for twisted.protocols.basic (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from twisted.internet import protocol -from typing import Any, Optional - -DEBUG: int - -class NetstringParseError(ValueError): ... -class IncompleteNetstring(Exception): ... - -class NetstringReceiver(protocol.Protocol): - MAX_LENGTH: int = ... - brokenPeer: int = ... - def makeConnection(self, transport: Any) -> None: ... - def sendString(self, string: Any) -> None: ... - def dataReceived(self, data: Any) -> None: ... - def stringReceived(self, string: Any) -> None: ... - -class LineOnlyReceiver(protocol.Protocol): - delimiter: bytes = ... - MAX_LENGTH: int = ... - def dataReceived(self, data: Any): ... - def lineReceived(self, line: Any) -> None: ... - def sendLine(self, line: Any): ... - def lineLengthExceeded(self, line: Any): ... - -class _PauseableMixin: - paused: bool = ... - def pauseProducing(self) -> None: ... - def resumeProducing(self) -> None: ... - def stopProducing(self) -> None: ... - -class LineReceiver(protocol.Protocol, _PauseableMixin): - line_mode: int = ... - delimiter: bytes = ... - MAX_LENGTH: int = ... - def clearLineBuffer(self): ... - def dataReceived(self, data: Any): ... - def setLineMode(self, extra: bytes = ...): ... - def setRawMode(self) -> None: ... - def rawDataReceived(self, data: Any) -> None: ... - def lineReceived(self, line: Any) -> None: ... - def sendLine(self, line: Any): ... - def lineLengthExceeded(self, line: Any): ... - -class StringTooLongError(AssertionError): ... - -class _RecvdCompatHack: - def __get__(self, oself: Any, type: Optional[Any] = ...): ... - -class IntNStringReceiver(protocol.Protocol, _PauseableMixin): - MAX_LENGTH: int = ... - recvd: Any = ... - def stringReceived(self, string: Any) -> None: ... - def lengthLimitExceeded(self, length: Any) -> None: ... - def dataReceived(self, data: Any) -> None: ... - def sendString(self, string: Any) -> None: ... - -class Int32StringReceiver(IntNStringReceiver): - structFormat: str = ... - prefixLength: Any = ... - -class Int16StringReceiver(IntNStringReceiver): - structFormat: str = ... - prefixLength: Any = ... - -class Int8StringReceiver(IntNStringReceiver): - structFormat: str = ... - prefixLength: Any = ... - -class StatefulStringProtocol: - state: str = ... - def stringReceived(self, string: Any) -> None: ... - -class FileSender: - CHUNK_SIZE: Any = ... - lastSent: str = ... - deferred: Any = ... - file: Any = ... - consumer: Any = ... - transform: Any = ... - def beginFileTransfer(self, file: Any, consumer: Any, transform: Optional[Any] = ...): ... - def resumeProducing(self) -> None: ... - def pauseProducing(self) -> None: ... - def stopProducing(self) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/__init__.pyi --- a/stubs/twisted/python/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,10 +0,0 @@ -# Stubs for twisted.python (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .compat import unicode -from .deprecate import deprecatedModuleAttribute -from .versions import Version -from typing import Any - -log: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/_oldstyle.pyi --- a/stubs/twisted/python/_oldstyle.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,3 +0,0 @@ -from typing import Any - -_replaceIf = Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/compat.pyi --- a/stubs/twisted/python/compat.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,5 +0,0 @@ -# Stubs for twisted.python.compat (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -def unicode(s): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/components.pyi --- a/stubs/twisted/python/components.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,50 +0,0 @@ -# Stubs for twisted.python.components (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -def registerAdapter(adapterFactory: Any, origInterface: Any, *interfaceClasses: Any) -> None: ... -def getAdapterFactory(fromInterface: Any, toInterface: Any, default: Any): ... -def getRegistry(): ... -CannotAdapt = TypeError - -class Adapter: - temporaryAdapter: int = ... - multiComponent: int = ... - original: Any = ... - def __init__(self, original: Any) -> None: ... - def __conform__(self, interface: Any): ... - def isuper(self, iface: Any, adapter: Any): ... - -class Componentized: - persistenceVersion: int = ... - def __init__(self) -> None: ... - def locateAdapterClass(self, klass: Any, interfaceClass: Any, default: Any): ... - def setAdapter(self, interfaceClass: Any, adapterClass: Any) -> None: ... - def addAdapter(self, adapterClass: Any, ignoreClass: int = ...): ... - def setComponent(self, interfaceClass: Any, component: Any) -> None: ... - def addComponent(self, component: Any, ignoreClass: int = ...) -> None: ... - def unsetComponent(self, interfaceClass: Any) -> None: ... - def removeComponent(self, component: Any): ... - def getComponent(self, interface: Any, default: Optional[Any] = ...): ... - def __conform__(self, interface: Any): ... - -class ReprableComponentized(Componentized): - def __init__(self) -> None: ... - -def proxyForInterface(iface: Any, originalAttribute: str = ...): ... - -class _ProxiedClassMethod: - methodName: Any = ... - originalAttribute: Any = ... - def __init__(self, methodName: Any, originalAttribute: Any) -> None: ... - def __call__(self, oself: Any, *args: Any, **kw: Any): ... - -class _ProxyDescriptor: - attributeName: Any = ... - originalAttribute: Any = ... - def __init__(self, attributeName: Any, originalAttribute: Any) -> None: ... - def __get__(self, oself: Any, type: Optional[Any] = ...): ... - def __set__(self, oself: Any, value: Any) -> None: ... - def __delete__(self, oself: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/deprecate.pyi --- a/stubs/twisted/python/deprecate.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,32 +0,0 @@ -# Stubs for twisted.python.deprecate (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -def getDeprecationWarningString(callableThing: Any, version: Any, format: Optional[Any] = ..., replacement: Optional[Any] = ...): ... -def deprecated(version: Any, replacement: Optional[Any] = ...): ... -def deprecatedProperty(version: Any, replacement: Optional[Any] = ...): ... -def getWarningMethod(): ... -def setWarningMethod(newMethod: Any) -> None: ... - -class _InternalState: - def __init__(self, proxy: Any) -> None: ... - def __getattribute__(self, name: Any): ... - def __setattr__(self, name: Any, value: Any): ... - -class _ModuleProxy: - def __init__(self, module: Any) -> None: ... - def __setattr__(self, name: Any, value: Any) -> None: ... - def __getattribute__(self, name: Any): ... - -class _DeprecatedAttribute: - module: Any = ... - __name__: Any = ... - fqpn: Any = ... - version: Any = ... - message: Any = ... - def __init__(self, module: Any, name: Any, version: Any, message: Any) -> None: ... - def get(self): ... - -def deprecatedModuleAttribute(version: Any, message: Any, moduleName: Any, name: Any) -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/failure.pyi --- a/stubs/twisted/python/failure.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,61 +0,0 @@ -# Stubs for twisted.python.failure (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -count: int -traceupLength: int - -class DefaultException(Exception): ... - -def format_frames(frames: Any, write: Any, detail: str = ...) -> None: ... - -EXCEPTION_CAUGHT_HERE: str - -class NoCurrentExceptionError(Exception): ... - -class _TracebackFrame: - tb_frame: Any = ... - tb_lineno: Any = ... - tb_next: Any = ... - def __init__(self, frame: Any, tb_next: Any) -> None: ... - -class _Frame: - f_code: Any = ... - f_globals: Any = ... - f_locals: Any = ... - def __init__(self, name: Any, filename: Any) -> None: ... - -class _Code: - co_name: Any = ... - co_filename: Any = ... - def __init__(self, name: Any, filename: Any) -> None: ... - -class Failure(BaseException): - pickled: int = ... - stack: Any = ... - count: Any = ... - type: Any = ... - captureVars: Any = ... - value: Any = ... - tb: Any = ... - parents: Any = ... - def __init__(self, exc_value: Optional[Any] = ..., exc_type: Optional[Any] = ..., exc_tb: Optional[Any] = ..., captureVars: bool = ...) -> None: ... - def trap(self, *errorTypes: Any): ... - def check(self, *errorTypes: Any): ... - def raiseException(self) -> None: ... - def throwExceptionIntoGenerator(self, g: Any): ... - __dict__: Any = ... - def cleanFailure(self) -> None: ... - def getTracebackObject(self): ... - def getErrorMessage(self): ... - def getBriefTraceback(self): ... - def getTraceback(self, elideFrameworkCode: int = ..., detail: str = ...): ... - def printTraceback(self, file: Optional[Any] = ..., elideFrameworkCode: bool = ..., detail: str = ...) -> None: ... - def printBriefTraceback(self, file: Optional[Any] = ..., elideFrameworkCode: int = ...) -> None: ... - def printDetailedTraceback(self, file: Optional[Any] = ..., elideFrameworkCode: int = ...) -> None: ... - -DO_POST_MORTEM: bool - -def startDebugMode() -> None: ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/filepath.pyi --- a/stubs/twisted/python/filepath.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,121 +0,0 @@ -# Stubs for twisted.python.filepath (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import base64 -import os -from twisted.python.util import FancyEqMixin -from typing import Any, Optional -from zope.interface import Interface - -islink: Any -randomBytes = os.urandom -armor = base64.urlsafe_b64encode - -class IFilePath(Interface): - def child(self, name: Any) -> None: ... - def open(self, mode: str = ...) -> None: ... - def changed(self, ) -> None: ... - def getsize(self, ) -> None: ... - def getModificationTime(self, ) -> None: ... - def getStatusChangeTime(self, ) -> None: ... - def getAccessTime(self, ) -> None: ... - def exists(self, ) -> None: ... - def isdir(self, ) -> None: ... - def isfile(self, ) -> None: ... - def children(self, ) -> None: ... - def basename(self, ) -> None: ... - def parent(self, ) -> None: ... - def sibling(self, name: Any) -> None: ... - -class InsecurePath(Exception): ... -class LinkError(Exception): ... - -class UnlistableError(OSError): - originalException: Any = ... - def __init__(self, originalException: Any) -> None: ... - -class _WindowsUnlistableError(UnlistableError, WindowsError): ... - -class AbstractFilePath: - def getContent(self): ... - def parents(self) -> None: ... - def children(self): ... - def walk(self, descend: Optional[Any] = ...) -> None: ... - def sibling(self, path: Any): ... - def descendant(self, segments: Any): ... - def segmentsFrom(self, ancestor: Any): ... - def __hash__(self): ... - def getmtime(self): ... - def getatime(self): ... - def getctime(self): ... - -class RWX(FancyEqMixin): - compareAttributes: Any = ... - read: Any = ... - write: Any = ... - execute: Any = ... - def __init__(self, readable: Any, writable: Any, executable: Any) -> None: ... - def shorthand(self): ... - -class Permissions(FancyEqMixin): - compareAttributes: Any = ... - def __init__(self, statModeInt: Any) -> None: ... - def shorthand(self): ... - -class _SpecialNoValue: ... - -class FilePath(AbstractFilePath): - path: Any = ... - alwaysCreate: Any = ... - def __init__(self, path: Any, alwaysCreate: bool = ...) -> None: ... - @property - def sep(self): ... - def asBytesMode(self, encoding: Optional[Any] = ...): ... - def asTextMode(self, encoding: Optional[Any] = ...): ... - def child(self, path: Any): ... - def preauthChild(self, path: Any): ... - def childSearchPreauth(self, *paths: Any): ... - def siblingExtensionSearch(self, *exts: Any): ... - def realpath(self): ... - def siblingExtension(self, ext: Any): ... - def linkTo(self, linkFilePath: Any) -> None: ... - def open(self, mode: str = ...): ... - def restat(self, reraise: bool = ...) -> None: ... - def changed(self) -> None: ... - def chmod(self, mode: Any) -> None: ... - def getsize(self): ... - def getModificationTime(self): ... - def getStatusChangeTime(self): ... - def getAccessTime(self): ... - def getInodeNumber(self): ... - def getDevice(self): ... - def getNumberOfHardLinks(self): ... - def getUserID(self): ... - def getGroupID(self): ... - def getPermissions(self): ... - def exists(self): ... - def isdir(self): ... - def isfile(self): ... - def isBlockDevice(self): ... - def isSocket(self): ... - def islink(self): ... - def isabs(self): ... - def listdir(self): ... - def splitext(self): ... - def touch(self) -> None: ... - def remove(self) -> None: ... - def makedirs(self, ignoreExistingDirectory: bool = ...): ... - def globChildren(self, pattern: Any): ... - def basename(self): ... - def dirname(self): ... - def parent(self): ... - def setContent(self, content: Any, ext: bytes = ...) -> None: ... - def __cmp__(self, other: Any): ... - def createDirectory(self) -> None: ... - def requireCreate(self, val: int = ...) -> None: ... - def create(self): ... - def temporarySibling(self, extension: bytes = ...): ... - def copyTo(self, destination: Any, followLinks: bool = ...) -> None: ... - def moveTo(self, destination: Any, followLinks: bool = ...) -> None: ... - def statinfo(self, value: Any = ...): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/lockfile.pyi --- a/stubs/twisted/python/lockfile.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,15 +0,0 @@ -# Stubs for twisted.python.lockfile (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class FilesystemLock: - clean: Any = ... - locked: bool = ... - name: Any = ... - def __init__(self, name: Any) -> None: ... - def lock(self): ... - def unlock(self) -> None: ... - -def isLocked(name: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/util.pyi --- a/stubs/twisted/python/util.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,104 +0,0 @@ -# Stubs for twisted.python.util (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from collections import OrderedDict as OrderedDict -from twisted.python._oldstyle import _replaceIf as _replaceIf -from typing import Any, Optional - -class InsensitiveDict: - data: Any = ... - preserve: Any = ... - def __init__(self, dict: Optional[Any] = ..., preserve: int = ...) -> None: ... - def __delitem__(self, key: Any) -> None: ... - def __getitem__(self, key: Any): ... - def __setitem__(self, key: Any, value: Any) -> None: ... - def has_key(self, key: Any): ... - __contains__: Any = ... - def keys(self): ... - def values(self): ... - def items(self): ... - def get(self, key: Any, default: Optional[Any] = ...): ... - def setdefault(self, key: Any, default: Any): ... - def update(self, dict: Any) -> None: ... - def iterkeys(self) -> None: ... - def itervalues(self) -> None: ... - def iteritems(self) -> None: ... - def popitem(self): ... - def clear(self) -> None: ... - def copy(self): ... - def __len__(self): ... - def __eq__(self, other: Any): ... - -def uniquify(lst: Any): ... -def padTo(n: Any, seq: Any, default: Optional[Any] = ...): ... -def getPluginDirs(): ... -def addPluginDir() -> None: ... -def sibpath(path: Any, sibling: Any): ... -def getPassword(prompt: str = ..., confirm: int = ..., forceTTY: int = ..., confirmPrompt: str = ..., mismatchMessage: str = ...): ... -def println(*a: Any) -> None: ... -def spewer(frame: Any, s: Any, ignored: Any) -> None: ... -def searchupwards(start: Any, files: Any = ..., dirs: Any = ...): ... - -class LineLog: - log: Any = ... - size: Any = ... - def __init__(self, size: int = ...) -> None: ... - def append(self, line: Any) -> None: ... - def str(self): ... - def __bytes__(self): ... - def __getitem__(self, item: Any): ... - def clear(self) -> None: ... - -def raises(exception: Any, f: Any, *args: Any, **kwargs: Any): ... - -class IntervalDifferential: - intervals: Any = ... - default: Any = ... - def __init__(self, intervals: Any, default: int = ...) -> None: ... - def __iter__(self): ... - -class _IntervalDifferentialIterator: - intervals: Any = ... - default: Any = ... - last: int = ... - def __init__(self, i: Any, d: Any) -> None: ... - def __next__(self): ... - next: Any = ... - def addInterval(self, i: Any) -> None: ... - def removeInterval(self, interval: Any) -> None: ... - -class FancyStrMixin: - showAttributes: Any = ... - -class FancyEqMixin: - compareAttributes: Any = ... - def __eq__(self, other: Any): ... - def __ne__(self, other: Any): ... - -def switchUID(uid: Any, gid: Any, euid: bool = ...) -> None: ... - -class SubclassableCStringIO: - def __init__(self, *a: Any, **kw: Any) -> None: ... - def __iter__(self): ... - def next(self): ... - def close(self): ... - def isatty(self): ... - def seek(self, pos: Any, mode: int = ...): ... - def tell(self): ... - def read(self, n: int = ...): ... - def readline(self, length: Optional[Any] = ...): ... - def readlines(self, sizehint: int = ...): ... - def truncate(self, size: Optional[Any] = ...): ... - def write(self, s: Any): ... - def writelines(self, list: Any): ... - def flush(self): ... - def getvalue(self): ... - -def untilConcludes(f: Any, *a: Any, **kw: Any): ... -def mergeFunctionMetadata(f: Any, g: Any): ... -def nameToLabel(mname: Any): ... -def uidFromString(uidString: Any): ... -def gidFromString(gidString: Any): ... -def runAsEffectiveUser(euid: Any, egid: Any, function: Any, *args: Any, **kwargs: Any): ... -def runWithWarningsSuppressed(suppressedWarnings: Any, f: Any, *args: Any, **kwargs: Any): ... diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/versions.pyi --- a/stubs/twisted/python/versions.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,5 +0,0 @@ -# Stubs for twisted.python.versions (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from incremental import IncomparableVersions as IncomparableVersions, Version as Version, getVersionString as getVersionString diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/twisted/python/win32.pyi --- a/stubs/twisted/python/win32.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,11 +0,0 @@ -# Stubs for twisted.python.win32 (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -ERROR_FILE_NOT_FOUND: int -ERROR_PATH_NOT_FOUND: int -ERROR_INVALID_NAME: int -ERROR_DIRECTORY: int -O_BINARY: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/zope/__init__.pyi --- a/stubs/zope/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,4 +0,0 @@ -from typing import Any - -declarations: Any -interface: Any diff -r ffd7fd7bc0e6 -r e2d558d7a511 stubs/zope/interface/__init__.pyi --- a/stubs/zope/interface/__init__.pyi Fri Aug 09 06:15:15 2019 +0000 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,5 +0,0 @@ -from typing import Any - -#from zope.interface.declarations import Declaration as Declaration, alsoProvides as alsoProvides, classImplements as classImplements, classImplementsOnly as classImplementsOnly, classProvides as classProvides, directlyProvidedBy as directlyProvidedBy, directlyProvides as directlyProvides, implementedBy as implementedBy, implementer as implementer, implementer_only as implementer_only, implements as implements, implementsOnly as implementsOnly, moduleProvides as moduleProvides, noLongerProvides as noLongerProvides, providedBy as providedBy, provider as provider -#from zope.interface.interface import Attribute as Attribute, Interface as Interface -Interface: Any