Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/zmq/constants.py: 95%

1"""zmq constants as enums""" 

2 

3from __future__ import annotations 

4 

5import errno 

6import sys 

7from enum import Enum, IntEnum, IntFlag 

8from typing import TYPE_CHECKING 

9 

10if TYPE_CHECKING: 

11 from typing_extensions import Self 

12 

13_HAUSNUMERO = 156384712 

14 

15 

16class Errno(IntEnum): 

17 """libzmq error codes 

18 

19 .. versionadded:: 23 

20 """ 

21 

22 EAGAIN = errno.EAGAIN 

23 EFAULT = errno.EFAULT 

24 EINVAL = errno.EINVAL 

25 

26 if sys.platform.startswith("win"): 

27 # Windows: libzmq uses errno.h 

28 # while Python errno prefers WSA* variants 

29 # many of these were introduced to errno.h in vs2010 

30 # ref: https://github.com/python/cpython/blob/3.9/Modules/errnomodule.c#L10-L37 

31 # source: https://docs.microsoft.com/en-us/cpp/c-runtime-library/errno-constants 

32 ENOTSUP = 129 

33 EPROTONOSUPPORT = 135 

34 ENOBUFS = 119 

35 ENETDOWN = 116 

36 EADDRINUSE = 100 

37 EADDRNOTAVAIL = 101 

38 ECONNREFUSED = 107 

39 EINPROGRESS = 112 

40 ENOTSOCK = 128 

41 EMSGSIZE = 115 

42 EAFNOSUPPORT = 102 

43 ENETUNREACH = 118 

44 ECONNABORTED = 106 

45 ECONNRESET = 108 

46 ENOTCONN = 126 

47 ETIMEDOUT = 138 

48 EHOSTUNREACH = 110 

49 ENETRESET = 117 

50 

51 else: 

52 ENOTSUP = getattr(errno, "ENOTSUP", _HAUSNUMERO + 1) 

53 EPROTONOSUPPORT = getattr(errno, "EPROTONOSUPPORT", _HAUSNUMERO + 2) 

54 ENOBUFS = getattr(errno, "ENOBUFS", _HAUSNUMERO + 3) 

55 ENETDOWN = getattr(errno, "ENETDOWN", _HAUSNUMERO + 4) 

56 EADDRINUSE = getattr(errno, "EADDRINUSE", _HAUSNUMERO + 5) 

57 EADDRNOTAVAIL = getattr(errno, "EADDRNOTAVAIL", _HAUSNUMERO + 6) 

58 ECONNREFUSED = getattr(errno, "ECONNREFUSED", _HAUSNUMERO + 7) 

59 EINPROGRESS = getattr(errno, "EINPROGRESS", _HAUSNUMERO + 8) 

60 ENOTSOCK = getattr(errno, "ENOTSOCK", _HAUSNUMERO + 9) 

61 EMSGSIZE = getattr(errno, "EMSGSIZE", _HAUSNUMERO + 10) 

62 EAFNOSUPPORT = getattr(errno, "EAFNOSUPPORT", _HAUSNUMERO + 11) 

63 ENETUNREACH = getattr(errno, "ENETUNREACH", _HAUSNUMERO + 12) 

64 ECONNABORTED = getattr(errno, "ECONNABORTED", _HAUSNUMERO + 13) 

65 ECONNRESET = getattr(errno, "ECONNRESET", _HAUSNUMERO + 14) 

66 ENOTCONN = getattr(errno, "ENOTCONN", _HAUSNUMERO + 15) 

67 ETIMEDOUT = getattr(errno, "ETIMEDOUT", _HAUSNUMERO + 16) 

68 EHOSTUNREACH = getattr(errno, "EHOSTUNREACH", _HAUSNUMERO + 17) 

69 ENETRESET = getattr(errno, "ENETRESET", _HAUSNUMERO + 18) 

70 

71 # Native 0MQ error codes 

72 EFSM = _HAUSNUMERO + 51 

73 ENOCOMPATPROTO = _HAUSNUMERO + 52 

74 ETERM = _HAUSNUMERO + 53 

75 EMTHREAD = _HAUSNUMERO + 54 

76 

77 

78class ContextOption(IntEnum): 

79 """Options for Context.get/set 

80 

81 .. versionadded:: 23 

82 """ 

83 

84 IO_THREADS = 1 

85 MAX_SOCKETS = 2 

86 SOCKET_LIMIT = 3 

87 THREAD_PRIORITY = 3 

88 THREAD_SCHED_POLICY = 4 

89 MAX_MSGSZ = 5 

90 MSG_T_SIZE = 6 

91 THREAD_AFFINITY_CPU_ADD = 7 

92 THREAD_AFFINITY_CPU_REMOVE = 8 

93 THREAD_NAME_PREFIX = 9 

94 

95 

96class SocketType(IntEnum): 

97 """zmq socket types 

98 

99 .. versionadded:: 23 

100 """ 

101 

102 PAIR = 0 

103 PUB = 1 

104 SUB = 2 

105 REQ = 3 

106 REP = 4 

107 DEALER = 5 

108 ROUTER = 6 

109 PULL = 7 

110 PUSH = 8 

111 XPUB = 9 

112 XSUB = 10 

113 STREAM = 11 

114 

115 # deprecated aliases 

116 XREQ = DEALER 

117 XREP = ROUTER 

118 

119 # DRAFT socket types 

120 SERVER = 12 

121 CLIENT = 13 

122 RADIO = 14 

123 DISH = 15 

124 GATHER = 16 

125 SCATTER = 17 

126 DGRAM = 18 

127 PEER = 19 

128 CHANNEL = 20 

129 

130 

131class _OptType(Enum): 

132 int = 'int' 

133 int64 = 'int64' 

134 bytes = 'bytes' 

135 fd = 'fd' 

