Mercurial > code > home > repos > light9
diff stubs/autobahn/websocket/protocol.pyi @ 1900:84b5aab10e47
stubs
Ignore-this: 69aa78eaab81f65fcf977cf9c00ddfec
| author | Drew Perttula <drewp@bigasterisk.com> |
|---|---|
| date | Fri, 31 May 2019 22:41:29 +0000 |
| parents | |
| children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/stubs/autobahn/websocket/protocol.pyi Fri May 31 22:41:29 2019 +0000 @@ -0,0 +1,325 @@ +# 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: ...