Upgrading pyzmq 22 to 23
Unknown22.3.0 → 23.2.1
Fetching 6 releases from GitHub…0 / 6
UnknownUpgrade verdict
DepDelta is still reading the notes for this range, so breaking changes can't be ruled out yet.
In plain terms
- DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
- This page updates as the notes come in.
Must act Still reading release notes
DepDelta is still reading the release notes in this range. This updates as they come in.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
variable DRAFT_API: bool
- changed:
class Context(_zmq.Context) → class Context(_zmq.Context[Socket])
- changed:
constructor AsyncioAuthenticator(context=…, loop=…) → constructor AsyncioAuthenticator(context: Optional[zmq.Context]=…, loop: Any=…) - changed:
method AsyncioAuthenticator.start() → method AsyncioAuthenticator.start() -> None - changed:
method AsyncioAuthenticator.stop() → method AsyncioAuthenticator.stop() -> None - added:
field AsyncioAuthenticator.zap_socket: zmq.asyncio.Socket
- changed:
class Authenticator(object) → class Authenticator - changed:
constructor Authenticator(context=…, encoding=…, log=…) → constructor Authenticator(context: Optional[zmq.Context]=…, encoding: str=…, log: Any=…) - changed:
method Authenticator.allow(*addresses) → method Authenticator.allow(*addresses: str) -> None - changed:
method Authenticator.configure_curve(domain=…, location=…) → method Authenticator.configure_curve(domain: str=…, location: Union[str, os.PathLike]=…) -> None - changed:
method Authenticator.configure_curve_callback(domain=…, credentials_provider=…) → method Authenticator.configure_curve_callback(domain: str=…, credentials_provider: Any=…) -> None - changed:
method Authenticator.configure_gssapi(domain=…, location=…) → method Authenticator.configure_gssapi(domain: str=…, location: Optional[str]=…) -> None - changed:
method Authenticator.configure_plain(domain=…, passwords=…) → method Authenticator.configure_plain(domain: str=…, passwords: Dict[str, str]=…) -> None - changed:
method Authenticator.curve_user_id(client_public_key) → method Authenticator.curve_user_id(client_public_key: bytes) -> str - changed:
method Authenticator.deny(*addresses) → method Authenticator.deny(*addresses: str) -> None - changed:
method Authenticator.handle_zap_message(msg) → method Authenticator.handle_zap_message(msg: List[bytes]) - changed:
method Authenticator.start() → method Authenticator.start() -> None - changed:
method Authenticator.stop() → method Authenticator.stop() -> None - added:
field Authenticator.allow_any: bool - added:
field Authenticator.blacklist: Set[str] - added:
field Authenticator.certs: Dict[str, Dict[bytes, Any]] - added:
field Authenticator.context: zmq.Context - added:
field Authenticator.credentials_providers: Dict[str, Any] - added:
field Authenticator.encoding: str - added:
field Authenticator.log: Any - added:
field Authenticator.passwords: Dict[str, Dict[str, str]] - added:
field Authenticator.whitelist: Set[str] - added:
field Authenticator.zap_socket: zmq.Socket
- changed:
function create_certificates(key_dir, name, metadata=…) → function create_certificates(key_dir: Union[str, os.PathLike], name: str, metadata: Optional[Dict[str, str]]=…) -> Tuple[str, str] - changed:
function load_certificate(filename) → function load_certificate(filename: Union[str, os.PathLike]) -> Tuple[bytes, Optional[bytes]] - changed:
function load_certificates(directory=…) → function load_certificates(directory: Union[str, os.PathLike]=…) -> Dict[bytes, bool]
- changed:
constructor IOLoopAuthenticator(context=…, encoding=…, log=…, io_loop=…) → constructor IOLoopAuthenticator(context: Optional[zmq.Context]=…, encoding: str=…, log: Any=…, io_loop: Optional[ioloop.IOLoop]=…) - changed:
method IOLoopAuthenticator.start() → method IOLoopAuthenticator.start() -> None - added:
field IOLoopAuthenticator.io_loop: ioloop.IOLoop - added:
field IOLoopAuthenticator.zap_stream: zmqstream.ZMQStream
- removed:
field ThreadAuthenticator.auth - changed:
class ThreadAuthenticator(object) → class ThreadAuthenticator - changed:
constructor ThreadAuthenticator(context=…, encoding=…, log=…) → constructor ThreadAuthenticator(context: Optional[zmq.Context]=…, encoding: str=…, log: Any=…) - changed:
field ThreadAuthenticator.context → field ThreadAuthenticator.context: zmq.Context - changed:
field ThreadAuthenticator.encoding → field ThreadAuthenticator.encoding: str - changed:
field ThreadAuthenticator.log → field ThreadAuthenticator.log: Any - changed:
field ThreadAuthenticator.pipe → field ThreadAuthenticator.pipe: zmq.Socket - changed:
field ThreadAuthenticator.pipe_endpoint → field ThreadAuthenticator.pipe_endpoint: str - changed:
field ThreadAuthenticator.thread → field ThreadAuthenticator.thread: AuthenticationThread - changed:
method ThreadAuthenticator.allow(*addresses) → method ThreadAuthenticator.allow(*addresses: str) - changed:
method ThreadAuthenticator.configure_curve(domain=…, location=…) → method ThreadAuthenticator.configure_curve(domain: str=…, location: str=…) - changed:
method ThreadAuthenticator.configure_curve_callback(domain=…, credentials_provider=…) → method ThreadAuthenticator.configure_curve_callback(domain: str=…, credentials_provider: Any=…) - changed:
method ThreadAuthenticator.configure_plain(domain=…, passwords=…) → method ThreadAuthenticator.configure_plain(domain: str=…, passwords: Optional[Dict[str, str]]=…) - changed:
method ThreadAuthenticator.deny(*addresses) → method ThreadAuthenticator.deny(*addresses: str) - changed:
method ThreadAuthenticator.is_alive() → method ThreadAuthenticator.is_alive() -> bool - changed:
method ThreadAuthenticator.start() → method ThreadAuthenticator.start() -> None - changed:
method ThreadAuthenticator.stop() → method ThreadAuthenticator.stop() -> None
- changed:
field Frame.bytes: ByteString → field Frame.bytes: bytes - changed:
function device(device_type: int, frontend: Socket, backend: Optional[Socket]=…) → function device(device_type: int, frontend: Socket, backend: Optional[Socket]=…) -> int - changed:
function proxy(frontend: Socket, backend: Socket) → function proxy(frontend: Socket, backend: Socket, capture: Optional[Socket]=…) -> int - changed:
function proxy_steerable(frontend: Socket, backend: Socket, capture: Optional[Socket]=…, control: Optional[Socket]=…) → function proxy_steerable(frontend: Socket, backend: Socket, capture: Optional[Socket]=…, control: Optional[Socket]=…) -> int - changed:
function zmq_poll(sockets: List[Any], timeout: Optional[int]=…) → function zmq_poll(sockets: List[Any], timeout: Optional[int]=…) -> List[Tuple[Socket, int]] - changed:
method Context.get(option: int) -> Union[int, ByteString, str] → method Context.get(option: int) -> Union[int, bytes, str] - changed:
method Context.set(option: int, value: Union[int, ByteString, str]) -> None → method Context.set(option: int, value: Union[int, bytes, str]) -> None - changed:
method Frame.copy_fast() -> Frame → method Frame.copy_fast() -> T - changed:
method Frame.get(option: int) -> Union[int, ByteString, str] → method Frame.get(option: int) -> Union[int, _bytestr, str] - changed:
method Frame.set(option: int, value: Union[int, ByteString, str]) -> None → method Frame.set(option: int, value: Union[int, _bytestr, str]) -> None - changed:
method Socket.bind(url: str) -> None → method Socket.bind(url: str) - changed:
method Socket.connect(url: str) -> None → method Socket.connect(url: str) - changed:
method Socket.get(option: int) -> Union[int, ByteString, str] → method Socket.get(option: int) -> Union[int, bytes, str] - changed:
method Socket.recv(flags: Optional[int]=…, copy: Optional[bool]=…, track: Optional[bool]=…) -> Union[Frame, ByteString] → method Socket.recv(flags: int=…, *, copy: Literal[False], track: bool=…) -> zmq.Frame | (flags: int=…, *, copy: Literal[True], track: bool=…) -> bytes | (flags: int=…, track: bool=…) -> bytes | (flags: Optional[int]=…, copy: bool=…, track: Optional[bool]=…) -> Union[zmq.Frame, bytes] - changed:
method Socket.send(data: Any, flags: Optional[int]=…, copy: Optional[bool]=…, track: Optional[bool]=…) -> Optional[Frame] → method Socket.send(data: Any, flags: int=…, copy: bool=…, track: bool=…) -> Optional[zmq.MessageTracker] - changed:
method Socket.set(option: int, value: Union[int, ByteString, str]) -> None → method Socket.set(option: int, value: Union[int, bytes, str]) -> None - added:
constructor Context(io_threads: int=…, shadow: Any=…) - added:
constructor Frame(data: Any=…, track: bool=…, copy: Optional[bool]=…, copy_threshold: Optional[int]=…) - added:
export zmq - added:
field Socket.FD: int - added:
field Socket.context: zmq.Context - added:
field Socket.copy_threshold: int - added:
method Context.term() -> None - added:
method Socket.join(group: str) -> None - added:
method Socket.leave(group: str) -> None - added:
method Socket.monitor(addr: Optional[str], events: int) -> None - added:
variable T
- removed:
variable DRAFT_API - removed:
variable c_constant_names - removed:
variable g
- changed:
class Context(object) → class Context
- changed:
class Socket(object) → class Socket
- removed:
variable AFFINITY: int - removed:
variable BACKLOG: int - removed:
variable BINDTODEVICE: int - removed:
variable BLOCKY: int - removed:
variable CHANNEL: int - removed:
variable CLIENT: int - removed:
variable CONFLATE: int - removed:
variable CONNECT_RID: int - removed:
variable CONNECT_ROUTING_ID: int - removed:
variable CONNECT_TIMEOUT: int - removed:
variable CURVE: int - removed:
variable CURVE_PUBLICKEY: int - removed:
variable CURVE_SECRETKEY: int - removed:
variable CURVE_SERVER: int - removed:
variable CURVE_SERVERKEY: int - removed:
variable DEALER: int - removed:
variable DELAY_ATTACH_ON_CONNECT: int - removed:
variable DGRAM: int - removed:
variable DISH: int - removed:
variable DONTWAIT: int - removed:
variable DOWNSTREAM: int - removed:
variable DRAFT_API: bool - removed:
variable EADDRINUSE: int - removed:
variable EADDRNOTAVAIL: int - removed:
variable EAFNOSUPPORT: int - removed:
variable EAGAIN: int - removed:
variable ECONNABORTED: int - removed:
variable ECONNREFUSED: int - removed:
variable ECONNRESET: int - removed:
variable EFAULT: int - removed:
variable EFSM: int - removed:
variable EHOSTUNREACH: int - removed:
variable EINPROGRESS: int - removed:
variable EINVAL: int - removed:
variable EMSGSIZE: int - removed:
variable EMTHREAD: int - removed:
variable ENETDOWN: int - removed:
variable ENETRESET: int - removed:
variable ENETUNREACH: int - removed:
variable ENOBUFS: int - removed:
variable ENOCOMPATPROTO: int - removed:
variable ENODEV: int - removed:
variable ENOMEM: int - removed:
variable ENOTCONN: int - removed:
variable ENOTSOCK: int - removed:
variable ENOTSUP: int - removed:
variable EPROTONOSUPPORT: int - removed:
variable ETERM: int - removed:
variable ETIMEDOUT: int - removed:
variable EVENTS: int - removed:
variable EVENT_ACCEPTED: int - removed:
variable EVENT_ACCEPT_FAILED: int - removed:
variable EVENT_ALL: int - removed:
variable EVENT_BIND_FAILED: int - removed:
variable EVENT_CLOSED: int - removed:
variable EVENT_CLOSE_FAILED: int - removed:
variable EVENT_CONNECTED: int - removed:
variable EVENT_CONNECT_DELAYED: int - removed:
variable EVENT_CONNECT_RETRIED: int - removed:
variable EVENT_DISCONNECTED: int - removed:
variable EVENT_HANDSHAKE_FAILED_AUTH: int - removed:
variable EVENT_HANDSHAKE_FAILED_NO_DETAIL: int - removed:
variable EVENT_HANDSHAKE_FAILED_PROTOCOL: int - removed:
variable EVENT_HANDSHAKE_SUCCEEDED: int - removed:
variable EVENT_LISTENING: int - removed:
variable EVENT_MONITOR_STOPPED: int - removed:
variable FAIL_UNROUTABLE: int - removed:
variable FD: int - removed:
variable FORWARDER: int - removed:
variable GATHER: int - removed:
variable GSSAPI: int - removed:
variable GSSAPI_NT_HOSTBASED: int - removed:
variable GSSAPI_NT_KRB5_PRINCIPAL: int - removed:
variable GSSAPI_NT_USER_NAME: int - removed:
variable GSSAPI_PLAINTEXT: int - removed:
variable GSSAPI_PRINCIPAL: int - removed:
variable GSSAPI_PRINCIPAL_NAMETYPE: int - removed:
variable GSSAPI_SERVER: int - removed:
variable GSSAPI_SERVICE_PRINCIPAL: int - removed:
variable GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int - removed:
variable HANDSHAKE_IVL: int - removed:
variable HAUSNUMERO: int - removed:
variable HEARTBEAT_IVL: int - removed:
variable HEARTBEAT_TIMEOUT: int - removed:
variable HEARTBEAT_TTL: int - removed:
variable HWM: int - removed:
variable IDENTITY: int - removed:
variable IMMEDIATE: int - removed:
variable INVERT_MATCHING: int - removed:
variable IO_THREADS: int - removed:
variable IO_THREADS_DFLT: int - removed:
variable IPC_FILTER_GID: int - removed:
variable IPC_FILTER_PID: int - removed:
variable IPC_FILTER_UID: int - removed:
variable IPV4ONLY: int - removed:
variable IPV6: int - removed:
variable LAST_ENDPOINT: int - removed:
variable LINGER: int - removed:
variable MAXMSGSIZE: int - removed:
variable MAX_SOCKETS: int - removed:
variable MAX_SOCKETS_DFLT: int - removed:
variable MCAST_LOOP: int - removed:
variable MECHANISM: int - removed:
variable MORE: int - removed:
variable MSG_T_SIZE: int - removed:
variable MULTICAST_HOPS: int - removed:
variable MULTICAST_LOOP: int - removed:
variable MULTICAST_MAXTPDU: int - removed:
variable NOBLOCK: int - removed:
variable NOTIFY_CONNECT: int - removed:
variable NOTIFY_DISCONNECT: int - removed:
variable NULL: int - removed:
variable PAIR: int - removed:
variable PEER: int - removed:
variable PLAIN: int - removed:
variable PLAIN_PASSWORD: int - removed:
variable PLAIN_SERVER: int - removed:
variable PLAIN_USERNAME: int - removed:
variable POLLERR: int - removed:
variable POLLIN: int - removed:
variable POLLITEMS_DFLT: int - removed:
variable POLLOUT: int - removed:
variable POLLPRI: int - removed:
variable PROBE_ROUTER: int - removed:
variable PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int - removed:
variable PROTOCOL_ERROR_ZAP_BAD_VERSION: int - removed:
variable PROTOCOL_ERROR_ZAP_INVALID_METADATA: int - removed:
variable PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int - removed:
variable PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int - removed:
variable PROTOCOL_ERROR_ZAP_UNSPECIFIED: int - removed:
variable PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int - removed:
variable PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int - removed:
variable PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int - removed:
variable PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int - removed:
variable PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int - removed:
variable PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int - removed:
variable PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int - removed:
variable PUB: int - removed:
variable PULL: int - removed:
variable PUSH: int - removed:
variable QUEUE: int - removed:
variable RADIO: int - removed:
variable RATE: int - removed:
variable RCVBUF: int - removed:
variable RCVHWM: int - removed:
variable RCVMORE: int - removed:
variable RCVTIMEO: int - removed:
variable RECONNECT_IVL: int - removed:
variable RECONNECT_IVL_MAX: int - removed:
variable RECOVERY_IVL: int - removed:
variable RECOVERY_IVL_MSEC: int - removed:
variable REP: int - removed:
variable REQ: int - removed:
variable REQ_CORRELATE: int - removed:
variable REQ_RELAXED: int - removed:
variable ROUTER: int - removed:
variable ROUTER_BEHAVIOR: int - removed:
variable ROUTER_HANDOVER: int - removed:
variable ROUTER_MANDATORY: int - removed:
variable ROUTER_NOTIFY: int - removed:
variable ROUTER_RAW: int - removed:
variable ROUTING_ID: int - removed:
variable SCATTER: int - removed:
variable SERVER: int - removed:
variable SHARED: int - removed:
variable SNDBUF: int - removed:
variable SNDHWM: int - removed:
variable SNDMORE: int - removed:
variable SNDTIMEO: int - removed:
variable SOCKET_LIMIT: int - removed:
variable SOCKS_PROXY: int - removed:
variable SRCFD: int - removed:
variable STREAM: int - removed:
variable STREAMER: int - removed:
variable STREAM_NOTIFY: int - removed:
variable SUB: int - removed:
variable SUBSCRIBE: int - removed:
variable SWAP: int - removed:
variable TCP_ACCEPT_FILTER: int - removed:
variable TCP_KEEPALIVE: int - removed:
variable TCP_KEEPALIVE_CNT: int - removed:
variable TCP_KEEPALIVE_IDLE: int - removed:
variable TCP_KEEPALIVE_INTVL: int - removed:
variable TCP_MAXRT: int - removed:
variable THREAD_AFFINITY_CPU_ADD: int - removed:
variable THREAD_AFFINITY_CPU_REMOVE: int - removed:
variable THREAD_NAME_PREFIX: int - removed:
variable THREAD_PRIORITY: int - removed:
variable THREAD_PRIORITY_DFLT: int - removed:
variable THREAD_SAFE: int - removed:
variable THREAD_SCHED_POLICY: int - removed:
variable THREAD_SCHED_POLICY_DFLT: int - removed:
variable TOS: int - removed:
variable TYPE: int - removed:
variable UNSUBSCRIBE: int - removed:
variable UPSTREAM: int - removed:
variable USE_FD: int - removed:
variable VERSION: int - removed:
variable VERSION_MAJOR: int - removed:
variable VERSION_MINOR: int - removed:
variable VERSION_PATCH: int - removed:
variable VMCI_BUFFER_MAX_SIZE: int - removed:
variable VMCI_BUFFER_MIN_SIZE: int - removed:
variable VMCI_BUFFER_SIZE: int - removed:
variable VMCI_CONNECT_TIMEOUT: int - removed:
variable XPUB: int - removed:
variable XPUB_MANUAL: int - removed:
variable XPUB_NODROP: int - removed:
variable XPUB_VERBOSE: int - removed:
variable XPUB_VERBOSER: int - removed:
variable XPUB_WELCOME_MSG: int - removed:
variable XREP: int - removed:
variable XREQ: int - removed:
variable XSUB: int - removed:
variable ZAP_DOMAIN: int - removed:
variable ZAP_ENFORCE_DOMAIN: int - removed:
variable bytes_sockopt_names: List[str] - removed:
variable bytes_sockopts: Set[int] - removed:
variable ctx_opt_names: List[str] - removed:
variable ctx_opts: Set[int] - removed:
variable fd_sockopt_names: List[str] - removed:
variable fd_sockopts: Set[int] - removed:
variable int64_sockopt_names: List[str] - removed:
variable int64_sockopts: Set[int] - removed:
variable int_sockopt_names: List[str] - removed:
variable int_sockopts: Set[int] - removed:
variable socket_types: Dict[int, str]
- added:
class ContextOption(IntEnum) - added:
class DeviceType(IntEnum) - added:
class Errno(IntEnum) - added:
class Event(IntFlag) - added:
class Flag(IntFlag) - added:
class MessageOption(IntEnum) - added:
class PollEvent(IntFlag) - added:
class SecurityMechanism(IntEnum) - added:
class SocketOption(IntEnum) - added:
class SocketType(IntEnum) - added:
export Enum - added:
export IntEnum - added:
export IntFlag - added:
field ContextOption.IO_THREADS - added:
field ContextOption.MAX_MSGSZ - added:
field ContextOption.MAX_SOCKETS - added:
field ContextOption.MSG_T_SIZE - added:
field ContextOption.SOCKET_LIMIT - added:
field ContextOption.THREAD_AFFINITY_CPU_ADD - added:
field ContextOption.THREAD_AFFINITY_CPU_REMOVE - added:
field ContextOption.THREAD_NAME_PREFIX - added:
field ContextOption.THREAD_PRIORITY - added:
field ContextOption.THREAD_SCHED_POLICY - added:
field DeviceType.FORWARDER - added:
field DeviceType.QUEUE - added:
field DeviceType.STREAMER - added:
field Errno.EADDRINUSE - added:
field Errno.EADDRNOTAVAIL - added:
field Errno.EAFNOSUPPORT - added:
field Errno.EAGAIN - added:
field Errno.ECONNABORTED - added:
field Errno.ECONNREFUSED - added:
field Errno.ECONNRESET - added:
field Errno.EFAULT - added:
field Errno.EFSM - added:
field Errno.EHOSTUNREACH - added:
field Errno.EINPROGRESS - added:
field Errno.EINVAL - added:
field Errno.EMSGSIZE - added:
field Errno.EMTHREAD - added:
field Errno.ENETDOWN - added:
field Errno.ENETRESET - added:
field Errno.ENETUNREACH - added:
field Errno.ENOBUFS - added:
field Errno.ENOCOMPATPROTO - added:
field Errno.ENOTCONN - added:
field Errno.ENOTSOCK - added:
field Errno.ENOTSUP - added:
field Errno.EPROTONOSUPPORT - added:
field Errno.ETERM - added:
field Errno.ETIMEDOUT - added:
field Event.ACCEPTED - added:
field Event.ACCEPT_FAILED - added:
field Event.ALL - added:
field Event.ALL_V1 - added:
field Event.ALL_V2 - added:
field Event.BIND_FAILED - added:
field Event.CLOSED - added:
field Event.CLOSE_FAILED - added:
field Event.CONNECTED - added:
field Event.CONNECT_DELAYED - added:
field Event.CONNECT_RETRIED - added:
field Event.DISCONNECTED - added:
field Event.HANDSHAKE_FAILED_AUTH - added:
field Event.HANDSHAKE_FAILED_NO_DETAIL - added:
field Event.HANDSHAKE_FAILED_PROTOCOL - added:
field Event.HANDSHAKE_SUCCEEDED - added:
field Event.LISTENING - added:
field Event.MONITOR_STOPPED - added:
field Event.PIPES_STATS - added:
field Event.PROTOCOL_ERROR_WS_UNSPECIFIED - added:
field Event.PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID - added:
field Event.PROTOCOL_ERROR_ZAP_BAD_VERSION - added:
field Event.PROTOCOL_ERROR_ZAP_INVALID_METADATA - added:
field Event.PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE - added:
field Event.PROTOCOL_ERROR_ZAP_MALFORMED_REPLY - added:
field Event.PROTOCOL_ERROR_ZAP_UNSPECIFIED - added:
field Event.PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC - added:
field Event.PROTOCOL_ERROR_ZMTP_INVALID_METADATA - added:
field Event.PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE - added:
field Event.PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED - added:
field Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME - added:
field Event.PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH - added:
field Event.PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND - added:
field Event.PROTOCOL_ERROR_ZMTP_UNSPECIFIED - added:
field Flag.DONTWAIT - added:
field Flag.NOBLOCK - added:
field Flag.SNDMORE - added:
field MessageOption.MORE - added:
field MessageOption.SHARED - added:
field MessageOption.SRCFD - added:
field PollEvent.POLLERR - added:
field PollEvent.POLLIN - added:
field PollEvent.POLLOUT - added:
field PollEvent.POLLPRI - added:
field SecurityMechanism.CURVE - added:
field SecurityMechanism.GSSAPI - added:
field SecurityMechanism.NULL - added:
field SecurityMechanism.PLAIN - added:
field SocketOption.AFFINITY - added:
field SocketOption.BACKLOG - added:
field SocketOption.BINDTODEVICE - added:
field SocketOption.BLOCKY - added:
field SocketOption.CONFLATE - added:
field SocketOption.CONNECT_RID - added:
field SocketOption.CONNECT_ROUTING_ID - added:
field SocketOption.CONNECT_TIMEOUT - added:
field SocketOption.CURVE_PUBLICKEY - added:
field SocketOption.CURVE_SECRETKEY - added:
field SocketOption.CURVE_SERVER - added:
field SocketOption.CURVE_SERVERKEY - added:
field SocketOption.DELAY_ATTACH_ON_CONNECT - added:
field SocketOption.DISCONNECT_MSG - added:
field SocketOption.EVENTS - added:
field SocketOption.FAIL_UNROUTABLE - added:
field SocketOption.FD - added:
field SocketOption.GSSAPI_PLAINTEXT - added:
field SocketOption.GSSAPI_PRINCIPAL - added:
field SocketOption.GSSAPI_PRINCIPAL_NAMETYPE - added:
field SocketOption.GSSAPI_SERVER - added:
field SocketOption.GSSAPI_SERVICE_PRINCIPAL - added:
field SocketOption.GSSAPI_SERVICE_PRINCIPAL_NAMETYPE - added:
field SocketOption.HANDSHAKE_IVL - added:
field SocketOption.HEARTBEAT_IVL - added:
field SocketOption.HEARTBEAT_TIMEOUT - added:
field SocketOption.HEARTBEAT_TTL - added:
field SocketOption.HELLO_MSG - added:
field SocketOption.HWM - added:
field SocketOption.IDENTITY - added:
field SocketOption.IMMEDIATE - added:
field SocketOption.INVERT_MATCHING - added:
field SocketOption.IN_BATCH_SIZE - added:
field SocketOption.IPC_FILTER_GID - added:
field SocketOption.IPC_FILTER_PID - added:
field SocketOption.IPC_FILTER_UID - added:
field SocketOption.IPV4ONLY - added:
field SocketOption.IPV6 - added:
field SocketOption.LAST_ENDPOINT - added:
field SocketOption.LINGER - added:
field SocketOption.LOOPBACK_FASTPATH - added:
field SocketOption.MAXMSGSIZE - added:
field SocketOption.MECHANISM - added:
field SocketOption.METADATA - added:
field SocketOption.MULTICAST_HOPS - added:
field SocketOption.MULTICAST_LOOP - added:
field SocketOption.MULTICAST_MAXTPDU - added:
field SocketOption.ONLY_FIRST_SUBSCRIBE - added:
field SocketOption.OUT_BATCH_SIZE - added:
field SocketOption.PLAIN_PASSWORD - added:
field SocketOption.PLAIN_SERVER - added:
field SocketOption.PLAIN_USERNAME - added:
field SocketOption.PRIORITY - added:
field SocketOption.PROBE_ROUTER - added:
field SocketOption.RATE - added:
field SocketOption.RCVBUF - added:
field SocketOption.RCVHWM - added:
field SocketOption.RCVMORE - added:
field SocketOption.RCVTIMEO - added:
field SocketOption.RECONNECT_IVL - added:
field SocketOption.RECONNECT_IVL_MAX - added:
field SocketOption.RECONNECT_STOP - added:
field SocketOption.RECOVERY_IVL - added:
field SocketOption.REQ_CORRELATE - added:
field SocketOption.REQ_RELAXED - added:
field SocketOption.ROUTER_BEHAVIOR - added:
field SocketOption.ROUTER_HANDOVER - added:
field SocketOption.ROUTER_MANDATORY - added:
field SocketOption.ROUTER_NOTIFY - added:
field SocketOption.ROUTER_RAW - added:
field SocketOption.ROUTING_ID - added:
field SocketOption.SNDBUF - added:
field SocketOption.SNDHWM - added:
field SocketOption.SNDTIMEO - added:
field SocketOption.SOCKS_PASSWORD - added:
field SocketOption.SOCKS_PROXY - added:
field SocketOption.SOCKS_USERNAME - added:
field SocketOption.STREAM_NOTIFY - added:
field SocketOption.SUBSCRIBE - added:
field SocketOption.TCP_ACCEPT_FILTER - added:
field SocketOption.TCP_KEEPALIVE - added:
field SocketOption.TCP_KEEPALIVE_CNT - added:
field SocketOption.TCP_KEEPALIVE_IDLE - added:
field SocketOption.TCP_KEEPALIVE_INTVL - added:
field SocketOption.TCP_MAXRT - added:
field SocketOption.THREAD_SAFE - added:
field SocketOption.TOS - added:
field SocketOption.TYPE - added:
field SocketOption.UNSUBSCRIBE - added:
field SocketOption.USE_FD - added:
field SocketOption.VMCI_BUFFER_MAX_SIZE - added:
field SocketOption.VMCI_BUFFER_MIN_SIZE - added:
field SocketOption.VMCI_BUFFER_SIZE - added:
field SocketOption.VMCI_CONNECT_TIMEOUT - added:
field SocketOption.WSS_CERT_PEM - added:
field SocketOption.WSS_HOSTNAME - added:
field SocketOption.WSS_KEY_PEM - added:
field SocketOption.WSS_TRUST_PEM - added:
field SocketOption.WSS_TRUST_SYSTEM - added:
field SocketOption.XPUB_MANUAL - added:
field SocketOption.XPUB_MANUAL_LAST_VALUE - added:
field SocketOption.XPUB_NODROP - added:
field SocketOption.XPUB_VERBOSE - added:
field SocketOption.XPUB_VERBOSER - added:
field SocketOption.XPUB_WELCOME_MSG - added:
field SocketOption.ZAP_DOMAIN - added:
field SocketOption.ZAP_ENFORCE_DOMAIN - added:
field SocketType.CHANNEL - added:
field SocketType.CLIENT - added:
field SocketType.DEALER - added:
field SocketType.DGRAM - added:
field SocketType.DISH - added:
field SocketType.GATHER - added:
field SocketType.PAIR - added:
field SocketType.PEER - added:
field SocketType.PUB - added:
field SocketType.PULL - added:
field SocketType.PUSH - added:
field SocketType.RADIO - added:
field SocketType.REP - added:
field SocketType.REQ - added:
field SocketType.ROUTER - added:
field SocketType.SCATTER - added:
field SocketType.SERVER - added:
field SocketType.STREAM - added:
field SocketType.SUB - added:
field SocketType.XPUB - added:
field SocketType.XREP - added:
field SocketType.XREQ - added:
field SocketType.XSUB - added:
variable AFFINITY: int - added:
variable BACKLOG: int - added:
variable BINDTODEVICE: int - added:
variable BLOCKY: int - added:
variable CHANNEL: int - added:
variable CLIENT: int - added:
variable CONFLATE: int - added:
variable CONNECT_RID: int - added:
variable CONNECT_ROUTING_ID: int - added:
variable CONNECT_TIMEOUT: int - added:
variable CURVE: int - added:
variable CURVE_PUBLICKEY: int - added:
variable CURVE_SECRETKEY: int - added:
variable CURVE_SERVER: int - added:
variable CURVE_SERVERKEY: int - added:
variable DEALER: int - added:
variable DELAY_ATTACH_ON_CONNECT: int - added:
variable DGRAM: int - added:
variable DISCONNECT_MSG: int - added:
variable DISH: int - added:
variable DONTWAIT: int - added:
variable EADDRINUSE: int - added:
variable EADDRNOTAVAIL: int - added:
variable EAFNOSUPPORT: int - added:
variable EAGAIN: int - added:
variable ECONNABORTED: int - added:
variable ECONNREFUSED: int - added:
variable ECONNRESET: int - added:
variable EFAULT: int - added:
variable EFSM: int - added:
variable EHOSTUNREACH: int - added:
variable EINPROGRESS: int - added:
variable EINVAL: int - added:
variable EMSGSIZE: int - added:
variable EMTHREAD: int - added:
variable ENETDOWN: int - added:
variable ENETRESET: int - added:
variable ENETUNREACH: int - added:
variable ENOBUFS: int - added:
variable ENOCOMPATPROTO: int - added:
variable ENOTCONN: int - added:
variable ENOTSOCK: int - added:
variable ENOTSUP: int - added:
variable EPROTONOSUPPORT: int - added:
variable ETERM: int - added:
variable ETIMEDOUT: int - added:
variable EVENTS: int - added:
variable EVENT_ACCEPTED: int - added:
variable EVENT_ACCEPT_FAILED: int - added:
variable EVENT_ALL: int - added:
variable EVENT_ALL_V1: int - added:
variable EVENT_ALL_V2: int - added:
variable EVENT_BIND_FAILED: int - added:
variable EVENT_CLOSED: int - added:
variable EVENT_CLOSE_FAILED: int - added:
variable EVENT_CONNECTED: int - added:
variable EVENT_CONNECT_DELAYED: int - added:
variable EVENT_CONNECT_RETRIED: int - added:
variable EVENT_DISCONNECTED: int - added:
variable EVENT_HANDSHAKE_FAILED_AUTH: int - added:
variable EVENT_HANDSHAKE_FAILED_NO_DETAIL: int - added:
variable EVENT_HANDSHAKE_FAILED_PROTOCOL: int - added:
variable EVENT_HANDSHAKE_SUCCEEDED: int - added:
variable EVENT_LISTENING: int - added:
variable EVENT_MONITOR_STOPPED: int - added:
variable EVENT_PIPES_STATS: int - added:
variable FAIL_UNROUTABLE: int - added:
variable FD: int - added:
variable FORWARDER: int - added:
variable GATHER: int - added:
variable GSSAPI: int - added:
variable GSSAPI_PLAINTEXT: int - added:
variable GSSAPI_PRINCIPAL: int - added:
variable GSSAPI_PRINCIPAL_NAMETYPE: int - added:
variable GSSAPI_SERVER: int - added:
variable GSSAPI_SERVICE_PRINCIPAL: int - added:
variable GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int - added:
variable HANDSHAKE_IVL: int - added:
variable HEARTBEAT_IVL: int - added:
variable HEARTBEAT_TIMEOUT: int - added:
variable HEARTBEAT_TTL: int - added:
variable HELLO_MSG: int - added:
variable HWM: int - added:
variable IDENTITY: int - added:
variable IMMEDIATE: int - added:
variable INVERT_MATCHING: int - added:
variable IN_BATCH_SIZE: int - added:
variable IO_THREADS: int - added:
variable IPC_FILTER_GID: int - added:
variable IPC_FILTER_PID: int - added:
variable IPC_FILTER_UID: int - added:
variable IPV4ONLY: int - added:
variable IPV6: int - added:
variable LAST_ENDPOINT: int - added:
variable LINGER: int - added:
variable LOOPBACK_FASTPATH: int - added:
variable MAXMSGSIZE: int - added:
variable MAX_MSGSZ: int - added:
variable MAX_SOCKETS: int - added:
variable MECHANISM: int - added:
variable METADATA: int - added:
variable MORE: int - added:
variable MSG_T_SIZE: int - added:
variable MULTICAST_HOPS: int - added:
variable MULTICAST_LOOP: int - added:
variable MULTICAST_MAXTPDU: int - added:
variable NOBLOCK: int - added:
variable NULL: int - added:
variable ONLY_FIRST_SUBSCRIBE: int - added:
variable OUT_BATCH_SIZE: int - added:
variable PAIR: int - added:
variable PEER: int - added:
variable PLAIN: int - added:
variable PLAIN_PASSWORD: int - added:
variable PLAIN_SERVER: int - added:
variable PLAIN_USERNAME: int - added:
variable POLLERR: int - added:
variable POLLIN: int - added:
variable POLLOUT: int - added:
variable POLLPRI: int - added:
variable PRIORITY: int - added:
variable PROBE_ROUTER: int - added:
variable PROTOCOL_ERROR_WS_UNSPECIFIED: int - added:
variable PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int - added:
variable PROTOCOL_ERROR_ZAP_BAD_VERSION: int - added:
variable PROTOCOL_ERROR_ZAP_INVALID_METADATA: int - added:
variable PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int - added:
variable PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int - added:
variable PROTOCOL_ERROR_ZAP_UNSPECIFIED: int - added:
variable PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int - added:
variable PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int - added:
variable PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int - added:
variable PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int - added:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int - added:
variable PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int - added:
variable PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int - added:
variable PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int - added:
variable PUB: int - added:
variable PULL: int - added:
variable PUSH: int - added:
variable QUEUE: int - added:
variable RADIO: int - added:
variable RATE: int - added:
variable RCVBUF: int - added:
variable RCVHWM: int - added:
variable RCVMORE: int - added:
variable RCVTIMEO: int - added:
variable RECONNECT_IVL: int - added:
variable RECONNECT_IVL_MAX: int - added:
variable RECONNECT_STOP: int - added:
variable RECOVERY_IVL: int - added:
variable REP: int - added:
variable REQ: int - added:
variable REQ_CORRELATE: int - added:
variable REQ_RELAXED: int - added:
variable ROUTER: int - added:
variable ROUTER_BEHAVIOR: int - added:
variable ROUTER_HANDOVER: int - added:
variable ROUTER_MANDATORY: int - added:
variable ROUTER_NOTIFY: int - added:
variable ROUTER_RAW: int - added:
variable ROUTING_ID: int - added:
variable SCATTER: int - added:
variable SERVER: int - added:
variable SHARED: int - added:
variable SNDBUF: int - added:
variable SNDHWM: int - added:
variable SNDMORE: int - added:
variable SNDTIMEO: int - added:
variable SOCKET_LIMIT: int - added:
variable SOCKS_PASSWORD: int - added:
variable SOCKS_PROXY: int - added:
variable SOCKS_USERNAME: int - added:
variable SRCFD: int - added:
variable STREAM: int - added:
variable STREAMER: int - added:
variable STREAM_NOTIFY: int - added:
variable SUB: int - added:
variable SUBSCRIBE: int - added:
variable TCP_ACCEPT_FILTER: int - added:
variable TCP_KEEPALIVE: int - added:
variable TCP_KEEPALIVE_CNT: int - added:
variable TCP_KEEPALIVE_IDLE: int - added:
variable TCP_KEEPALIVE_INTVL: int - added:
variable TCP_MAXRT: int - added:
variable THREAD_AFFINITY_CPU_ADD: int - added:
variable THREAD_AFFINITY_CPU_REMOVE: int - added:
variable THREAD_NAME_PREFIX: int - added:
variable THREAD_PRIORITY: int - added:
variable THREAD_SAFE: int - added:
variable THREAD_SCHED_POLICY: int - added:
variable TOS: int - added:
variable TYPE: int - added:
variable UNSUBSCRIBE: int - added:
variable USE_FD: int - added:
variable VMCI_BUFFER_MAX_SIZE: int - added:
variable VMCI_BUFFER_MIN_SIZE: int - added:
variable VMCI_BUFFER_SIZE: int - added:
variable VMCI_CONNECT_TIMEOUT: int - added:
variable WSS_CERT_PEM: int - added:
variable WSS_HOSTNAME: int - added:
variable WSS_KEY_PEM: int - added:
variable WSS_TRUST_PEM: int - added:
variable WSS_TRUST_SYSTEM: int - added:
variable XPUB: int - added:
variable XPUB_MANUAL: int - added:
variable XPUB_MANUAL_LAST_VALUE: int - added:
variable XPUB_NODROP: int - added:
variable XPUB_VERBOSE: int - added:
variable XPUB_VERBOSER: int - added:
variable XPUB_WELCOME_MSG: int - added:
variable XREP: int - added:
variable XREQ: int - added:
variable XSUB: int - added:
variable ZAP_DOMAIN: int - added:
variable ZAP_ENFORCE_DOMAIN: int
- changed:
constructor Device(device_type=…, in_type=…, out_type=…) → constructor Device(device_type: int=…, in_type: Optional[int]=…, out_type: Optional[int]=…) -> None - changed:
method Device.bind_in(addr) → method Device.bind_in(addr: str) -> None - changed:
method Device.bind_in_to_random_port(addr, *args, **kwargs) → method Device.bind_in_to_random_port(addr: str, *args, **kwargs) -> int - changed:
method Device.bind_out(addr) → method Device.bind_out(addr: str) -> None - changed:
method Device.bind_out_to_random_port(addr, *args, **kwargs) → method Device.bind_out_to_random_port(addr: str, *args, **kwargs) -> int - changed:
method Device.connect_in(addr) → method Device.connect_in(addr: str) -> None - changed:
method Device.connect_out(addr) → method Device.connect_out(addr: str) - changed:
method Device.join(timeout=…) → method Device.join(timeout: Optional[float]=…) -> None - changed:
method Device.run() → method Device.run() -> None - changed:
method Device.run_device() → method Device.run_device() -> None - changed:
method Device.setsockopt_in(opt, value) → method Device.setsockopt_in(opt: int, value: Any) -> None - changed:
method Device.setsockopt_out(opt, value) → method Device.setsockopt_out(opt: int, value: Any) - changed:
method Device.start() → method Device.start() -> None - added:
field Device.daemon: bool - added:
field Device.device_type: int - added:
field Device.in_type: int - added:
field Device.out_type: int
- changed:
class Context(_zmq.Context) → class Context(_zmq.Context[Socket]) - changed:
constructor Context(*args, **kwargs) → constructor Context(*args: Any, **kwargs: Any) -> None
- changed:
class ZMQStream(object) → class ZMQStream - changed:
constructor ZMQStream(socket, io_loop=…) → constructor ZMQStream(socket: zmq.Socket, io_loop: Optional[tornado.ioloop.IOLoop]=…) - changed:
field ZMQStream.io_loop → field ZMQStream.io_loop: tornado.ioloop.IOLoop - changed:
field ZMQStream.poller → field ZMQStream.poller: zmq.Poller - changed:
field ZMQStream.socket → field ZMQStream.socket: zmq.Socket - changed:
method ZMQStream.close(linger=…) → method ZMQStream.close(linger: Optional[int]=…) -> None - changed:
method ZMQStream.closed() → method ZMQStream.closed() -> bool - changed:
method ZMQStream.flush(flag=…, limit=…) → method ZMQStream.flush(flag: int=…, limit: Optional[int]=…) - changed:
method ZMQStream.on_err(callback) → method ZMQStream.on_err(callback: Callable) - changed:
method ZMQStream.on_recv(callback, copy=…) → method ZMQStream.on_recv(callback: Callable[[List[bytes]], Any]) -> None | (callback: Callable[[List[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[List[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Union[Callable[[List[zmq.Frame]], Any], Callable[[List[bytes]], Any]], copy: bool=…) - changed:
method ZMQStream.on_recv_stream(callback, copy=…) → method ZMQStream.on_recv_stream(callback: Callable[[ZMQStream, List[bytes]], Any]) -> None | (callback: Callable[[ZMQStream, List[bytes]], Any], copy: Literal[True]) -> None | (callback: Callable[[ZMQStream, List[zmq.Frame]], Any], copy: Literal[False]) -> None | (callback: Union[Callable[[ZMQStream, List[zmq.Frame]], Any], Callable[[ZMQStream, List[bytes]], Any]], copy: bool=…) - changed:
method ZMQStream.on_send(callback) → method ZMQStream.on_send(callback: Callable[[Sequence[Any], Optional[zmq.MessageTracker]], Any]) - changed:
method ZMQStream.on_send_stream(callback) → method ZMQStream.on_send_stream(callback: Callable[[ZMQStream, Sequence[Any], Optional[zmq.MessageTracker]], Any]) - changed:
method ZMQStream.receiving() → method ZMQStream.receiving() -> bool - changed:
method ZMQStream.send_json(obj, flags=…, callback=…, **kwargs) → method ZMQStream.send_json(obj: Any, flags: int=…, callback: Optional[Callable]=…, **kwargs: Any) - changed:
method ZMQStream.send_multipart(msg, flags=…, copy=…, track=…, callback=…, **kwargs) → method ZMQStream.send_multipart(msg: Sequence[Any], flags: int=…, copy: bool=…, track: bool=…, callback: Callable=…, **kwargs: Any) -> None - changed:
method ZMQStream.send_pyobj(obj, flags=…, protocol=…, callback=…, **kwargs) → method ZMQStream.send_pyobj(obj: Any, flags: int=…, protocol: int=…, callback: Optional[Callable]=…, **kwargs: Any) - changed:
method ZMQStream.send_string(u, flags=…, encoding=…, callback=…, **kwargs) → method ZMQStream.send_string(u: str, flags: int=…, encoding: str=…, callback: Optional[Callable]=…, **kwargs: Any) - changed:
method ZMQStream.sending() → method ZMQStream.sending() -> bool - changed:
method ZMQStream.set_close_callback(callback) → method ZMQStream.set_close_callback(callback: Optional[Callable])
- removed:
property PUBHandler.root_topic - changed:
constructor PUBHandler(interface_or_socket, context=…, root_topic=…) → constructor PUBHandler(interface_or_socket: Union[str, zmq.Socket], context: Optional[zmq.Context]=…, root_topic: str=…) -> None - changed:
field PUBHandler.socket → field PUBHandler.socket: zmq.Socket - changed:
method PUBHandler.setRootTopic(root_topic) → method PUBHandler.setRootTopic(root_topic: str) - added:
field PUBHandler.ctx: zmq.Context - added:
property PUBHandler.root_topic -> str
- changed:
class AttributeSetter(object) → class AttributeSetter - added:
method AttributeSetter.get(opt: int) -> OptValT - added:
method AttributeSetter.set(opt: int, val: OptValT) -> None
- removed:
variable AFFINITY: int - removed:
variable BACKLOG: int - removed:
variable BINDTODEVICE: int - removed:
variable BLOCKY: int - removed:
variable CHANNEL: int - removed:
variable CLIENT: int - removed:
variable CONFLATE: int - removed:
variable CONNECT_RID: int - removed:
variable CONNECT_ROUTING_ID: int - removed:
variable CONNECT_TIMEOUT: int - removed:
variable CURVE: int - removed:
variable CURVE_PUBLICKEY: int - removed:
variable CURVE_SECRETKEY: int - removed:
variable CURVE_SERVER: int - removed:
variable CURVE_SERVERKEY: int - removed:
variable DEALER: int - removed:
variable DELAY_ATTACH_ON_CONNECT: int - removed:
variable DGRAM: int - removed:
variable DISH: int - removed:
variable DONTWAIT: int - removed:
variable DOWNSTREAM: int - removed:
variable DRAFT_API: bool - removed:
variable EADDRINUSE: int - removed:
variable EADDRNOTAVAIL: int - removed:
variable EAFNOSUPPORT: int - removed:
variable EAGAIN: int - removed:
variable ECONNABORTED: int - removed:
variable ECONNREFUSED: int - removed:
variable ECONNRESET: int - removed:
variable EFAULT: int - removed:
variable EFSM: int - removed:
variable EHOSTUNREACH: int - removed:
variable EINPROGRESS: int - removed:
variable EINVAL: int - removed:
variable EMSGSIZE: int - removed:
variable EMTHREAD: int - removed:
variable ENETDOWN: int - removed:
variable ENETRESET: int - removed:
variable ENETUNREACH: int - removed:
variable ENOBUFS: int - removed:
variable ENOCOMPATPROTO: int - removed:
variable ENODEV: int - removed:
variable ENOMEM: int - removed:
variable ENOTCONN: int - removed:
variable ENOTSOCK: int - removed:
variable ENOTSUP: int - removed:
variable EPROTONOSUPPORT: int - removed:
variable ETERM: int - removed:
variable ETIMEDOUT: int - removed:
variable EVENTS: int - removed:
variable EVENT_ACCEPTED: int - removed:
variable EVENT_ACCEPT_FAILED: int - removed:
variable EVENT_ALL: int - removed:
variable EVENT_BIND_FAILED: int - removed:
variable EVENT_CLOSED: int - removed:
variable EVENT_CLOSE_FAILED: int - removed:
variable EVENT_CONNECTED: int - removed:
variable EVENT_CONNECT_DELAYED: int - removed:
variable EVENT_CONNECT_RETRIED: int - removed:
variable EVENT_DISCONNECTED: int - removed:
variable EVENT_HANDSHAKE_FAILED_AUTH: int - removed:
variable EVENT_HANDSHAKE_FAILED_NO_DETAIL: int - removed:
variable EVENT_HANDSHAKE_FAILED_PROTOCOL: int - removed:
variable EVENT_HANDSHAKE_SUCCEEDED: int - removed:
variable EVENT_LISTENING: int - removed:
variable EVENT_MONITOR_STOPPED: int - removed:
variable FAIL_UNROUTABLE: int - removed:
variable FD: int - removed:
variable FORWARDER: int - removed:
variable GATHER: int - removed:
variable GSSAPI: int - removed:
variable GSSAPI_NT_HOSTBASED: int - removed:
variable GSSAPI_NT_KRB5_PRINCIPAL: int - removed:
variable GSSAPI_NT_USER_NAME: int - removed:
variable GSSAPI_PLAINTEXT: int - removed:
variable GSSAPI_PRINCIPAL: int - removed:
variable GSSAPI_PRINCIPAL_NAMETYPE: int - removed:
variable GSSAPI_SERVER: int - removed:
variable GSSAPI_SERVICE_PRINCIPAL: int - removed:
variable GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int - removed:
variable HANDSHAKE_IVL: int - removed:
variable HAUSNUMERO: int - removed:
variable HEARTBEAT_IVL: int - removed:
variable HEARTBEAT_TIMEOUT: int - removed:
variable HEARTBEAT_TTL: int - removed:
variable HWM: int - removed:
variable IDENTITY: int - removed:
variable IMMEDIATE: int - removed:
variable INVERT_MATCHING: int - removed:
variable IO_THREADS: int - removed:
variable IO_THREADS_DFLT: int - removed:
variable IPC_FILTER_GID: int - removed:
variable IPC_FILTER_PID: int - removed:
variable IPC_FILTER_UID: int - removed:
variable IPV4ONLY: int - removed:
variable IPV6: int - removed:
variable LAST_ENDPOINT: int - removed:
variable LINGER: int - removed:
variable MAXMSGSIZE: int - removed:
variable MAX_SOCKETS: int - removed:
variable MAX_SOCKETS_DFLT: int - removed:
variable MCAST_LOOP: int - removed:
variable MECHANISM: int - removed:
variable MORE: int - removed:
variable MSG_T_SIZE: int - removed:
variable MULTICAST_HOPS: int - removed:
variable MULTICAST_LOOP: int - removed:
variable MULTICAST_MAXTPDU: int - removed:
variable NOBLOCK: int - removed:
variable NOTIFY_CONNECT: int - removed:
variable NOTIFY_DISCONNECT: int - removed:
variable NULL: int - removed:
variable PAIR: int - removed:
variable PEER: int - removed:
variable PLAIN: int - removed:
variable PLAIN_PASSWORD: int - removed:
variable PLAIN_SERVER: int - removed:
variable PLAIN_USERNAME: int - removed:
variable POLLERR: int - removed:
variable POLLIN: int - removed:
variable POLLITEMS_DFLT: int - removed:
variable POLLOUT: int - removed:
variable POLLPRI: int - removed:
variable PROBE_ROUTER: int - removed:
variable PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int - removed:
variable PROTOCOL_ERROR_ZAP_BAD_VERSION: int - removed:
variable PROTOCOL_ERROR_ZAP_INVALID_METADATA: int - removed:
variable PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int - removed:
variable PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int - removed:
variable PROTOCOL_ERROR_ZAP_UNSPECIFIED: int - removed:
variable PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int - removed:
variable PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int - removed:
variable PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int - removed:
variable PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int - removed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int - removed:
variable PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int - removed:
variable PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int - removed:
variable PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int - removed:
variable PUB: int - removed:
variable PULL: int - removed:
variable PUSH: int - removed:
variable QUEUE: int - removed:
variable RADIO: int - removed:
variable RATE: int - removed:
variable RCVBUF: int - removed:
variable RCVHWM: int - removed:
variable RCVMORE: int - removed:
variable RCVTIMEO: int - removed:
variable RECONNECT_IVL: int - removed:
variable RECONNECT_IVL_MAX: int - removed:
variable RECOVERY_IVL: int - removed:
variable RECOVERY_IVL_MSEC: int - removed:
variable REP: int - removed:
variable REQ: int - removed:
variable REQ_CORRELATE: int - removed:
variable REQ_RELAXED: int - removed:
variable ROUTER: int - removed:
variable ROUTER_BEHAVIOR: int - removed:
variable ROUTER_HANDOVER: int - removed:
variable ROUTER_MANDATORY: int - removed:
variable ROUTER_NOTIFY: int - removed:
variable ROUTER_RAW: int - removed:
variable ROUTING_ID: int - removed:
variable SCATTER: int - removed:
variable SERVER: int - removed:
variable SHARED: int - removed:
variable SNDBUF: int - removed:
variable SNDHWM: int - removed:
variable SNDMORE: int - removed:
variable SNDTIMEO: int - removed:
variable SOCKET_LIMIT: int - removed:
variable SOCKS_PROXY: int - removed:
variable SRCFD: int - removed:
variable STREAM: int - removed:
variable STREAMER: int - removed:
variable STREAM_NOTIFY: int - removed:
variable SUB: int - removed:
variable SUBSCRIBE: int - removed:
variable SWAP: int - removed:
variable TCP_ACCEPT_FILTER: int - removed:
variable TCP_KEEPALIVE: int - removed:
variable TCP_KEEPALIVE_CNT: int - removed:
variable TCP_KEEPALIVE_IDLE: int - removed:
variable TCP_KEEPALIVE_INTVL: int - removed:
variable TCP_MAXRT: int - removed:
variable THREAD_AFFINITY_CPU_ADD: int - removed:
variable THREAD_AFFINITY_CPU_REMOVE: int - removed:
variable THREAD_NAME_PREFIX: int - removed:
variable THREAD_PRIORITY: int - removed:
variable THREAD_PRIORITY_DFLT: int - removed:
variable THREAD_SAFE: int - removed:
variable THREAD_SCHED_POLICY: int - removed:
variable THREAD_SCHED_POLICY_DFLT: int - removed:
variable TOS: int - removed:
variable TYPE: int - removed:
variable UNSUBSCRIBE: int - removed:
variable UPSTREAM: int - removed:
variable USE_FD: int - removed:
variable VERSION: int - removed:
variable VERSION_MAJOR: int - removed:
variable VERSION_MINOR: int - removed:
variable VERSION_PATCH: int - removed:
variable VMCI_BUFFER_MAX_SIZE: int - removed:
variable VMCI_BUFFER_MIN_SIZE: int - removed:
variable VMCI_BUFFER_SIZE: int - removed:
variable VMCI_CONNECT_TIMEOUT: int - removed:
variable XPUB: int - removed:
variable XPUB_MANUAL: int - removed:
variable XPUB_NODROP: int - removed:
variable XPUB_VERBOSE: int - removed:
variable XPUB_VERBOSER: int - removed:
variable XPUB_WELCOME_MSG: int - removed:
variable XREP: int - removed:
variable XREQ: int - removed:
variable XSUB: int - removed:
variable ZAP_DOMAIN: int - removed:
variable ZAP_ENFORCE_DOMAIN: int - removed:
variable bytes_sockopt_names: List[str] - removed:
variable bytes_sockopts: Set[int] - removed:
variable ctx_opt_names: List[str] - removed:
variable ctx_opts: Set[int] - removed:
variable fd_sockopt_names: List[str] - removed:
variable fd_sockopts: Set[int] - removed:
variable int64_sockopt_names: List[str] - removed:
variable int64_sockopts: Set[int] - removed:
variable int_sockopt_names: List[str] - removed:
variable int_sockopts: Set[int] - removed:
variable socket_types: Dict[int, str]
- changed:
class Context(ContextBase, AttributeSetter) → class Context(ContextBase, AttributeSetter, Generic[ST]) - changed:
constructor Context(io_threads=…, **kwargs) → constructor Context(io_threads: int=…, **kwargs: Any) -> None - changed:
field Context.sockopts → field Context.sockopts: Dict[int, Any] - changed:
method Context.destroy(linger=…) → method Context.destroy(linger: Optional[float]=…) -> None - changed:
method Context.getsockopt(opt) → method Context.getsockopt(opt: int) -> OptValT - changed:
method Context.setsockopt(opt, value) → method Context.setsockopt(opt: int, value: Any) -> None - changed:
method Context.socket(socket_type, **kwargs) → method Context.socket(socket_type: int, **kwargs: Any) -> ST - changed:
method Context.term() → method Context.term() -> None - changed:
static method Context.instance(io_threads=…) -> T → static method Context.instance(io_threads: int=…) -> T - changed:
static method Context.shadow(address) → static method Context.shadow(address: int) -> T - changed:
static method Context.shadow_pyczmq(ctx) → static method Context.shadow_pyczmq(ctx: Any) -> T
- changed:
constructor Poller() → constructor Poller() -> None - changed:
function select(rlist: List, wlist: List, xlist: List, timeout: Optional[int]=…) → function select(rlist: List, wlist: List, xlist: List, timeout: Optional[float]=…) - changed:
method Poller.poll(timeout: Optional[int]=…) → method Poller.poll(timeout: Optional[int]=…) -> List[Tuple[Any, int]] - changed:
method Poller.register(socket, flags: int=…) → method Poller.register(socket: Any, flags: int=…) - changed:
method Poller.unregister(socket) → method Poller.unregister(socket: Any)
- changed:
class Socket(SocketBase, AttributeSetter) → class Socket(SocketBase, AttributeSetter, Generic[ST]) - changed:
method Socket.bind(addr) → method Socket.bind(addr: str) -> _SocketContext[T] - changed:
method Socket.bind_to_random_port(addr, min_port=…, max_port=…, max_tries=…) → method Socket.bind_to_random_port(addr: str, min_port: int=…, max_port: int=…, max_tries: int=…) -> int - changed:
method Socket.close(linger=…) → method Socket.close(linger=…) -> None - changed:
method Socket.connect(addr) → method Socket.connect(addr: str) -> _SocketContext[T] - changed:
method Socket.disable_monitor() → method Socket.disable_monitor() -> None - changed:
method Socket.fileno() → method Socket.fileno() -> int - changed:
method Socket.get_hwm() → method Socket.get_hwm() -> int - changed:
method Socket.get_monitor_socket(events=…, addr=…) → method Socket.get_monitor_socket(events: Optional[int]=…, addr: Optional[str]=…) -> T - changed:
method Socket.get_string(option, encoding=…) → method Socket.get_string(option: int, encoding=…) -> str - changed:
method Socket.poll(timeout=…, flags=…) → method Socket.poll(timeout=…, flags=…) -> int - changed:
method Socket.recv_json(flags=…, **kwargs) → method Socket.recv_json(flags: int=…, **kwargs) -> Union[List, str, int, float, Dict] - changed:
method Socket.recv_multipart(flags=…, copy=…, track=…) → method Socket.recv_multipart(flags: int=…, *, copy: Literal[True], track: bool=…) -> List[bytes] | (flags: int=…, *, copy: Literal[False], track: bool=…) -> List[zmq.Frame] | (flags: int=…, *, track: bool=…) -> List[bytes] | (flags: int=…, copy: bool=…, track: bool=…) -> Union[List[zmq.Frame], List[bytes]] - changed:
method Socket.recv_pyobj(flags=…) → method Socket.recv_pyobj(flags: int=…) -> Any - changed:
method Socket.recv_string(flags=…, encoding=…) → method Socket.recv_string(flags: int=…, encoding: str=…) -> str - changed:
method Socket.send(data, flags=…, copy=…, track=…, routing_id=…, group=…) → method Socket.send(data: Any, flags: int=…, copy: bool=…, *, track: Literal[True], routing_id: Optional[int]=…, group: Optional[str]=…) -> zmq.MessageTracker | (data: Any, flags: int=…, copy: bool=…, *, track: Literal[False], routing_id: Optional[int]=…, group: Optional[str]=…) -> None | (data: Any, flags: int=…, *, copy: bool=…, routing_id: Optional[int]=…, group: Optional[str]=…) -> None | (dat… - changed:
method Socket.send_json(obj, flags=…, **kwargs) → method Socket.send_json(obj: Any, flags: int=…, **kwargs) -> None - changed:
method Socket.send_multipart(msg_parts, flags=…, copy=…, track=…, **kwargs) → method Socket.send_multipart(msg_parts: Sequence, flags: int=…, copy: bool=…, track: bool=…, **kwargs) - changed:
method Socket.send_pyobj(obj, flags=…, protocol=…, **kwargs) → method Socket.send_pyobj(obj: Any, flags: int=…, protocol: int=…, **kwargs) -> Optional[zmq.Frame] - changed:
method Socket.send_string(u, flags=…, copy=…, encoding=…, **kwargs) → method Socket.send_string(u: str, flags: int=…, copy: bool=…, encoding: str=…, **kwargs) -> Optional[zmq.Frame] - changed:
method Socket.set_hwm(value) → method Socket.set_hwm(value: int) -> None - changed:
method Socket.set_string(option, optval, encoding=…) → method Socket.set_string(option: int, optval: str, encoding=…) -> None - changed:
method Socket.subscribe(topic) → method Socket.subscribe(topic: Union[str, bytes]) -> None - changed:
method Socket.unsubscribe(topic) → method Socket.unsubscribe(topic: Union[str, bytes]) -> None - changed:
static method Socket.shadow(address) → static method Socket.shadow(address: int) -> T
- changed:
class Stopwatch(object) → class Stopwatch
- changed:
constructor MessageTracker(*towatch) → constructor MessageTracker(*towatch: Tuple[Union[MessageTracker, Event, Frame]]) - changed:
field MessageTracker.events → field MessageTracker.events: Set[Event] - changed:
field MessageTracker.peers → field MessageTracker.peers: Set[MessageTracker] - changed:
method MessageTracker.wait(timeout=…) → method MessageTracker.wait(timeout: Union[float, int]=…)
- changed:
variable __revision__ → variable __revision__: str - changed:
variable __version__ → variable __version__: str
- removed:
function no_prefix(name) - removed:
variable all_names - removed:
variable base_names - removed:
variable bytes_sockopt_names - removed:
variable ctx_opt_names - removed:
variable draft_in - removed:
variable fd_sockopt_names - removed:
variable int64_sockopt_names - removed:
variable int_sockopt_names - removed:
variable msg_opt_names - removed:
variable new_in - removed:
variable removed_in - removed:
variable socket_type_names - removed:
variable switched_sockopt_names
- changed:
class GarbageCollector(object) → class GarbageCollector
- changed:
function parse_monitor_message(msg) → function parse_monitor_message(msg: List[bytes]) -> _MonitorMessage - changed:
function recv_monitor_message(socket, flags=…) → function recv_monitor_message(socket: zmq.asyncio.Socket, flags: int=…) -> Awaitable[_MonitorMessage] | (socket: zmq.Socket[bytes], flags: int=…) -> _MonitorMessage