136 

137 

138class SocketOption(IntEnum): 

139 """Options for Socket.get/set 

140 

141 .. versionadded:: 23 

142 """ 

143 

144 _opt_type: _OptType 

145 

146 def __new__(cls, value: int, opt_type: _OptType = _OptType.int) -> Self: 

147 """Attach option type as `._opt_type`""" 

148 obj = int.__new__(cls, value) 

149 obj._value_ = value 

150 obj._opt_type = opt_type 

151 return obj 

152 

153 HWM = 1 

154 AFFINITY = 4, _OptType.int64 

155 ROUTING_ID = 5, _OptType.bytes 

156 SUBSCRIBE = 6, _OptType.bytes 

157 UNSUBSCRIBE = 7, _OptType.bytes 

158 RATE = 8 

159 RECOVERY_IVL = 9 

160 SNDBUF = 11 

161 RCVBUF = 12 

162 RCVMORE = 13 

163 FD = 14, _OptType.fd 

164 EVENTS = 15 

165 TYPE = 16 

166 LINGER = 17 

167 RECONNECT_IVL = 18 

168 BACKLOG = 19 

169 RECONNECT_IVL_MAX = 21 

170 MAXMSGSIZE = 22, _OptType.int64 

171 SNDHWM = 23 

172 RCVHWM = 24 

173 MULTICAST_HOPS = 25 

174 RCVTIMEO = 27 

175 SNDTIMEO = 28 

176 LAST_ENDPOINT = 32, _OptType.bytes 

177 ROUTER_MANDATORY = 33 

178 TCP_KEEPALIVE = 34 

179 TCP_KEEPALIVE_CNT = 35 

180 TCP_KEEPALIVE_IDLE = 36 

181 TCP_KEEPALIVE_INTVL = 37 

182 IMMEDIATE = 39 

183 XPUB_VERBOSE = 40 

184 ROUTER_RAW = 41 

185 IPV6 = 42 

186 MECHANISM = 43 

187 PLAIN_SERVER = 44 

188 PLAIN_USERNAME = 45, _OptType.bytes 

189 PLAIN_PASSWORD = 46, _OptType.bytes 

190 CURVE_SERVER = 47 

191 CURVE_PUBLICKEY = 48, _OptType.bytes 

192 CURVE_SECRETKEY = 49, _OptType.bytes 

193 CURVE_SERVERKEY = 50, _OptType.bytes 

194 PROBE_ROUTER = 51 

195 REQ_CORRELATE = 52 

196 REQ_RELAXED = 53 

197 CONFLATE = 54 

198 ZAP_DOMAIN = 55, _OptType.bytes 

199 ROUTER_HANDOVER = 56 

200 TOS = 57 

201 CONNECT_ROUTING_ID = 61, _OptType.bytes 

202 GSSAPI_SERVER = 62 

203 GSSAPI_PRINCIPAL = 63, _OptType.bytes 

204 GSSAPI_SERVICE_PRINCIPAL = 64, _OptType.bytes 

205 GSSAPI_PLAINTEXT = 65 

206 HANDSHAKE_IVL = 66 

207 SOCKS_PROXY = 68, _OptType.bytes 

208 XPUB_NODROP = 69 

209 BLOCKY = 70 

210 XPUB_MANUAL = 71 

211 XPUB_WELCOME_MSG = 72, _OptType.bytes 

212 STREAM_NOTIFY = 73 

213 INVERT_MATCHING = 74 

214 HEARTBEAT_IVL = 75 

215 HEARTBEAT_TTL = 76 

216 HEARTBEAT_TIMEOUT = 77 

217 XPUB_VERBOSER = 78 

218 CONNECT_TIMEOUT = 79 

219 TCP_MAXRT = 80 

220 THREAD_SAFE = 81 

221 MULTICAST_MAXTPDU = 84 

222 VMCI_BUFFER_SIZE = 85, _OptType.int64 

223 VMCI_BUFFER_MIN_SIZE = 86, _OptType.int64 

224 VMCI_BUFFER_MAX_SIZE = 87, _OptType.int64 

225 VMCI_CONNECT_TIMEOUT = 88 

226 USE_FD = 89 

227 GSSAPI_PRINCIPAL_NAMETYPE = 90 

228 GSSAPI_SERVICE_PRINCIPAL_NAMETYPE = 91 

229 BINDTODEVICE = 92, _OptType.bytes 

230 

231 # Deprecated options and aliases 

232 # must not use name-assignment, must have the same value 

233 IDENTITY = ROUTING_ID 

234 CONNECT_RID = CONNECT_ROUTING_ID 

235 TCP_ACCEPT_FILTER = 38, _OptType.bytes 

236 IPC_FILTER_PID = 58 

237 IPC_FILTER_UID = 59 

238 IPC_FILTER_GID = 60 

239 IPV4ONLY = 31 

240 DELAY_ATTACH_ON_CONNECT = IMMEDIATE 

241 FAIL_UNROUTABLE = ROUTER_MANDATORY 

242 ROUTER_BEHAVIOR = ROUTER_MANDATORY 

243 

244 # Draft socket options 

245 ZAP_ENFORCE_DOMAIN = 93 

246 LOOPBACK_FASTPATH = 94 

247 METADATA = 95, _OptType.bytes 

248 MULTICAST_LOOP = 96 

249 ROUTER_NOTIFY = 97 

250 XPUB_MANUAL_LAST_VALUE = 98 

251 SOCKS_USERNAME = 99, _OptType.bytes 

252 SOCKS_PASSWORD = 100, _OptType.bytes 

253 IN_BATCH_SIZE = 101 

254 OUT_BATCH_SIZE = 102 

255 WSS_KEY_PEM = 103, _OptType.bytes 

256 WSS_CERT_PEM = 104, _OptType.bytes 

