Upgrading pyzmq 26 to 27
Review needed26.4.0 → 27.2.0Other1
Review neededUpgrade verdict
A major version jump with sparse notes. Read the release notes before upgrading.
In plain terms
- The notes are sparse for a jump this size, so read them first.
Must act Nothing to change
No breaking, platform, security or deprecated items in this range.
Python requirement changed in 27.2.0: >=3.8 → >=3.9.
Nothing in this upgrade needs a code or configuration change.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
export backend - removed:
export sugar - removed:
function get_library_dirs() -> list[str] - added:
export PYZMQ_DRAFT_API - added:
variable __version__: str
- changed:
constructor ZMQEventLoop(selector=…) → constructor ZMQEventLoop(selector: selectors.BaseSelector | None=…) -> None - changed:
function install() → function install() -> None
- changed:
async method Authenticator.handle_zap_message(msg: List[bytes]) → async method Authenticator.handle_zap_message(msg: list[bytes]) -> None - changed:
field Authenticator.certs: Dict[str, Dict[bytes, Any]] → field Authenticator.certs: dict[str, dict[bytes, Any]] - changed:
field Authenticator.credentials_providers: Dict[str, Any] → field Authenticator.credentials_providers: dict[str, Any] - changed:
field Authenticator.passwords: Dict[str, Dict[str, str]] → field Authenticator.passwords: dict[str, dict[str, str]] - changed:
method Authenticator.configure_plain(domain: str=…, passwords: Optional[Dict[str, str]]=…) -> None → method Authenticator.configure_plain(domain: str=…, passwords: Optional[dict[str, str]]=…) -> None
- changed:
function create_certificates(key_dir: Union[str, os.PathLike], name: str, metadata: Optional[Dict[str, str]]=…) -> Tuple[str, str] → function create_certificates(key_dir: Union[str, os.PathLike], name: str, metadata: Optional[dict[str, str]]=…) -> tuple[str, str] - changed:
function load_certificate(filename: Union[str, os.PathLike]) -> Tuple[bytes, Optional[bytes]] → function load_certificate(filename: Union[str, os.PathLike]) -> tuple[bytes, Optional[bytes]] - changed:
function load_certificates(directory: Union[str, os.PathLike]=…) -> Dict[bytes, bool] → function load_certificates(directory: Union[str, os.PathLike]=…) -> dict[bytes, bool]
- removed:
export select_backend - removed:
export zmq - removed:
field Context.underlying: int - removed:
field Frame.buffer: Any - removed:
field Frame.bytes: bytes - removed:
field Socket.underlying: int - removed:
function zmq_version() -> str - removed:
method Context.socket(socket_type: int) -> Socket - removed:
method Frame.copy_fast() -> T - removed:
variable T - removed:
variable monitored_queue - changed:
constructor Context(io_threads: int=…, shadow: int=…) → constructor Context(io_threads: int=…, shadow: int=…) -> None - changed:
constructor Frame(data: Any=…, track: bool=…, copy: bool | None=…, copy_threshold: int | None=…) → constructor Frame(data: Any=…, track: bool=…, copy: bool | None=…, copy_threshold: int | None=…) -> None - changed:
function curve_public(secret_key: bytes) -> bytes → function curve_public(secret_key: str | bytes) -> bytes - changed:
function strerror(errno: int | None=…) -> str → function strerror(errno: int) -> str - changed:
function zmq_poll(sockets: list[Any], timeout: int | None=…) -> list[tuple[Socket, int]] → function zmq_poll(sockets: Sequence[tuple[Socket, int]], timeout: int=…) -> list[tuple[Socket, int]] | (sockets: Sequence[tuple[int | HasFileno, int]], timeout: int=…) -> list[tuple[int, int]] - changed:
method Context.get(option: int) -> int | bytes | str → method Context.get(option: int) -> int - changed:
method Context.set(option: int, value: int | bytes | str) -> None → method Context.set(option: int, optval: int) -> None - changed:
method Frame.get(option: int) -> int | _bytestr | str → method Frame.get(option: int | Literal['routing_id']) -> int | (option: bytes | Literal['group']) -> str | (option: str) -> int | str - changed:
method Frame.set(option: int, value: int | _bytestr | str) -> None → method Frame.set(option: Literal['routing_id'], value: int) -> None | (option: Literal['group'], value: str | bytes) -> None | (option: int, value: int) -> None - changed:
method Socket.bind(url: str) → method Socket.bind(addr: str) -> None - changed:
method Socket.connect(url: str) → method Socket.connect(addr: str) -> None - changed:
method Socket.disconnect(url: str) -> None → method Socket.disconnect(addr: str | bytes) -> None - changed:
method Socket.get(option: int) -> int | bytes | str → method Socket.get(option: int) -> int | bytes - changed:
method Socket.join(group: str) -> None → method Socket.join(group: str | bytes) -> None - changed:
method Socket.leave(group: str) -> None → method Socket.leave(group: str | bytes) -> None - changed:
method Socket.monitor(addr: str | None, events: int) -> None → method Socket.monitor(addr: str | bytes | None, events: int=…) -> None - changed:
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: int | None=…, copy: bool=…, track: bool | None=…) -> zmq.Frame | bytes → method Socket.recv(flags: int=…, copy: Literal[True]=…, track: bool=…) -> bytes | (flags: int=…, *, copy: Literal[False], track: bool=…) -> zmq.Frame | (flags: int, copy: Literal[False], track: bool=…) -> zmq.Frame | (flags: int=…, copy: bool=…, track: bool=…) -> bytes | zmq.Frame - changed:
method Socket.recv_into(buf, /, *, nbytes: int=…, flags: int=…) -> int → method Socket.recv_into(buffer: Buffer, /, *, nbytes: int=…, flags: int=…) -> int - changed:
method Socket.send(data: Any, flags: int=…, copy: bool=…, track: bool=…) -> zmq.MessageTracker | None → method Socket.send(data: Buffer, flags: int=…, copy: Literal[True]=…, track: bool=…) -> None | (data: Buffer, flags: int=…, *, copy: Literal[False], track: bool=…) -> zmq.MessageTracker | (data: Buffer, flags: int, copy: Literal[False], track: bool=…) -> zmq.MessageTracker | (data: Frame, flags: int=…, copy: bool=…, track: bool=…) -> zmq.MessageTracker - changed:
method Socket.set(option: int, value: int | bytes | str) -> None → method Socket.set(option: int, optval: int | bytes) -> None - changed:
method Socket.unbind(url: str) -> None → method Socket.unbind(addr: str | bytes) -> None - changed:
variable IPC_PATH_MAX_LEN: int → variable IPC_PATH_MAX_LEN: Final[int] - added:
field Context.closed: bool - added:
field Context.handle: int - added:
method Frame.fast_copy() -> Self - added:
property Context.underlying -> int - added:
property Frame.buffer -> memoryview - added:
property Frame.bytes -> bytes - added:
property Socket.closed -> bool - added:
property Socket.underlying -> int - added:
variable Message - added:
variable PYZMQ_DRAFT_API: Final[bool]
- added:
variable PYZMQ_DRAFT_API: bool
- changed:
function select_backend(name: str) -> Dict → function select_backend(name: str) -> dict[str, Any]
- changed:
variable AFFINITY: int → variable AFFINITY: SocketOption - changed:
variable BACKLOG: int → variable BACKLOG: SocketOption - changed:
variable BINDTODEVICE: int → variable BINDTODEVICE: SocketOption - changed:
variable BLOCKY: int → variable BLOCKY: SocketOption - changed:
variable BUSY_POLL: int → variable BUSY_POLL: SocketOption - changed:
variable CHANNEL: int → variable CHANNEL: SocketType - changed:
variable CLIENT: int → variable CLIENT: SocketType - changed:
variable CONFLATE: int → variable CONFLATE: SocketOption - changed:
variable CONNECT_RID: int → variable CONNECT_RID: SocketOption - changed:
variable CONNECT_ROUTING_ID: int → variable CONNECT_ROUTING_ID: SocketOption - changed:
variable CONNECT_TIMEOUT: int → variable CONNECT_TIMEOUT: SocketOption - changed:
variable CURVE: int → variable CURVE: SecurityMechanism - changed:
variable CURVE_PUBLICKEY: int → variable CURVE_PUBLICKEY: SocketOption - changed:
variable CURVE_SECRETKEY: int → variable CURVE_SECRETKEY: SocketOption - changed:
variable CURVE_SERVER: int → variable CURVE_SERVER: SocketOption - changed:
variable CURVE_SERVERKEY: int → variable CURVE_SERVERKEY: SocketOption - changed:
variable DEALER: int → variable DEALER: SocketType - changed:
variable DELAY_ATTACH_ON_CONNECT: int → variable DELAY_ATTACH_ON_CONNECT: SocketOption - changed:
variable DGRAM: int → variable DGRAM: SocketType - changed:
variable DISCONNECT_MSG: int → variable DISCONNECT_MSG: SocketOption - changed:
variable DISH: int → variable DISH: SocketType - changed:
variable DONTWAIT: int → variable DONTWAIT: Flag - changed:
variable EADDRINUSE: int → variable EADDRINUSE: Errno - changed:
variable EADDRNOTAVAIL: int → variable EADDRNOTAVAIL: Errno - changed:
variable EAFNOSUPPORT: int → variable EAFNOSUPPORT: Errno - changed:
variable EAGAIN: int → variable EAGAIN: Errno - changed:
variable ECONNABORTED: int → variable ECONNABORTED: Errno - changed:
variable ECONNREFUSED: int → variable ECONNREFUSED: Errno - changed:
variable ECONNRESET: int → variable ECONNRESET: Errno - changed:
variable EFAULT: int → variable EFAULT: Errno - changed:
variable EFSM: int → variable EFSM: Errno - changed:
variable EHOSTUNREACH: int → variable EHOSTUNREACH: Errno - changed:
variable EINPROGRESS: int → variable EINPROGRESS: Errno - changed:
variable EINVAL: int → variable EINVAL: Errno - changed:
variable EMSGSIZE: int → variable EMSGSIZE: Errno - changed:
variable EMTHREAD: int → variable EMTHREAD: Errno - changed:
variable ENETDOWN: int → variable ENETDOWN: Errno - changed:
variable ENETRESET: int → variable ENETRESET: Errno - changed:
variable ENETUNREACH: int → variable ENETUNREACH: Errno - changed:
variable ENOBUFS: int → variable ENOBUFS: Errno - changed:
variable ENOCOMPATPROTO: int → variable ENOCOMPATPROTO: Errno - changed:
variable ENOTCONN: int → variable ENOTCONN: Errno - changed:
variable ENOTSOCK: int → variable ENOTSOCK: Errno - changed:
variable ENOTSUP: int → variable ENOTSUP: Errno - changed:
variable EPROTONOSUPPORT: int → variable EPROTONOSUPPORT: Errno - changed:
variable ETERM: int → variable ETERM: Errno - changed:
variable ETIMEDOUT: int → variable ETIMEDOUT: Errno - changed:
variable EVENTS: int → variable EVENTS: SocketOption - changed:
variable EVENT_ACCEPTED: int → variable EVENT_ACCEPTED: Event - changed:
variable EVENT_ACCEPT_FAILED: int → variable EVENT_ACCEPT_FAILED: Event - changed:
variable EVENT_ALL: int → variable EVENT_ALL: Event - changed:
variable EVENT_ALL_V1: int → variable EVENT_ALL_V1: Event - changed:
variable EVENT_ALL_V2: int → variable EVENT_ALL_V2: Event - changed:
variable EVENT_BIND_FAILED: int → variable EVENT_BIND_FAILED: Event - changed:
variable EVENT_CLOSED: int → variable EVENT_CLOSED: Event - changed:
variable EVENT_CLOSE_FAILED: int → variable EVENT_CLOSE_FAILED: Event - changed:
variable EVENT_CONNECTED: int → variable EVENT_CONNECTED: Event - changed:
variable EVENT_CONNECT_DELAYED: int → variable EVENT_CONNECT_DELAYED: Event - changed:
variable EVENT_CONNECT_RETRIED: int → variable EVENT_CONNECT_RETRIED: Event - changed:
variable EVENT_DISCONNECTED: int → variable EVENT_DISCONNECTED: Event - changed:
variable EVENT_HANDSHAKE_FAILED_AUTH: int → variable EVENT_HANDSHAKE_FAILED_AUTH: Event - changed:
variable EVENT_HANDSHAKE_FAILED_NO_DETAIL: int → variable EVENT_HANDSHAKE_FAILED_NO_DETAIL: Event - changed:
variable EVENT_HANDSHAKE_FAILED_PROTOCOL: int → variable EVENT_HANDSHAKE_FAILED_PROTOCOL: Event - changed:
variable EVENT_HANDSHAKE_SUCCEEDED: int → variable EVENT_HANDSHAKE_SUCCEEDED: Event - changed:
variable EVENT_LISTENING: int → variable EVENT_LISTENING: Event - changed:
variable EVENT_MONITOR_STOPPED: int → variable EVENT_MONITOR_STOPPED: Event - changed:
variable EVENT_PIPES_STATS: int → variable EVENT_PIPES_STATS: Event - changed:
variable FAIL_UNROUTABLE: int → variable FAIL_UNROUTABLE: SocketOption - changed:
variable FD: int → variable FD: SocketOption - changed:
variable FORWARDER: int → variable FORWARDER: DeviceType - changed:
variable GATHER: int → variable GATHER: SocketType - changed:
variable GSSAPI: int → variable GSSAPI: SecurityMechanism - changed:
variable GSSAPI_PLAINTEXT: int → variable GSSAPI_PLAINTEXT: SocketOption - changed:
variable GSSAPI_PRINCIPAL: int → variable GSSAPI_PRINCIPAL: SocketOption - changed:
variable GSSAPI_PRINCIPAL_NAMETYPE: int → variable GSSAPI_PRINCIPAL_NAMETYPE: SocketOption - changed:
variable GSSAPI_SERVER: int → variable GSSAPI_SERVER: SocketOption - changed:
variable GSSAPI_SERVICE_PRINCIPAL: int → variable GSSAPI_SERVICE_PRINCIPAL: SocketOption - changed:
variable GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int → variable GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: SocketOption - changed:
variable HANDSHAKE_IVL: int → variable HANDSHAKE_IVL: SocketOption - changed:
variable HEARTBEAT_IVL: int → variable HEARTBEAT_IVL: SocketOption - changed:
variable HEARTBEAT_TIMEOUT: int → variable HEARTBEAT_TIMEOUT: SocketOption - changed:
variable HEARTBEAT_TTL: int → variable HEARTBEAT_TTL: SocketOption - changed:
variable HELLO_MSG: int → variable HELLO_MSG: SocketOption - changed:
variable HICCUP_MSG: int → variable HICCUP_MSG: SocketOption - changed:
variable HWM: int → variable HWM: SocketOption - changed:
variable IDENTITY: int → variable IDENTITY: SocketOption - changed:
variable IMMEDIATE: int → variable IMMEDIATE: SocketOption - changed:
variable INVERT_MATCHING: int → variable INVERT_MATCHING: SocketOption - changed:
variable IN_BATCH_SIZE: int → variable IN_BATCH_SIZE: SocketOption - changed:
variable IO_THREADS: int → variable IO_THREADS: ContextOption - changed:
variable IPC_FILTER_GID: int → variable IPC_FILTER_GID: SocketOption - changed:
variable IPC_FILTER_PID: int → variable IPC_FILTER_PID: SocketOption - changed:
variable IPC_FILTER_UID: int → variable IPC_FILTER_UID: SocketOption - changed:
variable IPV4ONLY: int → variable IPV4ONLY: SocketOption - changed:
variable IPV6: int → variable IPV6: SocketOption - changed:
variable LAST_ENDPOINT: int → variable LAST_ENDPOINT: SocketOption - changed:
variable LINGER: int → variable LINGER: SocketOption - changed:
variable LOOPBACK_FASTPATH: int → variable LOOPBACK_FASTPATH: SocketOption - changed:
variable MAXMSGSIZE: int → variable MAXMSGSIZE: SocketOption - changed:
variable MAX_MSGSZ: int → variable MAX_MSGSZ: ContextOption - changed:
variable MAX_SOCKETS: int → variable MAX_SOCKETS: ContextOption - changed:
variable MECHANISM: int → variable MECHANISM: SocketOption - changed:
variable METADATA: int → variable METADATA: SocketOption - changed:
variable MORE: int → variable MORE: MessageOption - changed:
variable MSG_T_SIZE: int → variable MSG_T_SIZE: ContextOption - changed:
variable MULTICAST_HOPS: int → variable MULTICAST_HOPS: SocketOption - changed:
variable MULTICAST_LOOP: int → variable MULTICAST_LOOP: SocketOption - changed:
variable MULTICAST_MAXTPDU: int → variable MULTICAST_MAXTPDU: SocketOption - changed:
variable NOBLOCK: int → variable NOBLOCK: Flag - changed:
variable NORM_BLOCK_SIZE: int → variable NORM_BLOCK_SIZE: SocketOption - changed:
variable NORM_BUFFER_SIZE: int → variable NORM_BUFFER_SIZE: SocketOption - changed:
variable NORM_CC: int → variable NORM_CC: NormMode - changed:
variable NORM_CCE: int → variable NORM_CCE: NormMode - changed:
variable NORM_CCE_ECNONLY: int → variable NORM_CCE_ECNONLY: NormMode - changed:
variable NORM_CCL: int → variable NORM_CCL: NormMode - changed:
variable NORM_FIXED: int → variable NORM_FIXED: NormMode - changed:
variable NORM_MODE: int → variable NORM_MODE: SocketOption - changed:
variable NORM_NUM_AUTOPARITY: int → variable NORM_NUM_AUTOPARITY: SocketOption - changed:
variable NORM_NUM_PARITY: int → variable NORM_NUM_PARITY: SocketOption - changed:
variable NORM_PUSH: int → variable NORM_PUSH: SocketOption - changed:
variable NORM_SEGMENT_SIZE: int → variable NORM_SEGMENT_SIZE: SocketOption - changed:
variable NORM_UNICAST_NACK: int → variable NORM_UNICAST_NACK: SocketOption - changed:
variable NOTIFY_CONNECT: int → variable NOTIFY_CONNECT: RouterNotify - changed:
variable NOTIFY_DISCONNECT: int → variable NOTIFY_DISCONNECT: RouterNotify - changed:
variable NULL: int → variable NULL: SecurityMechanism - changed:
variable ONLY_FIRST_SUBSCRIBE: int → variable ONLY_FIRST_SUBSCRIBE: SocketOption - changed:
variable OUT_BATCH_SIZE: int → variable OUT_BATCH_SIZE: SocketOption - changed:
variable PAIR: int → variable PAIR: SocketType - changed:
variable PEER: int → variable PEER: SocketType - changed:
variable PLAIN: int → variable PLAIN: SecurityMechanism - changed:
variable PLAIN_PASSWORD: int → variable PLAIN_PASSWORD: SocketOption - changed:
variable PLAIN_SERVER: int → variable PLAIN_SERVER: SocketOption - changed:
variable PLAIN_USERNAME: int → variable PLAIN_USERNAME: SocketOption - changed:
variable POLLERR: int → variable POLLERR: PollEvent - changed:
variable POLLIN: int → variable POLLIN: PollEvent - changed:
variable POLLOUT: int → variable POLLOUT: PollEvent - changed:
variable POLLPRI: int → variable POLLPRI: PollEvent - changed:
variable PRIORITY: int → variable PRIORITY: SocketOption - changed:
variable PROBE_ROUTER: int → variable PROBE_ROUTER: SocketOption - changed:
variable PROTOCOL_ERROR_WS_UNSPECIFIED: int → variable PROTOCOL_ERROR_WS_UNSPECIFIED: Event - changed:
variable PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int → variable PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: Event - changed:
variable PROTOCOL_ERROR_ZAP_BAD_VERSION: int → variable PROTOCOL_ERROR_ZAP_BAD_VERSION: Event - changed:
variable PROTOCOL_ERROR_ZAP_INVALID_METADATA: int → variable PROTOCOL_ERROR_ZAP_INVALID_METADATA: Event - changed:
variable PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int → variable PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: Event - changed:
variable PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int → variable PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: Event - changed:
variable PROTOCOL_ERROR_ZAP_UNSPECIFIED: int → variable PROTOCOL_ERROR_ZAP_UNSPECIFIED: Event - changed:
variable PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int → variable PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: Event - changed:
variable PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int → variable PROTOCOL_ERROR_ZMTP_INVALID_METADATA: Event - changed:
variable PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int → variable PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: Event - changed:
variable PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int → variable PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int → variable PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: Event - changed:
variable PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int → variable PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: Event - changed:
variable PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int → variable PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: Event - changed:
variable PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int → variable PROTOCOL_ERROR_ZMTP_UNSPECIFIED: Event - changed:
variable PUB: int → variable PUB: SocketType - changed:
variable PULL: int → variable PULL: SocketType - changed:
variable PUSH: int → variable PUSH: SocketType - changed:
variable QUEUE: int → variable QUEUE: DeviceType - changed:
variable RADIO: int → variable RADIO: SocketType - changed:
variable RATE: int → variable RATE: SocketOption - changed:
variable RCVBUF: int → variable RCVBUF: SocketOption - changed:
variable RCVHWM: int → variable RCVHWM: SocketOption - changed:
variable RCVMORE: int → variable RCVMORE: SocketOption - changed:
variable RCVTIMEO: int → variable RCVTIMEO: SocketOption - changed:
variable RECONNECT_IVL: int → variable RECONNECT_IVL: SocketOption - changed:
variable RECONNECT_IVL_MAX: int → variable RECONNECT_IVL_MAX: SocketOption - changed:
variable RECONNECT_STOP: int → variable RECONNECT_STOP: SocketOption - changed:
variable RECONNECT_STOP_AFTER_DISCONNECT: int → variable RECONNECT_STOP_AFTER_DISCONNECT: ReconnectStop - changed:
variable RECONNECT_STOP_CONN_REFUSED: int → variable RECONNECT_STOP_CONN_REFUSED: ReconnectStop - changed:
variable RECONNECT_STOP_HANDSHAKE_FAILED: int → variable RECONNECT_STOP_HANDSHAKE_FAILED: ReconnectStop - changed:
variable RECOVERY_IVL: int → variable RECOVERY_IVL: SocketOption - changed:
variable REP: int → variable REP: SocketType - changed:
variable REQ: int → variable REQ: SocketType - changed:
variable REQ_CORRELATE: int → variable REQ_CORRELATE: SocketOption - changed:
variable REQ_RELAXED: int → variable REQ_RELAXED: SocketOption - changed:
variable ROUTER: int → variable ROUTER: SocketType - changed:
variable ROUTER_BEHAVIOR: int → variable ROUTER_BEHAVIOR: SocketOption - changed:
variable ROUTER_HANDOVER: int → variable ROUTER_HANDOVER: SocketOption - changed:
variable ROUTER_MANDATORY: int → variable ROUTER_MANDATORY: SocketOption - changed:
variable ROUTER_NOTIFY: int → variable ROUTER_NOTIFY: SocketOption - changed:
variable ROUTER_RAW: int → variable ROUTER_RAW: SocketOption - changed:
variable ROUTING_ID: int → variable ROUTING_ID: SocketOption - changed:
variable SCATTER: int → variable SCATTER: SocketType - changed:
variable SERVER: int → variable SERVER: SocketType - changed:
variable SHARED: int → variable SHARED: MessageOption - changed:
variable SNDBUF: int → variable SNDBUF: SocketOption - changed:
variable SNDHWM: int → variable SNDHWM: SocketOption - changed:
variable SNDMORE: int → variable SNDMORE: Flag - changed:
variable SNDTIMEO: int → variable SNDTIMEO: SocketOption - changed:
variable SOCKET_LIMIT: int → variable SOCKET_LIMIT: ContextOption - changed:
variable SOCKS_PASSWORD: int → variable SOCKS_PASSWORD: SocketOption - changed:
variable SOCKS_PROXY: int → variable SOCKS_PROXY: SocketOption - changed:
variable SOCKS_USERNAME: int → variable SOCKS_USERNAME: SocketOption - changed:
variable SRCFD: int → variable SRCFD: MessageOption - changed:
variable STREAM: int → variable STREAM: SocketType - changed:
variable STREAMER: int → variable STREAMER: DeviceType - changed:
variable STREAM_NOTIFY: int → variable STREAM_NOTIFY: SocketOption - changed:
variable SUB: int → variable SUB: SocketType - changed:
variable SUBSCRIBE: int → variable SUBSCRIBE: SocketOption - changed:
variable TCP_ACCEPT_FILTER: int → variable TCP_ACCEPT_FILTER: SocketOption - changed:
variable TCP_KEEPALIVE: int → variable TCP_KEEPALIVE: SocketOption - changed:
variable TCP_KEEPALIVE_CNT: int → variable TCP_KEEPALIVE_CNT: SocketOption - changed:
variable TCP_KEEPALIVE_IDLE: int → variable TCP_KEEPALIVE_IDLE: SocketOption - changed:
variable TCP_KEEPALIVE_INTVL: int → variable TCP_KEEPALIVE_INTVL: SocketOption - changed:
variable TCP_MAXRT: int → variable TCP_MAXRT: SocketOption - changed:
variable THREAD_AFFINITY_CPU_ADD: int → variable THREAD_AFFINITY_CPU_ADD: ContextOption - changed:
variable THREAD_AFFINITY_CPU_REMOVE: int → variable THREAD_AFFINITY_CPU_REMOVE: ContextOption - changed:
variable THREAD_NAME_PREFIX: int → variable THREAD_NAME_PREFIX: ContextOption - changed:
variable THREAD_PRIORITY: int → variable THREAD_PRIORITY: ContextOption - changed:
variable THREAD_SAFE: int → variable THREAD_SAFE: SocketOption - changed:
variable THREAD_SCHED_POLICY: int → variable THREAD_SCHED_POLICY: ContextOption - changed:
variable TOPICS_COUNT: int → variable TOPICS_COUNT: SocketOption - changed:
variable TOS: int → variable TOS: SocketOption - changed:
variable TYPE: int → variable TYPE: SocketOption - changed:
variable UNSUBSCRIBE: int → variable UNSUBSCRIBE: SocketOption - changed:
variable USE_FD: int → variable USE_FD: SocketOption - changed:
variable VMCI_BUFFER_MAX_SIZE: int → variable VMCI_BUFFER_MAX_SIZE: SocketOption - changed:
variable VMCI_BUFFER_MIN_SIZE: int → variable VMCI_BUFFER_MIN_SIZE: SocketOption - changed:
variable VMCI_BUFFER_SIZE: int → variable VMCI_BUFFER_SIZE: SocketOption - changed:
variable VMCI_CONNECT_TIMEOUT: int → variable VMCI_CONNECT_TIMEOUT: SocketOption - changed:
variable WSS_CERT_PEM: int → variable WSS_CERT_PEM: SocketOption - changed:
variable WSS_HOSTNAME: int → variable WSS_HOSTNAME: SocketOption - changed:
variable WSS_KEY_PEM: int → variable WSS_KEY_PEM: SocketOption - changed:
variable WSS_TRUST_PEM: int → variable WSS_TRUST_PEM: SocketOption - changed:
variable WSS_TRUST_SYSTEM: int → variable WSS_TRUST_SYSTEM: SocketOption - changed:
variable XPUB: int → variable XPUB: SocketType - changed:
variable XPUB_MANUAL: int → variable XPUB_MANUAL: SocketOption - changed:
variable XPUB_MANUAL_LAST_VALUE: int → variable XPUB_MANUAL_LAST_VALUE: SocketOption - changed:
variable XPUB_NODROP: int → variable XPUB_NODROP: SocketOption - changed:
variable XPUB_VERBOSE: int → variable XPUB_VERBOSE: SocketOption - changed:
variable XPUB_VERBOSER: int → variable XPUB_VERBOSER: SocketOption - changed:
variable XPUB_WELCOME_MSG: int → variable XPUB_WELCOME_MSG: SocketOption - changed:
variable XREP: int → variable XREP: SocketType - changed:
variable XREQ: int → variable XREQ: SocketType - changed:
variable XSUB: int → variable XSUB: SocketType - changed:
variable XSUB_VERBOSE_UNSUBSCRIBE: int → variable XSUB_VERBOSE_UNSUBSCRIBE: SocketOption - changed:
variable ZAP_DOMAIN: int → variable ZAP_DOMAIN: SocketOption - changed:
variable ZAP_ENFORCE_DOMAIN: int → variable ZAP_ENFORCE_DOMAIN: SocketOption
- changed:
function context(*args, **kwargs) → function context(*args: Any, **kwargs: Any) -> _DecoratorCallable - changed:
function socket(*args, **kwargs) → function socket(*args: Any, **kwargs: Any) -> _DecoratorCallable
- changed:
constructor Again(errno=…, msg=…) → constructor Again(errno: int | Literal['ignored']=…, msg: str=…) -> None - changed:
constructor ContextTerminated(errno=…, msg=…) → constructor ContextTerminated(errno: int | Literal['ignored']=…, msg: str=…) -> None - changed:
constructor InterruptedSystemCall(errno=…, msg=…) → constructor InterruptedSystemCall(errno: int | Literal['ignored']=…, msg: str=…) -> None - changed:
constructor ZMQVersionError(min_version: str, msg: str=…) → constructor ZMQVersionError(min_version: str, msg: str=…) -> None - changed:
field ZMQVersionError.min_version → field ZMQVersionError.min_version: str - added:
class DraftFDWarning(RuntimeWarning) - added:
constructor DraftFDWarning(msg: str=…) -> None - added:
field ZMQVersionError.msg: str - added:
field ZMQVersionError.version: str
- changed:
method PUBHandler.emit(record) → method PUBHandler.emit(record: logging.LogRecord) -> None - changed:
method PUBHandler.format(record) → method PUBHandler.format(record: logging.LogRecord) -> str - changed:
method PUBHandler.setFormatter(fmt, level=…) → method PUBHandler.setFormatter(fmt: logging.Formatter | None, level: int=…) -> None - changed:
method PUBHandler.setRootTopic(root_topic: str) → method PUBHandler.setRootTopic(root_topic: str) -> None - changed:
method TopicLogger.log(level, topic, msg, *args, **kwargs) → method TopicLogger.log(level: int, topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - changed:
variable TOPIC_DELIM → variable TOPIC_DELIM: Final - added:
field PUBHandler.formatters: dict[int, logging.Formatter | None] - added:
method TopicLogger.critical(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - added:
method TopicLogger.debug(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - added:
method TopicLogger.error(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - added:
method TopicLogger.fatal(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - added:
method TopicLogger.warn(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None - added:
method TopicLogger.warning(topic: str, msg: str, *args: Any, **kwargs: Unpack[_LogKwargs]) -> None
- changed:
function forward_tunnel(local_port, remote_host, remote_port, transport) → function forward_tunnel(local_port: int, remote_host: str, remote_port: int, transport: paramiko.Transport) -> None
- changed:
function openssh_tunnel(lport, rport, server, remoteip=…, keyfile=…, password=…, timeout=…) → function openssh_tunnel(lport: int, rport: int, server: str, remoteip: str=…, keyfile: str | None=…, password: str | None=…, timeout: int=…) -> int - changed:
function paramiko_tunnel(lport, rport, server, remoteip=…, keyfile=…, password=…, timeout=…) → function paramiko_tunnel(lport: int, rport: int, server: str, remoteip: str=…, keyfile: str | None=…, password: str | None=…, timeout: int=…) -> Process - changed:
function try_passwordless_ssh(server, keyfile, paramiko=…) → function try_passwordless_ssh(server: str, keyfile: str | None, paramiko: bool | None=…) -> bool - changed:
function tunnel_connection(socket, addr, server, keyfile=…, password=…, paramiko=…, timeout=…) → function tunnel_connection(socket: socket.socket, addr: str, server: str, keyfile: str | None=…, password: str | None=…, *, paramiko: Literal[True], timeout: int=…) -> Process | (socket: socket.socket, addr: str, server: str, keyfile: str | None=…, password: str | None=…, *, paramiko: Literal[False], timeout: int=…) -> int | (socket: socket.socket, addr: str, server: str, keyfile: str | None=…, p…
- removed:
export constants - added:
class Stopwatch - added:
constructor Stopwatch() -> None - added:
function device(device_type: DeviceType, frontend: Socket, backend: Socket) -> int - added:
method Stopwatch.start() -> None - added:
method Stopwatch.stop() -> int
- changed:
method AttributeSetter.get(opt: int) -> OptValT → method AttributeSetter.get(option: int) -> OptValT - changed:
method AttributeSetter.set(opt: int, val: OptValT) -> None → method AttributeSetter.set(option: int, value: Any) -> None
- removed:
property Frame.group - removed:
property Frame.routing_id - added:
property Frame.group -> str - added:
property Frame.routing_id -> int
- changed:
class Socket(SocketBase, AttributeSetter, Generic[SocketReturnType]) → class Socket(SocketBase, AttributeSetter, Generic[_SocketReturnT_co]) - changed:
constructor Socket(ctx_or_socket: zmq.Context, socket_type: int, *, copy_threshold: int | None=…) | (*, shadow: Socket | int, copy_threshold: int | None=…) | (ctx_or_socket: Socket) → constructor Socket(ctx_or_socket: zmq.Context, socket_type: int, *, copy_threshold: int | None=…) -> None | (*, shadow: Socket | int, copy_threshold: int | None=…) -> None | (ctx_or_socket: Socket) -> None - changed:
field Socket.hwm → field Socket.hwm: property - changed:
method Socket.bind(addr: str) -> _SocketContext[_SocketType] → method Socket.bind(addr: str) -> _SocketContext[Self] - changed:
method Socket.close(linger=…) -> None → method Socket.close(linger: int | None=…) -> None - changed:
method Socket.connect(addr: str) -> _SocketContext[_SocketType] → method Socket.connect(addr: str) -> _SocketContext[Self] - changed:
method Socket.get_monitor_socket(events: int | None=…, addr: str | None=…) -> _SocketType → method Socket.get_monitor_socket(events: int | None=…, addr: str | None=…) -> Self - changed:
method Socket.get_string(option: int, encoding=…) -> str → method Socket.get_string(option: int, encoding: str=…) -> str - changed:
method Socket.recv_json(flags: int=…, **kwargs) -> _JSONType → method Socket.recv_json(flags: int=…, **kwargs: Any) -> _JSON - changed:
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=…) -> list[zmq.Frame] | list[bytes] → 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, copy: Literal[False], track: bool=…) -> list[zmq.Frame] | (flags: int, copy: bool, track: bool=…) -> list[bytes] | list[zmq.Frame] - changed:
method Socket.recv_serialized(deserialize, flags=…, copy=…) → method Socket.recv_serialized(deserialize: Callable[[list[bytes]], _RT], flags: int=…, copy: bool=…) -> _RT | (deserialize: Callable[[list[zmq.Frame]], _RT], flags: int=…, copy: bool=…) -> _RT - changed:
method Socket.send(data: Any, flags: int=…, copy: bool=…, *, track: Literal[True], routing_id: int | None=…, group: str | None=…) -> zmq.MessageTracker | (data: Any, flags: int=…, copy: bool=…, *, track: Literal[False], routing_id: int | None=…, group: str | None=…) -> None | (data: Any, flags: int=…, *, copy: bool=…, routing_id: int | None=…, group: str | None=…) -> None | (data: Any, flags: int… → method Socket.send(data: Buffer, flags: int=…, copy: Literal[True]=…, track: bool=…, routing_id: int | None=…, group: str | None=…) -> None | (data: Buffer, flags: int=…, *, copy: Literal[False], track: bool=…, routing_id: int | None=…, group: str | None=…) -> zmq.MessageTracker | (data: Buffer, flags: int, copy: Literal[False], track: bool=…, routing_id: int | None=…, group: str | None=…) -> zmq… - changed:
method Socket.send_json(obj: Any, flags: int=…, **kwargs) -> None → method Socket.send_json(obj: object, flags: int=…, **kwargs: Any) -> None - changed:
method Socket.send_multipart(msg_parts: Sequence, flags: int=…, copy: bool=…, track: bool=…, **kwargs) → method Socket.send_multipart(msg_parts: Sequence[zmq.Frame | Buffer], flags: int=…, copy: bool=…, track: bool=…, **kwargs: Any) -> zmq.MessageTracker | None - changed:
method Socket.send_pyobj(obj: Any, flags: int=…, protocol: int=…, **kwargs) -> zmq.Frame | None → method Socket.send_pyobj(obj: object, flags: int=…, protocol: int=…, **kwargs: Any) -> zmq.MessageTracker | None - changed:
method Socket.send_serialized(msg, serialize, flags=…, copy=…, **kwargs) → method Socket.send_serialized(msg: _T, serialize: Callable[[_T], Sequence[zmq.Frame | Buffer]], flags: int=…, copy: bool=…, **kwargs: Any) -> zmq.MessageTracker | None - changed:
method Socket.send_string(u: str, flags: int=…, copy: bool=…, encoding: str=…, **kwargs) -> zmq.Frame | None → method Socket.send_string(u: str, flags: int=…, copy: bool=…, encoding: str=…, **kwargs: Any) -> zmq.MessageTracker | None - changed:
method Socket.set_string(option: int, optval: str, encoding=…) -> None → method Socket.set_string(option: int, optval: str, encoding: str=…) -> None - changed:
static method Socket.shadow(address: int | zmq.Socket) -> _SocketType → static method Socket.shadow(address: int | zmq.Socket) -> Self - added:
field Socket.context: zmq.Context - added:
property Socket.hwm -> int
- removed:
property GarbageCollector.context - removed:
variable gcref - changed:
constructor GarbageCollector(context=…) → constructor GarbageCollector(context: zmq.Context | None=…) -> None - changed:
constructor GarbageCollectorThread(gc) → constructor GarbageCollectorThread(gc: GarbageCollector) -> None - changed:
field GarbageCollector.refs → field GarbageCollector.refs: dict[int, gcref] - changed:
method GarbageCollector.is_alive() → method GarbageCollector.is_alive() -> bool - changed:
method GarbageCollector.start() → method GarbageCollector.start() -> None - changed:
method GarbageCollector.stop() → method GarbageCollector.stop() -> None - changed:
method GarbageCollector.store(obj, event=…) → method GarbageCollector.store(obj: object, event: Event | None=…) -> int - changed:
method GarbageCollectorThread.run() → method GarbageCollectorThread.run() -> None - changed:
variable gc → variable gc: Final[GarbageCollector] - added:
class gcref(NamedTuple) - added:
field GarbageCollectorThread.daemon: bool - added:
field GarbageCollectorThread.gc: GarbageCollector - added:
field GarbageCollectorThread.pid: int - added:
field GarbageCollectorThread.ready: Event - added:
field gcref.event: Event | None - added:
field gcref.obj: object - added:
property GarbageCollector.context -> zmq.Context
- changed:
function dumps(o: Any, **kwargs) -> bytes → function dumps(o: object, **kwargs: Any) -> bytes - changed:
function loads(s: bytes | str, **kwargs) -> dict | list | str | int | float → function loads(s: bytes | str, **kwargs: Any) -> dict[str, Any] | list[Any] | str | float
- changed:
function cast_bytes(s, encoding=…, errors=…) → function cast_bytes(s: str | bytes, encoding: str=…, errors: str=…) -> bytes - changed:
function cast_unicode(s, encoding=…, errors=…) → function cast_unicode(s: str | bytes, encoding: str=…, errors: str=…) -> str
- changed:
function decode(z85bytes) → function decode(z85bytes: str | _RawBytes) -> bytes - changed:
function encode(rawbytes) → function encode(rawbytes: _RawBytes) -> bytes - changed:
variable Z85CHARS → variable Z85CHARS: Final - changed:
variable Z85MAP → variable Z85MAP: Final[dict[int, int]]