257 WSS_TRUST_PEM = 105, _OptType.bytes 

258 WSS_HOSTNAME = 106, _OptType.bytes 

259 WSS_TRUST_SYSTEM = 107 

260 ONLY_FIRST_SUBSCRIBE = 108 

261 RECONNECT_STOP = 109 

262 HELLO_MSG = 110, _OptType.bytes 

263 DISCONNECT_MSG = 111, _OptType.bytes 

264 PRIORITY = 112 

265 # 4.3.5 

266 BUSY_POLL = 113 

267 HICCUP_MSG = 114, _OptType.bytes 

268 XSUB_VERBOSE_UNSUBSCRIBE = 115 

269 TOPICS_COUNT = 116 

270 NORM_MODE = 117 

271 NORM_UNICAST_NACK = 118 

272 NORM_BUFFER_SIZE = 119 

273 NORM_SEGMENT_SIZE = 120 

274 NORM_BLOCK_SIZE = 121 

275 NORM_NUM_PARITY = 122 

276 NORM_NUM_AUTOPARITY = 123 

277 NORM_PUSH = 124 

278 

279 

280class MessageOption(IntEnum): 

281 """Options on zmq.Frame objects 

282 

283 .. versionadded:: 23 

284 """ 

285 

286 MORE = 1 

287 SHARED = 3 

288 # Deprecated message options 

289 SRCFD = 2 

290 

291 

292class Flag(IntFlag): 

293 """Send/recv flags 

294 

295 .. versionadded:: 23 

296 """ 

297 

298 DONTWAIT = 1 

299 SNDMORE = 2 

300 NOBLOCK = DONTWAIT 

301 

302 

303class RouterNotify(IntEnum): 

304 """Values for zmq.ROUTER_NOTIFY socket option 

305 

306 .. versionadded:: 26 

307 .. versionadded:: libzmq-4.3.0 (draft) 

308 """ 

309 

310 @staticmethod 

311 def _global_name(name): 

312 return f"NOTIFY_{name}" 

313 

314 CONNECT = 1 

315 DISCONNECT = 2 

316 

317 

318class NormMode(IntEnum): 

319 """Values for zmq.NORM_MODE socket option 

320 

321 .. versionadded:: 26 

322 .. versionadded:: libzmq-4.3.5 (draft) 

323 """ 

324 

325 @staticmethod 

326 def _global_name(name): 

327 return f"NORM_{name}" 

328 

329 FIXED = 0 

330 CC = 1 

331 CCL = 2 

332 CCE = 3 

333 CCE_ECNONLY = 4 

334 

335 

336class SecurityMechanism(IntEnum): 

337 """Security mechanisms (as returned by ``socket.get(zmq.MECHANISM)``) 

338 

339 .. versionadded:: 23 

340 """ 

341 

342 NULL = 0 

343 PLAIN = 1 

344 CURVE = 2 

345 GSSAPI = 3 

346 

347 

348class ReconnectStop(IntEnum): 

349 """Select behavior for socket.reconnect_stop 

350 

351 .. versionadded:: 25 

352 """ 

353 

354 @staticmethod 

355 def _global_name(name): 

356 return f"RECONNECT_STOP_{name}" 

357 

358 CONN_REFUSED = 0x1 

359 HANDSHAKE_FAILED = 0x2 

360 AFTER_DISCONNECT = 0x4 

361 

362 

363class Event(IntFlag): 

364 """Socket monitoring events 

365 

366 .. versionadded:: 23 

367 """ 

368 

369 @staticmethod 

370 def _global_name(name): 

371 if name.startswith("PROTOCOL_ERROR_"): 

372 return name 

373 else: 

374 # add EVENT_ prefix 

375 return "EVENT_" + name 

376 

377 PROTOCOL_ERROR_WS_UNSPECIFIED = 0x30000000 

378 PROTOCOL_ERROR_ZMTP_UNSPECIFIED = 0x10000000 

379 PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND = 0x10000001 

380 PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE = 0x10000002 

381 PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE = 0x10000003 

382 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED = 0x10000011 

383 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE = 0x10000012 

384 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO = 0x10000013 

385 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE = 0x10000014 

386 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR = 0x10000015 

387 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY = 0x10000016 

388 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME = 0x10000017 

389 PROTOCOL_ERROR_ZMTP_INVALID_METADATA = 0x10000018 

390 

391 PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC = 0x11000001 

392 PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH = 0x11000002 

393 PROTOCOL_ERROR_ZAP_UNSPECIFIED = 0x20000000 

394 PROTOCOL_ERROR_ZAP_MALFORMED_REPLY = 0x20000001 

395 PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID = 0x20000002 

396 PROTOCOL_ERROR_ZAP_BAD_VERSION = 0x20000003 

397 PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE = 0x20000004 

398 PROTOCOL_ERROR_ZAP_INVALID_METADATA = 0x20000005 

399 

400 # define event types _after_ overlapping protocol error masks 

401 CONNECTED = 0x0001 

402 CONNECT_DELAYED = 0x0002 

403 CONNECT_RETRIED = 0x0004 

404 LISTENING = 0x0008 

405 BIND_FAILED = 0x0010 

406 ACCEPTED = 0x0020 

407 ACCEPT_FAILED = 0x0040 

408 CLOSED = 0x0080 

409 CLOSE_FAILED = 0x0100 

410 DISCONNECTED = 0x0200 

411 MONITOR_STOPPED = 0x0400 

412 

413 HANDSHAKE_FAILED_NO_DETAIL = 0x0800 

414 HANDSHAKE_SUCCEEDED = 0x1000 

415 HANDSHAKE_FAILED_PROTOCOL = 0x2000 

416 HANDSHAKE_FAILED_AUTH = 0x4000 

417 

418 ALL_V1 = 0xFFFF 

419 ALL = ALL_V1 

420 

421 # DRAFT Socket monitoring events 

422 PIPES_STATS = 0x10000 

423 ALL_V2 = ALL_V1 | PIPES_STATS 

424 

425 

426class PollEvent(IntFlag): 

427 """Which events to poll for in poll methods 

428 

429 .. versionadded: 23 

430 """ 

431 

432 POLLIN = 1 

433 POLLOUT = 2 

434 POLLERR = 4 

435 POLLPRI = 8 

436 

437 

438class DeviceType(IntEnum): 

439 """Device type constants for zmq.device 

440 

441 .. versionadded: 23 

442 """ 

443 

444 STREAMER = 1 

445 FORWARDER = 2 

446 QUEUE = 3 

447 

448 

449# AUTOGENERATED_BELOW_HERE 

450 

451 

452IO_THREADS: ContextOption = ContextOption.IO_THREADS 

453MAX_SOCKETS: ContextOption = ContextOption.MAX_SOCKETS 

454SOCKET_LIMIT: ContextOption = ContextOption.SOCKET_LIMIT 

455THREAD_PRIORITY: ContextOption = ContextOption.THREAD_PRIORITY 

456THREAD_SCHED_POLICY: ContextOption = ContextOption.THREAD_SCHED_POLICY 

457MAX_MSGSZ: ContextOption = ContextOption.MAX_MSGSZ 

458MSG_T_SIZE: ContextOption = ContextOption.MSG_T_SIZE 

459THREAD_AFFINITY_CPU_ADD: ContextOption = ContextOption.THREAD_AFFINITY_CPU_ADD 

460THREAD_AFFINITY_CPU_REMOVE: ContextOption = ContextOption.THREAD_AFFINITY_CPU_REMOVE 

461THREAD_NAME_PREFIX: ContextOption = ContextOption.THREAD_NAME_PREFIX 

462STREAMER: DeviceType = DeviceType.STREAMER 

463FORWARDER: DeviceType = DeviceType.FORWARDER 

464QUEUE: DeviceType = DeviceType.QUEUE 

465EAGAIN: Errno = Errno.EAGAIN 

466EFAULT: Errno = Errno.EFAULT 

467EINVAL: Errno = Errno.EINVAL 

468ENOTSUP: Errno = Errno.ENOTSUP 

469EPROTONOSUPPORT: Errno = Errno.EPROTONOSUPPORT 

470ENOBUFS: Errno = Errno.ENOBUFS 

471ENETDOWN: Errno = Errno.ENETDOWN 

472EADDRINUSE: Errno = Errno.EADDRINUSE 

473EADDRNOTAVAIL: Errno = Errno.EADDRNOTAVAIL 

474ECONNREFUSED: Errno = Errno.ECONNREFUSED 

475EINPROGRESS: Errno = Errno.EINPROGRESS 

476ENOTSOCK: Errno = Errno.ENOTSOCK 

477EMSGSIZE: Errno = Errno.EMSGSIZE 

478EAFNOSUPPORT: Errno = Errno.EAFNOSUPPORT 

479ENETUNREACH: Errno = Errno.ENETUNREACH 

480ECONNABORTED: Errno = Errno.ECONNABORTED 

481ECONNRESET: Errno = Errno.ECONNRESET 

482ENOTCONN: Errno = Errno.ENOTCONN 

483ETIMEDOUT: Errno = Errno.ETIMEDOUT 

484EHOSTUNREACH: Errno = Errno.EHOSTUNREACH 

485ENETRESET: Errno = Errno.ENETRESET 

486EFSM: Errno = Errno.EFSM 

487ENOCOMPATPROTO: Errno = Errno.ENOCOMPATPROTO 

488ETERM: Errno = Errno.ETERM 

489EMTHREAD: Errno = Errno.EMTHREAD 

490PROTOCOL_ERROR_WS_UNSPECIFIED: Event = Event.PROTOCOL_ERROR_WS_UNSPECIFIED 

491PROTOCOL_ERROR_ZMTP_UNSPECIFIED: Event = Event.PROTOCOL_ERROR_ZMTP_UNSPECIFIED 

492PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: Event = ( 

493 Event.PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND 

494) 

495PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: Event = Event.PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE 

496PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: Event = Event.PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE 

497PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: Event = ( 

498 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED 

499) 

500PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: Event = ( 

501 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE 

502) 

503PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: Event = ( 

504 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO 

505) 

506PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: Event = ( 

507 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE 

508) 

509PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: Event = ( 

510 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR 

511) 

512PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: Event = ( 

513 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY 

514) 

515PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: Event = ( 

516 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME 

517) 

518PROTOCOL_ERROR_ZMTP_INVALID_METADATA: Event = Event.PROTOCOL_ERROR_ZMTP_INVALID_METADATA 

519PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: Event = Event.PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC 

520PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: Event = ( 

521 Event.PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH 

522) 

523PROTOCOL_ERROR_ZAP_UNSPECIFIED: Event = Event.PROTOCOL_ERROR_ZAP_UNSPECIFIED 

524PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: Event = Event.PROTOCOL_ERROR_ZAP_MALFORMED_REPLY 

525PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: Event = Event.PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID 

526PROTOCOL_ERROR_ZAP_BAD_VERSION: Event = Event.PROTOCOL_ERROR_ZAP_BAD_VERSION 

527PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: Event = ( 

528 Event.PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE 

529) 

530PROTOCOL_ERROR_ZAP_INVALID_METADATA: Event = Event.PROTOCOL_ERROR_ZAP_INVALID_METADATA 

531EVENT_CONNECTED: Event = Event.CONNECTED 

532EVENT_CONNECT_DELAYED: Event = Event.CONNECT_DELAYED 

533EVENT_CONNECT_RETRIED: Event = Event.CONNECT_RETRIED 

534EVENT_LISTENING: Event = Event.LISTENING 

535EVENT_BIND_FAILED: Event = Event.BIND_FAILED 

536EVENT_ACCEPTED: Event = Event.ACCEPTED 

537EVENT_ACCEPT_FAILED: Event = Event.ACCEPT_FAILED 

538EVENT_CLOSED: Event = Event.CLOSED 

539EVENT_CLOSE_FAILED: Event = Event.CLOSE_FAILED 

540EVENT_DISCONNECTED: Event = Event.DISCONNECTED 

541EVENT_MONITOR_STOPPED: Event = Event.MONITOR_STOPPED 

542EVENT_HANDSHAKE_FAILED_NO_DETAIL: Event = Event.HANDSHAKE_FAILED_NO_DETAIL 

543EVENT_HANDSHAKE_SUCCEEDED: Event = Event.HANDSHAKE_SUCCEEDED 

544EVENT_HANDSHAKE_FAILED_PROTOCOL: Event = Event.HANDSHAKE_FAILED_PROTOCOL 

545EVENT_HANDSHAKE_FAILED_AUTH: Event = Event.HANDSHAKE_FAILED_AUTH 

546EVENT_ALL_V1: Event = Event.ALL_V1 

547EVENT_ALL: Event = Event.ALL 

548EVENT_PIPES_STATS: Event = Event.PIPES_STATS 

549EVENT_ALL_V2: Event = Event.ALL_V2 

550DONTWAIT: Flag = Flag.DONTWAIT 

551SNDMORE: Flag = Flag.SNDMORE 

552NOBLOCK: Flag = Flag.NOBLOCK 

553MORE: MessageOption = MessageOption.MORE 

554SHARED: MessageOption = MessageOption.SHARED 

555SRCFD: MessageOption = MessageOption.SRCFD 

556NORM_FIXED: NormMode = NormMode.FIXED 

557NORM_CC: NormMode = NormMode.CC 

558NORM_CCL: NormMode = NormMode.CCL 

559NORM_CCE: NormMode = NormMode.CCE 

560NORM_CCE_ECNONLY: NormMode = NormMode.CCE_ECNONLY 

561POLLIN: PollEvent = PollEvent.POLLIN 

562POLLOUT: PollEvent = PollEvent.POLLOUT 

563POLLERR: PollEvent = PollEvent.POLLERR 

564POLLPRI: PollEvent = PollEvent.POLLPRI 

565RECONNECT_STOP_CONN_REFUSED: ReconnectStop = ReconnectStop.CONN_REFUSED 

566RECONNECT_STOP_HANDSHAKE_FAILED: ReconnectStop = ReconnectStop.HANDSHAKE_FAILED 

567RECONNECT_STOP_AFTER_DISCONNECT: ReconnectStop = ReconnectStop.AFTER_DISCONNECT 

568NOTIFY_CONNECT: RouterNotify = RouterNotify.CONNECT 

569NOTIFY_DISCONNECT: RouterNotify = RouterNotify.DISCONNECT 

570NULL: SecurityMechanism = SecurityMechanism.NULL 

571PLAIN: SecurityMechanism = SecurityMechanism.PLAIN 

572CURVE: SecurityMechanism = SecurityMechanism.CURVE 

573GSSAPI: SecurityMechanism = SecurityMechanism.GSSAPI 

574HWM: SocketOption = SocketOption.HWM 

575AFFINITY: SocketOption = SocketOption.AFFINITY 

576ROUTING_ID: SocketOption = SocketOption.ROUTING_ID 

577SUBSCRIBE: SocketOption = SocketOption.SUBSCRIBE 

578UNSUBSCRIBE: SocketOption = SocketOption.UNSUBSCRIBE 

579RATE: SocketOption = SocketOption.RATE 

580RECOVERY_IVL: SocketOption = SocketOption.RECOVERY_IVL 

581SNDBUF: SocketOption = SocketOption.SNDBUF 

582RCVBUF: SocketOption = SocketOption.RCVBUF 

583RCVMORE: SocketOption = SocketOption.RCVMORE 

584FD: SocketOption = SocketOption.FD 

585EVENTS: SocketOption = SocketOption.EVENTS 

586TYPE: SocketOption = SocketOption.TYPE 

587LINGER: SocketOption = SocketOption.LINGER 

588RECONNECT_IVL: SocketOption = SocketOption.RECONNECT_IVL 

589BACKLOG: SocketOption = SocketOption.BACKLOG 

590RECONNECT_IVL_MAX: SocketOption = SocketOption.RECONNECT_IVL_MAX 

591MAXMSGSIZE: SocketOption = SocketOption.MAXMSGSIZE 

592SNDHWM: SocketOption = SocketOption.SNDHWM 

593RCVHWM: SocketOption = SocketOption.RCVHWM 

594MULTICAST_HOPS: SocketOption = SocketOption.MULTICAST_HOPS 

595RCVTIMEO: SocketOption = SocketOption.RCVTIMEO 

596SNDTIMEO: SocketOption = SocketOption.SNDTIMEO 

597LAST_ENDPOINT: SocketOption = SocketOption.LAST_ENDPOINT 

598ROUTER_MANDATORY: SocketOption = SocketOption.ROUTER_MANDATORY 

599TCP_KEEPALIVE: SocketOption = SocketOption.TCP_KEEPALIVE 

600TCP_KEEPALIVE_CNT: SocketOption = SocketOption.TCP_KEEPALIVE_CNT 

601TCP_KEEPALIVE_IDLE: SocketOption = SocketOption.TCP_KEEPALIVE_IDLE 

602TCP_KEEPALIVE_INTVL: SocketOption = SocketOption.TCP_KEEPALIVE_INTVL 

603IMMEDIATE: SocketOption = SocketOption.IMMEDIATE 

604XPUB_VERBOSE: SocketOption = SocketOption.XPUB_VERBOSE 

605ROUTER_RAW: SocketOption = SocketOption.ROUTER_RAW 

606IPV6: SocketOption = SocketOption.IPV6 

607MECHANISM: SocketOption = SocketOption.MECHANISM 

608PLAIN_SERVER: SocketOption = SocketOption.PLAIN_SERVER 

609PLAIN_USERNAME: SocketOption = SocketOption.PLAIN_USERNAME 

610PLAIN_PASSWORD: SocketOption = SocketOption.PLAIN_PASSWORD 

611CURVE_SERVER: SocketOption = SocketOption.CURVE_SERVER 

612CURVE_PUBLICKEY: SocketOption = SocketOption.CURVE_PUBLICKEY 

613CURVE_SECRETKEY: SocketOption = SocketOption.CURVE_SECRETKEY 

614CURVE_SERVERKEY: SocketOption = SocketOption.CURVE_SERVERKEY 

615PROBE_ROUTER: SocketOption = SocketOption.PROBE_ROUTER 

616REQ_CORRELATE: SocketOption = SocketOption.REQ_CORRELATE 

617REQ_RELAXED: SocketOption = SocketOption.REQ_RELAXED 

618CONFLATE: SocketOption = SocketOption.CONFLATE 

619ZAP_DOMAIN: SocketOption = SocketOption.ZAP_DOMAIN 

620ROUTER_HANDOVER: SocketOption = SocketOption.ROUTER_HANDOVER 

621TOS: SocketOption = SocketOption.TOS 

622CONNECT_ROUTING_ID: SocketOption = SocketOption.CONNECT_ROUTING_ID 

623GSSAPI_SERVER: SocketOption = SocketOption.GSSAPI_SERVER 

624GSSAPI_PRINCIPAL: SocketOption = SocketOption.GSSAPI_PRINCIPAL 

625GSSAPI_SERVICE_PRINCIPAL: SocketOption = SocketOption.GSSAPI_SERVICE_PRINCIPAL 

626GSSAPI_PLAINTEXT: SocketOption = SocketOption.GSSAPI_PLAINTEXT 

627HANDSHAKE_IVL: SocketOption = SocketOption.HANDSHAKE_IVL 

628SOCKS_PROXY: SocketOption = SocketOption.SOCKS_PROXY 

629XPUB_NODROP: SocketOption = SocketOption.XPUB_NODROP 

630BLOCKY: SocketOption = SocketOption.BLOCKY 

631XPUB_MANUAL: SocketOption = SocketOption.XPUB_MANUAL 

632XPUB_WELCOME_MSG: SocketOption = SocketOption.XPUB_WELCOME_MSG 

633STREAM_NOTIFY: SocketOption = SocketOption.STREAM_NOTIFY 

634INVERT_MATCHING: SocketOption = SocketOption.INVERT_MATCHING 

635HEARTBEAT_IVL: SocketOption = SocketOption.HEARTBEAT_IVL 

636HEARTBEAT_TTL: SocketOption = SocketOption.HEARTBEAT_TTL 

637HEARTBEAT_TIMEOUT: SocketOption = SocketOption.HEARTBEAT_TIMEOUT 

638XPUB_VERBOSER: SocketOption = SocketOption.XPUB_VERBOSER 

639CONNECT_TIMEOUT: SocketOption = SocketOption.CONNECT_TIMEOUT 

640TCP_MAXRT: SocketOption = SocketOption.TCP_MAXRT 

641THREAD_SAFE: SocketOption = SocketOption.THREAD_SAFE 

642MULTICAST_MAXTPDU: SocketOption = SocketOption.MULTICAST_MAXTPDU 

643VMCI_BUFFER_SIZE: SocketOption = SocketOption.VMCI_BUFFER_SIZE 

644VMCI_BUFFER_MIN_SIZE: SocketOption = SocketOption.VMCI_BUFFER_MIN_SIZE 

645VMCI_BUFFER_MAX_SIZE: SocketOption = SocketOption.VMCI_BUFFER_MAX_SIZE 

646VMCI_CONNECT_TIMEOUT: SocketOption = SocketOption.VMCI_CONNECT_TIMEOUT 

647USE_FD: SocketOption = SocketOption.USE_FD 

648GSSAPI_PRINCIPAL_NAMETYPE: SocketOption = SocketOption.GSSAPI_PRINCIPAL_NAMETYPE 

649GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: SocketOption = ( 

650 SocketOption.GSSAPI_SERVICE_PRINCIPAL_NAMETYPE 

651) 

652BINDTODEVICE: SocketOption = SocketOption.BINDTODEVICE 

653IDENTITY: SocketOption = SocketOption.IDENTITY 

654CONNECT_RID: SocketOption = SocketOption.CONNECT_RID 

655TCP_ACCEPT_FILTER: SocketOption = SocketOption.TCP_ACCEPT_FILTER 

656IPC_FILTER_PID: SocketOption = SocketOption.IPC_FILTER_PID 

657IPC_FILTER_UID: SocketOption = SocketOption.IPC_FILTER_UID 

658IPC_FILTER_GID: SocketOption = SocketOption.IPC_FILTER_GID 

659IPV4ONLY: SocketOption = SocketOption.IPV4ONLY 

660DELAY_ATTACH_ON_CONNECT: SocketOption = SocketOption.DELAY_ATTACH_ON_CONNECT 

661FAIL_UNROUTABLE: SocketOption = SocketOption.FAIL_UNROUTABLE 

662ROUTER_BEHAVIOR: SocketOption = SocketOption.ROUTER_BEHAVIOR 

663ZAP_ENFORCE_DOMAIN: SocketOption = SocketOption.ZAP_ENFORCE_DOMAIN 

664LOOPBACK_FASTPATH: SocketOption = SocketOption.LOOPBACK_FASTPATH 

665METADATA: SocketOption = SocketOption.METADATA 

666MULTICAST_LOOP: SocketOption = SocketOption.MULTICAST_LOOP 

667ROUTER_NOTIFY: SocketOption = SocketOption.ROUTER_NOTIFY 

668XPUB_MANUAL_LAST_VALUE: SocketOption = SocketOption.XPUB_MANUAL_LAST_VALUE 

669SOCKS_USERNAME: SocketOption = SocketOption.SOCKS_USERNAME 

670SOCKS_PASSWORD: SocketOption = SocketOption.SOCKS_PASSWORD 

671IN_BATCH_SIZE: SocketOption = SocketOption.IN_BATCH_SIZE 

672OUT_BATCH_SIZE: SocketOption = SocketOption.OUT_BATCH_SIZE 

673WSS_KEY_PEM: SocketOption = SocketOption.WSS_KEY_PEM 

674WSS_CERT_PEM: SocketOption = SocketOption.WSS_CERT_PEM 

675WSS_TRUST_PEM: SocketOption = SocketOption.WSS_TRUST_PEM 

676WSS_HOSTNAME: SocketOption = SocketOption.WSS_HOSTNAME 

677WSS_TRUST_SYSTEM: SocketOption = SocketOption.WSS_TRUST_SYSTEM 

678ONLY_FIRST_SUBSCRIBE: SocketOption = SocketOption.ONLY_FIRST_SUBSCRIBE 

679RECONNECT_STOP: SocketOption = SocketOption.RECONNECT_STOP 

680HELLO_MSG: SocketOption = SocketOption.HELLO_MSG 

681DISCONNECT_MSG: SocketOption = SocketOption.DISCONNECT_MSG 

682PRIORITY: SocketOption = SocketOption.PRIORITY 

683BUSY_POLL: SocketOption = SocketOption.BUSY_POLL 

684HICCUP_MSG: SocketOption = SocketOption.HICCUP_MSG 

685XSUB_VERBOSE_UNSUBSCRIBE: SocketOption = SocketOption.XSUB_VERBOSE_UNSUBSCRIBE 

686TOPICS_COUNT: SocketOption = SocketOption.TOPICS_COUNT 

687NORM_MODE: SocketOption = SocketOption.NORM_MODE 

688NORM_UNICAST_NACK: SocketOption = SocketOption.NORM_UNICAST_NACK 

689NORM_BUFFER_SIZE: SocketOption = SocketOption.NORM_BUFFER_SIZE 

690NORM_SEGMENT_SIZE: SocketOption = SocketOption.NORM_SEGMENT_SIZE 

691NORM_BLOCK_SIZE: SocketOption = SocketOption.NORM_BLOCK_SIZE 

692NORM_NUM_PARITY: SocketOption = SocketOption.NORM_NUM_PARITY 

693NORM_NUM_AUTOPARITY: SocketOption = SocketOption.NORM_NUM_AUTOPARITY 

694NORM_PUSH: SocketOption = SocketOption.NORM_PUSH 

695PAIR: SocketType = SocketType.PAIR 

696PUB: SocketType = SocketType.PUB 

697SUB: SocketType = SocketType.SUB 

698REQ: SocketType = SocketType.REQ 

699REP: SocketType = SocketType.REP 

700DEALER: SocketType = SocketType.DEALER 

701ROUTER: SocketType = SocketType.ROUTER 

702PULL: SocketType = SocketType.PULL 

703PUSH: SocketType = SocketType.PUSH 

704XPUB: SocketType = SocketType.XPUB 

705XSUB: SocketType = SocketType.XSUB 

706STREAM: SocketType = SocketType.STREAM 

707XREQ: SocketType = SocketType.XREQ 

708XREP: SocketType = SocketType.XREP 

709SERVER: SocketType = SocketType.SERVER 

710CLIENT: SocketType = SocketType.CLIENT 

711RADIO: SocketType = SocketType.RADIO 

712DISH: SocketType = SocketType.DISH 

713GATHER: SocketType = SocketType.GATHER 

714SCATTER: SocketType = SocketType.SCATTER 

715DGRAM: SocketType = SocketType.DGRAM 

716PEER: SocketType = SocketType.PEER 

717CHANNEL: SocketType = SocketType.CHANNEL 

718 

719__all__: list[str] = [ 

720 "ContextOption", 

721 "IO_THREADS", 

722 "MAX_SOCKETS", 

723 "SOCKET_LIMIT", 

724 "THREAD_PRIORITY", 

725 "THREAD_SCHED_POLICY", 

726 "MAX_MSGSZ", 

727 "MSG_T_SIZE", 

728 "THREAD_AFFINITY_CPU_ADD", 

729 "THREAD_AFFINITY_CPU_REMOVE", 

730 "THREAD_NAME_PREFIX", 

731 "DeviceType", 

732 "STREAMER", 

733 "FORWARDER", 

734 "QUEUE", 

735 "Enum", 

736 "Errno", 

737 "EAGAIN", 

738 "EFAULT", 

739 "EINVAL", 

740 "ENOTSUP", 

741 "EPROTONOSUPPORT", 

742 "ENOBUFS", 

743 "ENETDOWN", 

744 "EADDRINUSE", 

745 "EADDRNOTAVAIL", 

746 "ECONNREFUSED", 

747 "EINPROGRESS", 

748 "ENOTSOCK", 

749 "EMSGSIZE", 

750 "EAFNOSUPPORT", 

751 "ENETUNREACH", 

752 "ECONNABORTED", 

753 "ECONNRESET", 

754 "ENOTCONN", 

755 "ETIMEDOUT", 

756 "EHOSTUNREACH", 

757 "ENETRESET", 

758 "EFSM", 

759 "ENOCOMPATPROTO", 

760 "ETERM", 

761 "EMTHREAD", 

762 "Event", 

763 "PROTOCOL_ERROR_WS_UNSPECIFIED", 

764 "PROTOCOL_ERROR_ZMTP_UNSPECIFIED", 

765 "PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND", 

766 "PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE", 

767 "PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE", 

768 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED", 

769 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE", 

770 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO", 

771 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE", 

772 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR", 

773 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY", 

774 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME", 

775 "PROTOCOL_ERROR_ZMTP_INVALID_METADATA", 

776 "PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC", 

777 "PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH", 

778 "PROTOCOL_ERROR_ZAP_UNSPECIFIED", 

779 "PROTOCOL_ERROR_ZAP_MALFORMED_REPLY", 

780 "PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID", 

781 "PROTOCOL_ERROR_ZAP_BAD_VERSION", 

782 "PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE", 

783 "PROTOCOL_ERROR_ZAP_INVALID_METADATA", 

784 "EVENT_CONNECTED", 

785 "EVENT_CONNECT_DELAYED", 

786 "EVENT_CONNECT_RETRIED", 

787 "EVENT_LISTENING", 

788 "EVENT_BIND_FAILED", 

789 "EVENT_ACCEPTED", 

790 "EVENT_ACCEPT_FAILED", 

791 "EVENT_CLOSED", 

792 "EVENT_CLOSE_FAILED", 

793 "EVENT_DISCONNECTED", 

794 "EVENT_MONITOR_STOPPED", 

795 "EVENT_HANDSHAKE_FAILED_NO_DETAIL", 

796 "EVENT_HANDSHAKE_SUCCEEDED", 

797 "EVENT_HANDSHAKE_FAILED_PROTOCOL", 

798 "EVENT_HANDSHAKE_FAILED_AUTH", 

799 "EVENT_ALL_V1", 

800 "EVENT_ALL", 

801 "EVENT_PIPES_STATS", 

802 "EVENT_ALL_V2", 

803 "Flag", 

804 "DONTWAIT", 

805 "SNDMORE", 

806 "NOBLOCK", 

807 "IntEnum", 

808 "IntFlag", 

809 "MessageOption", 

810 "MORE", 

811 "SHARED", 

812 "SRCFD", 

813 "NormMode", 

814 "NORM_FIXED", 

815 "NORM_CC", 

816 "NORM_CCL", 

817 "NORM_CCE", 

818 "NORM_CCE_ECNONLY", 

819 "PollEvent", 

820 "POLLIN", 

821 "POLLOUT", 

822 "POLLERR", 

823 "POLLPRI", 

824 "ReconnectStop", 

825 "RECONNECT_STOP_CONN_REFUSED", 

826 "RECONNECT_STOP_HANDSHAKE_FAILED", 

827 "RECONNECT_STOP_AFTER_DISCONNECT", 

828 "RouterNotify", 

829 "NOTIFY_CONNECT", 

830 "NOTIFY_DISCONNECT", 

831 "SecurityMechanism", 

832 "NULL", 

833 "PLAIN", 

834 "CURVE", 

835 "GSSAPI", 

836 "SocketOption", 

837 "HWM", 

838 "AFFINITY", 

839 "ROUTING_ID", 

840 "SUBSCRIBE", 

841 "UNSUBSCRIBE", 

842 "RATE", 

843 "RECOVERY_IVL", 

844 "SNDBUF", 

845 "RCVBUF", 

846 "RCVMORE", 

847 "FD", 

848 "EVENTS", 

849 "TYPE", 

850 "LINGER", 

851 "RECONNECT_IVL", 

852 "BACKLOG", 

853 "RECONNECT_IVL_MAX", 

854 "MAXMSGSIZE", 

855 "SNDHWM", 

856 "RCVHWM", 

857 "MULTICAST_HOPS", 

858 "RCVTIMEO", 

859 "SNDTIMEO", 

860 "LAST_ENDPOINT", 

861 "ROUTER_MANDATORY", 

862 "TCP_KEEPALIVE", 

863 "TCP_KEEPALIVE_CNT", 

864 "TCP_KEEPALIVE_IDLE", 

865 "TCP_KEEPALIVE_INTVL", 

866 "IMMEDIATE", 

867 "XPUB_VERBOSE", 

868 "ROUTER_RAW", 

869 "IPV6", 

870 "MECHANISM", 

871 "PLAIN_SERVER", 

872 "PLAIN_USERNAME", 

873 "PLAIN_PASSWORD", 

874 "CURVE_SERVER", 

875 "CURVE_PUBLICKEY", 

876 "CURVE_SECRETKEY", 

877 "CURVE_SERVERKEY", 

878 "PROBE_ROUTER", 

879 "REQ_CORRELATE", 

880 "REQ_RELAXED", 

881 "CONFLATE", 

882 "ZAP_DOMAIN", 

883 "ROUTER_HANDOVER", 

884 "TOS", 

885 "CONNECT_ROUTING_ID", 

886 "GSSAPI_SERVER", 

887 "GSSAPI_PRINCIPAL", 

888 "GSSAPI_SERVICE_PRINCIPAL", 

889 "GSSAPI_PLAINTEXT", 

890 "HANDSHAKE_IVL", 

891 "SOCKS_PROXY", 

892 "XPUB_NODROP", 

893 "BLOCKY", 

894 "XPUB_MANUAL", 

895 "XPUB_WELCOME_MSG", 

896 "STREAM_NOTIFY", 

897 "INVERT_MATCHING", 

898 "HEARTBEAT_IVL", 

899 "HEARTBEAT_TTL", 

900 "HEARTBEAT_TIMEOUT", 

901 "XPUB_VERBOSER",