Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.8/site-packages/zmq/constants.py: 96%
505 statements
« prev ^ index » next coverage.py v7.2.7, created at 2023-07-01 06:54 +0000
1"""zmq constants as enums"""
2import errno
3import sys
4from enum import Enum, IntEnum, IntFlag
5from typing import List
7_HAUSNUMERO = 156384712
10class Errno(IntEnum):
11 """libzmq error codes
13 .. versionadded:: 23
14 """
16 EAGAIN = errno.EAGAIN
17 EFAULT = errno.EFAULT
18 EINVAL = errno.EINVAL
20 if sys.platform.startswith("win"):
21 # Windows: libzmq uses errno.h
22 # while Python errno prefers WSA* variants
23 # many of these were introduced to errno.h in vs2010
24 # ref: https://github.com/python/cpython/blob/3.9/Modules/errnomodule.c#L10-L37
25 # source: https://docs.microsoft.com/en-us/cpp/c-runtime-library/errno-constants
26 ENOTSUP = 129
27 EPROTONOSUPPORT = 135
28 ENOBUFS = 119
29 ENETDOWN = 116
30 EADDRINUSE = 100
31 EADDRNOTAVAIL = 101
32 ECONNREFUSED = 107
33 EINPROGRESS = 112
34 ENOTSOCK = 128
35 EMSGSIZE = 115
36 EAFNOSUPPORT = 102
37 ENETUNREACH = 118
38 ECONNABORTED = 106
39 ECONNRESET = 108
40 ENOTCONN = 126
41 ETIMEDOUT = 138
42 EHOSTUNREACH = 110
43 ENETRESET = 117
45 else:
46 ENOTSUP = getattr(errno, "ENOTSUP", _HAUSNUMERO + 1)
47 EPROTONOSUPPORT = getattr(errno, "EPROTONOSUPPORT", _HAUSNUMERO + 2)
48 ENOBUFS = getattr(errno, "ENOBUFS", _HAUSNUMERO + 3)
49 ENETDOWN = getattr(errno, "ENETDOWN", _HAUSNUMERO + 4)
50 EADDRINUSE = getattr(errno, "EADDRINUSE", _HAUSNUMERO + 5)
51 EADDRNOTAVAIL = getattr(errno, "EADDRNOTAVAIL", _HAUSNUMERO + 6)
52 ECONNREFUSED = getattr(errno, "ECONNREFUSED", _HAUSNUMERO + 7)
53 EINPROGRESS = getattr(errno, "EINPROGRESS", _HAUSNUMERO + 8)
54 ENOTSOCK = getattr(errno, "ENOTSOCK", _HAUSNUMERO + 9)
55 EMSGSIZE = getattr(errno, "EMSGSIZE", _HAUSNUMERO + 10)
56 EAFNOSUPPORT = getattr(errno, "EAFNOSUPPORT", _HAUSNUMERO + 11)
57 ENETUNREACH = getattr(errno, "ENETUNREACH", _HAUSNUMERO + 12)
58 ECONNABORTED = getattr(errno, "ECONNABORTED", _HAUSNUMERO + 13)
59 ECONNRESET = getattr(errno, "ECONNRESET", _HAUSNUMERO + 14)
60 ENOTCONN = getattr(errno, "ENOTCONN", _HAUSNUMERO + 15)
61 ETIMEDOUT = getattr(errno, "ETIMEDOUT", _HAUSNUMERO + 16)
62 EHOSTUNREACH = getattr(errno, "EHOSTUNREACH", _HAUSNUMERO + 17)
63 ENETRESET = getattr(errno, "ENETRESET", _HAUSNUMERO + 18)
65 # Native 0MQ error codes
66 EFSM = _HAUSNUMERO + 51
67 ENOCOMPATPROTO = _HAUSNUMERO + 52
68 ETERM = _HAUSNUMERO + 53
69 EMTHREAD = _HAUSNUMERO + 54
72class ContextOption(IntEnum):
73 """Options for Context.get/set
75 .. versionadded:: 23
76 """
78 IO_THREADS = 1
79 MAX_SOCKETS = 2
80 SOCKET_LIMIT = 3
81 THREAD_PRIORITY = 3
82 THREAD_SCHED_POLICY = 4
83 MAX_MSGSZ = 5
84 MSG_T_SIZE = 6
85 THREAD_AFFINITY_CPU_ADD = 7
86 THREAD_AFFINITY_CPU_REMOVE = 8
87 THREAD_NAME_PREFIX = 9
90class SocketType(IntEnum):
91 """zmq socket types
93 .. versionadded:: 23
94 """
96 PAIR = 0
97 PUB = 1
98 SUB = 2
99 REQ = 3
100 REP = 4
101 DEALER = 5
102 ROUTER = 6
103 PULL = 7
104 PUSH = 8
105 XPUB = 9
106 XSUB = 10
107 STREAM = 11
109 # deprecated aliases
110 XREQ = DEALER
111 XREP = ROUTER
113 # DRAFT socket types
114 SERVER = 12
115 CLIENT = 13
116 RADIO = 14
117 DISH = 15
118 GATHER = 16
119 SCATTER = 17
120 DGRAM = 18
121 PEER = 19
122 CHANNEL = 20
125class _OptType(Enum):
126 int = 'int'
127 int64 = 'int64'
128 bytes = 'bytes'
129 fd = 'fd'
132class SocketOption(IntEnum):
133 """Options for Socket.get/set
135 .. versionadded:: 23
136 """
138 _opt_type: _OptType
140 def __new__(cls, value: int, opt_type: _OptType = _OptType.int):
141 """Attach option type as `._opt_type`"""
142 obj = int.__new__(cls, value)
143 obj._value_ = value
144 obj._opt_type = opt_type
145 return obj
147 HWM = 1
148 AFFINITY = 4, _OptType.int64
149 ROUTING_ID = 5, _OptType.bytes
150 SUBSCRIBE = 6, _OptType.bytes
151 UNSUBSCRIBE = 7, _OptType.bytes
152 RATE = 8
153 RECOVERY_IVL = 9
154 SNDBUF = 11
155 RCVBUF = 12
156 RCVMORE = 13
157 FD = 14, _OptType.fd
158 EVENTS = 15
159 TYPE = 16
160 LINGER = 17
161 RECONNECT_IVL = 18
162 BACKLOG = 19
163 RECONNECT_IVL_MAX = 21
164 MAXMSGSIZE = 22, _OptType.int64
165 SNDHWM = 23
166 RCVHWM = 24
167 MULTICAST_HOPS = 25
168 RCVTIMEO = 27
169 SNDTIMEO = 28
170 LAST_ENDPOINT = 32, _OptType.bytes
171 ROUTER_MANDATORY = 33
172 TCP_KEEPALIVE = 34
173 TCP_KEEPALIVE_CNT = 35
174 TCP_KEEPALIVE_IDLE = 36
175 TCP_KEEPALIVE_INTVL = 37
176 IMMEDIATE = 39
177 XPUB_VERBOSE = 40
178 ROUTER_RAW = 41
179 IPV6 = 42
180 MECHANISM = 43
181 PLAIN_SERVER = 44
182 PLAIN_USERNAME = 45, _OptType.bytes
183 PLAIN_PASSWORD = 46, _OptType.bytes
184 CURVE_SERVER = 47
185 CURVE_PUBLICKEY = 48, _OptType.bytes
186 CURVE_SECRETKEY = 49, _OptType.bytes
187 CURVE_SERVERKEY = 50, _OptType.bytes
188 PROBE_ROUTER = 51
189 REQ_CORRELATE = 52
190 REQ_RELAXED = 53
191 CONFLATE = 54
192 ZAP_DOMAIN = 55, _OptType.bytes
193 ROUTER_HANDOVER = 56
194 TOS = 57
195 CONNECT_ROUTING_ID = 61, _OptType.bytes
196 GSSAPI_SERVER = 62
197 GSSAPI_PRINCIPAL = 63, _OptType.bytes
198 GSSAPI_SERVICE_PRINCIPAL = 64, _OptType.bytes
199 GSSAPI_PLAINTEXT = 65
200 HANDSHAKE_IVL = 66
201 SOCKS_PROXY = 68, _OptType.bytes
202 XPUB_NODROP = 69
203 BLOCKY = 70
204 XPUB_MANUAL = 71
205 XPUB_WELCOME_MSG = 72, _OptType.bytes
206 STREAM_NOTIFY = 73
207 INVERT_MATCHING = 74
208 HEARTBEAT_IVL = 75
209 HEARTBEAT_TTL = 76
210 HEARTBEAT_TIMEOUT = 77
211 XPUB_VERBOSER = 78
212 CONNECT_TIMEOUT = 79
213 TCP_MAXRT = 80
214 THREAD_SAFE = 81
215 MULTICAST_MAXTPDU = 84
216 VMCI_BUFFER_SIZE = 85, _OptType.int64
217 VMCI_BUFFER_MIN_SIZE = 86, _OptType.int64
218 VMCI_BUFFER_MAX_SIZE = 87, _OptType.int64
219 VMCI_CONNECT_TIMEOUT = 88
220 USE_FD = 89
221 GSSAPI_PRINCIPAL_NAMETYPE = 90
222 GSSAPI_SERVICE_PRINCIPAL_NAMETYPE = 91
223 BINDTODEVICE = 92, _OptType.bytes
225 # Deprecated options and aliases
226 # must not use name-assignment, must have the same value
227 IDENTITY = ROUTING_ID
228 CONNECT_RID = CONNECT_ROUTING_ID
229 TCP_ACCEPT_FILTER = 38, _OptType.bytes
230 IPC_FILTER_PID = 58
231 IPC_FILTER_UID = 59
232 IPC_FILTER_GID = 60
233 IPV4ONLY = 31
234 DELAY_ATTACH_ON_CONNECT = IMMEDIATE
235 FAIL_UNROUTABLE = ROUTER_MANDATORY
236 ROUTER_BEHAVIOR = ROUTER_MANDATORY
238 # Draft socket options
239 ZAP_ENFORCE_DOMAIN = 93
240 LOOPBACK_FASTPATH = 94
241 METADATA = 95, _OptType.bytes
242 MULTICAST_LOOP = 96
243 ROUTER_NOTIFY = 97
244 XPUB_MANUAL_LAST_VALUE = 98
245 SOCKS_USERNAME = 99, _OptType.bytes
246 SOCKS_PASSWORD = 100, _OptType.bytes
247 IN_BATCH_SIZE = 101
248 OUT_BATCH_SIZE = 102
249 WSS_KEY_PEM = 103, _OptType.bytes
250 WSS_CERT_PEM = 104, _OptType.bytes
251 WSS_TRUST_PEM = 105, _OptType.bytes
252 WSS_HOSTNAME = 106, _OptType.bytes
253 WSS_TRUST_SYSTEM = 107
254 ONLY_FIRST_SUBSCRIBE = 108
255 RECONNECT_STOP = 109
256 HELLO_MSG = 110, _OptType.bytes
257 DISCONNECT_MSG = 111, _OptType.bytes
258 PRIORITY = 112
261class MessageOption(IntEnum):
262 """Options on zmq.Frame objects
264 .. versionadded:: 23
265 """
267 MORE = 1
268 SHARED = 3
269 # Deprecated message options
270 SRCFD = 2
273class Flag(IntFlag):
274 """Send/recv flags
276 .. versionadded:: 23
277 """
279 DONTWAIT = 1
280 SNDMORE = 2
281 NOBLOCK = DONTWAIT
284class SecurityMechanism(IntEnum):
285 """Security mechanisms (as returned by ``socket.get(zmq.MECHANISM)``)
287 .. versionadded:: 23
288 """
290 NULL = 0
291 PLAIN = 1
292 CURVE = 2
293 GSSAPI = 3
296class ReconnectStop(IntEnum):
297 """Select behavior for socket.reconnect_stop
299 .. versionadded:: 25
300 """
302 @staticmethod
303 def _global_name(name):
304 return f"RECONNECT_STOP_{name}"
306 CONN_REFUSED = 0x1
307 HANDSHAKE_FAILED = 0x2
308 AFTER_DISCONNECT = 0x4
311class Event(IntFlag):
312 """Socket monitoring events
314 .. versionadded:: 23
315 """
317 @staticmethod
318 def _global_name(name):
319 if name.startswith("PROTOCOL_ERROR_"):
320 return name
321 else:
322 # add EVENT_ prefix
323 return "EVENT_" + name
325 PROTOCOL_ERROR_WS_UNSPECIFIED = 0x30000000
326 PROTOCOL_ERROR_ZMTP_UNSPECIFIED = 0x10000000
327 PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND = 0x10000001
328 PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE = 0x10000002
329 PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE = 0x10000003
330 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED = 0x10000011
331 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE = 0x10000012
332 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO = 0x10000013
333 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE = 0x10000014
334 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR = 0x10000015
335 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY = 0x10000016
336 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME = 0x10000017
337 PROTOCOL_ERROR_ZMTP_INVALID_METADATA = 0x10000018
339 PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC = 0x11000001
340 PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH = 0x11000002
341 PROTOCOL_ERROR_ZAP_UNSPECIFIED = 0x20000000
342 PROTOCOL_ERROR_ZAP_MALFORMED_REPLY = 0x20000001
343 PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID = 0x20000002
344 PROTOCOL_ERROR_ZAP_BAD_VERSION = 0x20000003
345 PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE = 0x20000004
346 PROTOCOL_ERROR_ZAP_INVALID_METADATA = 0x20000005
348 # define event types _after_ overlapping protocol error masks
349 CONNECTED = 0x0001
350 CONNECT_DELAYED = 0x0002
351 CONNECT_RETRIED = 0x0004
352 LISTENING = 0x0008
353 BIND_FAILED = 0x0010
354 ACCEPTED = 0x0020
355 ACCEPT_FAILED = 0x0040
356 CLOSED = 0x0080
357 CLOSE_FAILED = 0x0100
358 DISCONNECTED = 0x0200
359 MONITOR_STOPPED = 0x0400
361 HANDSHAKE_FAILED_NO_DETAIL = 0x0800
362 HANDSHAKE_SUCCEEDED = 0x1000
363 HANDSHAKE_FAILED_PROTOCOL = 0x2000
364 HANDSHAKE_FAILED_AUTH = 0x4000
366 ALL_V1 = 0xFFFF
367 ALL = ALL_V1
369 # DRAFT Socket monitoring events
370 PIPES_STATS = 0x10000
371 ALL_V2 = ALL_V1 | PIPES_STATS
374class PollEvent(IntFlag):
375 """Which events to poll for in poll methods
377 .. versionadded: 23
378 """
380 POLLIN = 1
381 POLLOUT = 2
382 POLLERR = 4
383 POLLPRI = 8
386class DeviceType(IntEnum):
387 """Device type constants for zmq.device
389 .. versionadded: 23
390 """
392 STREAMER = 1
393 FORWARDER = 2
394 QUEUE = 3
397# AUTOGENERATED_BELOW_HERE
400IO_THREADS: int = ContextOption.IO_THREADS
401MAX_SOCKETS: int = ContextOption.MAX_SOCKETS
402SOCKET_LIMIT: int = ContextOption.SOCKET_LIMIT
403THREAD_PRIORITY: int = ContextOption.THREAD_PRIORITY
404THREAD_SCHED_POLICY: int = ContextOption.THREAD_SCHED_POLICY
405MAX_MSGSZ: int = ContextOption.MAX_MSGSZ
406MSG_T_SIZE: int = ContextOption.MSG_T_SIZE
407THREAD_AFFINITY_CPU_ADD: int = ContextOption.THREAD_AFFINITY_CPU_ADD
408THREAD_AFFINITY_CPU_REMOVE: int = ContextOption.THREAD_AFFINITY_CPU_REMOVE
409THREAD_NAME_PREFIX: int = ContextOption.THREAD_NAME_PREFIX
410STREAMER: int = DeviceType.STREAMER
411FORWARDER: int = DeviceType.FORWARDER
412QUEUE: int = DeviceType.QUEUE
413EAGAIN: int = Errno.EAGAIN
414EFAULT: int = Errno.EFAULT
415EINVAL: int = Errno.EINVAL
416ENOTSUP: int = Errno.ENOTSUP
417EPROTONOSUPPORT: int = Errno.EPROTONOSUPPORT
418ENOBUFS: int = Errno.ENOBUFS
419ENETDOWN: int = Errno.ENETDOWN
420EADDRINUSE: int = Errno.EADDRINUSE
421EADDRNOTAVAIL: int = Errno.EADDRNOTAVAIL
422ECONNREFUSED: int = Errno.ECONNREFUSED
423EINPROGRESS: int = Errno.EINPROGRESS
424ENOTSOCK: int = Errno.ENOTSOCK
425EMSGSIZE: int = Errno.EMSGSIZE
426EAFNOSUPPORT: int = Errno.EAFNOSUPPORT
427ENETUNREACH: int = Errno.ENETUNREACH
428ECONNABORTED: int = Errno.ECONNABORTED
429ECONNRESET: int = Errno.ECONNRESET
430ENOTCONN: int = Errno.ENOTCONN
431ETIMEDOUT: int = Errno.ETIMEDOUT
432EHOSTUNREACH: int = Errno.EHOSTUNREACH
433ENETRESET: int = Errno.ENETRESET
434EFSM: int = Errno.EFSM
435ENOCOMPATPROTO: int = Errno.ENOCOMPATPROTO
436ETERM: int = Errno.ETERM
437EMTHREAD: int = Errno.EMTHREAD
438PROTOCOL_ERROR_WS_UNSPECIFIED: int = Event.PROTOCOL_ERROR_WS_UNSPECIFIED
439PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZMTP_UNSPECIFIED
440PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int = (
441 Event.PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND
442)
443PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE
444PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int = Event.PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE
445PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int = (
446 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED
447)
448PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int = (
449 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE
450)
451PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int = (
452 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO
453)
454PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int = (
455 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE
456)
457PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int = (
458 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR
459)
460PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int = (
461 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY
462)
463PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int = (
464 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME
465)
466PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_METADATA
467PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int = Event.PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC
468PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int = (
469 Event.PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH
470)
471PROTOCOL_ERROR_ZAP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZAP_UNSPECIFIED
472PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int = Event.PROTOCOL_ERROR_ZAP_MALFORMED_REPLY
473PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int = Event.PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID
474PROTOCOL_ERROR_ZAP_BAD_VERSION: int = Event.PROTOCOL_ERROR_ZAP_BAD_VERSION
475PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int = (
476 Event.PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE
477)
478PROTOCOL_ERROR_ZAP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZAP_INVALID_METADATA
479EVENT_CONNECTED: int = Event.CONNECTED
480EVENT_CONNECT_DELAYED: int = Event.CONNECT_DELAYED
481EVENT_CONNECT_RETRIED: int = Event.CONNECT_RETRIED
482EVENT_LISTENING: int = Event.LISTENING
483EVENT_BIND_FAILED: int = Event.BIND_FAILED
484EVENT_ACCEPTED: int = Event.ACCEPTED
485EVENT_ACCEPT_FAILED: int = Event.ACCEPT_FAILED
486EVENT_CLOSED: int = Event.CLOSED
487EVENT_CLOSE_FAILED: int = Event.CLOSE_FAILED
488EVENT_DISCONNECTED: int = Event.DISCONNECTED
489EVENT_MONITOR_STOPPED: int = Event.MONITOR_STOPPED
490EVENT_HANDSHAKE_FAILED_NO_DETAIL: int = Event.HANDSHAKE_FAILED_NO_DETAIL
491EVENT_HANDSHAKE_SUCCEEDED: int = Event.HANDSHAKE_SUCCEEDED
492EVENT_HANDSHAKE_FAILED_PROTOCOL: int = Event.HANDSHAKE_FAILED_PROTOCOL
493EVENT_HANDSHAKE_FAILED_AUTH: int = Event.HANDSHAKE_FAILED_AUTH
494EVENT_ALL_V1: int = Event.ALL_V1
495EVENT_ALL: int = Event.ALL
496EVENT_PIPES_STATS: int = Event.PIPES_STATS
497EVENT_ALL_V2: int = Event.ALL_V2
498DONTWAIT: int = Flag.DONTWAIT
499SNDMORE: int = Flag.SNDMORE
500NOBLOCK: int = Flag.NOBLOCK
501MORE: int = MessageOption.MORE
502SHARED: int = MessageOption.SHARED
503SRCFD: int = MessageOption.SRCFD
504POLLIN: int = PollEvent.POLLIN
505POLLOUT: int = PollEvent.POLLOUT
506POLLERR: int = PollEvent.POLLERR
507POLLPRI: int = PollEvent.POLLPRI
508RECONNECT_STOP_CONN_REFUSED: int = ReconnectStop.CONN_REFUSED
509RECONNECT_STOP_HANDSHAKE_FAILED: int = ReconnectStop.HANDSHAKE_FAILED
510RECONNECT_STOP_AFTER_DISCONNECT: int = ReconnectStop.AFTER_DISCONNECT
511NULL: int = SecurityMechanism.NULL
512PLAIN: int = SecurityMechanism.PLAIN
513CURVE: int = SecurityMechanism.CURVE
514GSSAPI: int = SecurityMechanism.GSSAPI
515HWM: int = SocketOption.HWM
516AFFINITY: int = SocketOption.AFFINITY
517ROUTING_ID: int = SocketOption.ROUTING_ID
518SUBSCRIBE: int = SocketOption.SUBSCRIBE
519UNSUBSCRIBE: int = SocketOption.UNSUBSCRIBE
520RATE: int = SocketOption.RATE
521RECOVERY_IVL: int = SocketOption.RECOVERY_IVL
522SNDBUF: int = SocketOption.SNDBUF
523RCVBUF: int = SocketOption.RCVBUF
524RCVMORE: int = SocketOption.RCVMORE
525FD: int = SocketOption.FD
526EVENTS: int = SocketOption.EVENTS
527TYPE: int = SocketOption.TYPE
528LINGER: int = SocketOption.LINGER
529RECONNECT_IVL: int = SocketOption.RECONNECT_IVL
530BACKLOG: int = SocketOption.BACKLOG
531RECONNECT_IVL_MAX: int = SocketOption.RECONNECT_IVL_MAX
532MAXMSGSIZE: int = SocketOption.MAXMSGSIZE
533SNDHWM: int = SocketOption.SNDHWM
534RCVHWM: int = SocketOption.RCVHWM
535MULTICAST_HOPS: int = SocketOption.MULTICAST_HOPS
536RCVTIMEO: int = SocketOption.RCVTIMEO
537SNDTIMEO: int = SocketOption.SNDTIMEO
538LAST_ENDPOINT: int = SocketOption.LAST_ENDPOINT
539ROUTER_MANDATORY: int = SocketOption.ROUTER_MANDATORY
540TCP_KEEPALIVE: int = SocketOption.TCP_KEEPALIVE
541TCP_KEEPALIVE_CNT: int = SocketOption.TCP_KEEPALIVE_CNT
542TCP_KEEPALIVE_IDLE: int = SocketOption.TCP_KEEPALIVE_IDLE
543TCP_KEEPALIVE_INTVL: int = SocketOption.TCP_KEEPALIVE_INTVL
544IMMEDIATE: int = SocketOption.IMMEDIATE
545XPUB_VERBOSE: int = SocketOption.XPUB_VERBOSE
546ROUTER_RAW: int = SocketOption.ROUTER_RAW
547IPV6: int = SocketOption.IPV6
548MECHANISM: int = SocketOption.MECHANISM
549PLAIN_SERVER: int = SocketOption.PLAIN_SERVER
550PLAIN_USERNAME: int = SocketOption.PLAIN_USERNAME
551PLAIN_PASSWORD: int = SocketOption.PLAIN_PASSWORD
552CURVE_SERVER: int = SocketOption.CURVE_SERVER
553CURVE_PUBLICKEY: int = SocketOption.CURVE_PUBLICKEY
554CURVE_SECRETKEY: int = SocketOption.CURVE_SECRETKEY
555CURVE_SERVERKEY: int = SocketOption.CURVE_SERVERKEY
556PROBE_ROUTER: int = SocketOption.PROBE_ROUTER
557REQ_CORRELATE: int = SocketOption.REQ_CORRELATE
558REQ_RELAXED: int = SocketOption.REQ_RELAXED
559CONFLATE: int = SocketOption.CONFLATE
560ZAP_DOMAIN: int = SocketOption.ZAP_DOMAIN
561ROUTER_HANDOVER: int = SocketOption.ROUTER_HANDOVER
562TOS: int = SocketOption.TOS
563CONNECT_ROUTING_ID: int = SocketOption.CONNECT_ROUTING_ID
564GSSAPI_SERVER: int = SocketOption.GSSAPI_SERVER
565GSSAPI_PRINCIPAL: int = SocketOption.GSSAPI_PRINCIPAL
566GSSAPI_SERVICE_PRINCIPAL: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL
567GSSAPI_PLAINTEXT: int = SocketOption.GSSAPI_PLAINTEXT
568HANDSHAKE_IVL: int = SocketOption.HANDSHAKE_IVL
569SOCKS_PROXY: int = SocketOption.SOCKS_PROXY
570XPUB_NODROP: int = SocketOption.XPUB_NODROP
571BLOCKY: int = SocketOption.BLOCKY
572XPUB_MANUAL: int = SocketOption.XPUB_MANUAL
573XPUB_WELCOME_MSG: int = SocketOption.XPUB_WELCOME_MSG
574STREAM_NOTIFY: int = SocketOption.STREAM_NOTIFY
575INVERT_MATCHING: int = SocketOption.INVERT_MATCHING
576HEARTBEAT_IVL: int = SocketOption.HEARTBEAT_IVL
577HEARTBEAT_TTL: int = SocketOption.HEARTBEAT_TTL
578HEARTBEAT_TIMEOUT: int = SocketOption.HEARTBEAT_TIMEOUT
579XPUB_VERBOSER: int = SocketOption.XPUB_VERBOSER
580CONNECT_TIMEOUT: int = SocketOption.CONNECT_TIMEOUT
581TCP_MAXRT: int = SocketOption.TCP_MAXRT
582THREAD_SAFE: int = SocketOption.THREAD_SAFE
583MULTICAST_MAXTPDU: int = SocketOption.MULTICAST_MAXTPDU
584VMCI_BUFFER_SIZE: int = SocketOption.VMCI_BUFFER_SIZE
585VMCI_BUFFER_MIN_SIZE: int = SocketOption.VMCI_BUFFER_MIN_SIZE
586VMCI_BUFFER_MAX_SIZE: int = SocketOption.VMCI_BUFFER_MAX_SIZE
587VMCI_CONNECT_TIMEOUT: int = SocketOption.VMCI_CONNECT_TIMEOUT
588USE_FD: int = SocketOption.USE_FD
589GSSAPI_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_PRINCIPAL_NAMETYPE
590GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL_NAMETYPE
591BINDTODEVICE: int = SocketOption.BINDTODEVICE
592IDENTITY: int = SocketOption.IDENTITY
593CONNECT_RID: int = SocketOption.CONNECT_RID
594TCP_ACCEPT_FILTER: int = SocketOption.TCP_ACCEPT_FILTER
595IPC_FILTER_PID: int = SocketOption.IPC_FILTER_PID
596IPC_FILTER_UID: int = SocketOption.IPC_FILTER_UID
597IPC_FILTER_GID: int = SocketOption.IPC_FILTER_GID
598IPV4ONLY: int = SocketOption.IPV4ONLY
599DELAY_ATTACH_ON_CONNECT: int = SocketOption.DELAY_ATTACH_ON_CONNECT
600FAIL_UNROUTABLE: int = SocketOption.FAIL_UNROUTABLE
601ROUTER_BEHAVIOR: int = SocketOption.ROUTER_BEHAVIOR
602ZAP_ENFORCE_DOMAIN: int = SocketOption.ZAP_ENFORCE_DOMAIN
603LOOPBACK_FASTPATH: int = SocketOption.LOOPBACK_FASTPATH
604METADATA: int = SocketOption.METADATA
605MULTICAST_LOOP: int = SocketOption.MULTICAST_LOOP
606ROUTER_NOTIFY: int = SocketOption.ROUTER_NOTIFY
607XPUB_MANUAL_LAST_VALUE: int = SocketOption.XPUB_MANUAL_LAST_VALUE
608SOCKS_USERNAME: int = SocketOption.SOCKS_USERNAME
609SOCKS_PASSWORD: int = SocketOption.SOCKS_PASSWORD
610IN_BATCH_SIZE: int = SocketOption.IN_BATCH_SIZE
611OUT_BATCH_SIZE: int = SocketOption.OUT_BATCH_SIZE
612WSS_KEY_PEM: int = SocketOption.WSS_KEY_PEM
613WSS_CERT_PEM: int = SocketOption.WSS_CERT_PEM
614WSS_TRUST_PEM: int = SocketOption.WSS_TRUST_PEM
615WSS_HOSTNAME: int = SocketOption.WSS_HOSTNAME
616WSS_TRUST_SYSTEM: int = SocketOption.WSS_TRUST_SYSTEM
617ONLY_FIRST_SUBSCRIBE: int = SocketOption.ONLY_FIRST_SUBSCRIBE
618RECONNECT_STOP: int = SocketOption.RECONNECT_STOP
619HELLO_MSG: int = SocketOption.HELLO_MSG
620DISCONNECT_MSG: int = SocketOption.DISCONNECT_MSG
621PRIORITY: int = SocketOption.PRIORITY
622PAIR: int = SocketType.PAIR
623PUB: int = SocketType.PUB
624SUB: int = SocketType.SUB
625REQ: int = SocketType.REQ
626REP: int = SocketType.REP
627DEALER: int = SocketType.DEALER
628ROUTER: int = SocketType.ROUTER
629PULL: int = SocketType.PULL
630PUSH: int = SocketType.PUSH
631XPUB: int = SocketType.XPUB
632XSUB: int = SocketType.XSUB
633STREAM: int = SocketType.STREAM
634XREQ: int = SocketType.XREQ
635XREP: int = SocketType.XREP
636SERVER: int = SocketType.SERVER
637CLIENT: int = SocketType.CLIENT
638RADIO: int = SocketType.RADIO
639DISH: int = SocketType.DISH
640GATHER: int = SocketType.GATHER
641SCATTER: int = SocketType.SCATTER
642DGRAM: int = SocketType.DGRAM
643PEER: int = SocketType.PEER
644CHANNEL: int = SocketType.CHANNEL
646__all__: List[str] = [
647 "ContextOption",
648 "IO_THREADS",
649 "MAX_SOCKETS",
650 "SOCKET_LIMIT",
651 "THREAD_PRIORITY",
652 "THREAD_SCHED_POLICY",
653 "MAX_MSGSZ",
654 "MSG_T_SIZE",
655 "THREAD_AFFINITY_CPU_ADD",
656 "THREAD_AFFINITY_CPU_REMOVE",
657 "THREAD_NAME_PREFIX",
658 "DeviceType",
659 "STREAMER",
660 "FORWARDER",
661 "QUEUE",
662 "Enum",
663 "Errno",
664 "EAGAIN",
665 "EFAULT",
666 "EINVAL",
667 "ENOTSUP",
668 "EPROTONOSUPPORT",
669 "ENOBUFS",
670 "ENETDOWN",
671 "EADDRINUSE",
672 "EADDRNOTAVAIL",
673 "ECONNREFUSED",
674 "EINPROGRESS",
675 "ENOTSOCK",
676 "EMSGSIZE",
677 "EAFNOSUPPORT",
678 "ENETUNREACH",
679 "ECONNABORTED",
680 "ECONNRESET",
681 "ENOTCONN",
682 "ETIMEDOUT",
683 "EHOSTUNREACH",
684 "ENETRESET",
685 "EFSM",
686 "ENOCOMPATPROTO",
687 "ETERM",
688 "EMTHREAD",
689 "Event",
690 "PROTOCOL_ERROR_WS_UNSPECIFIED",
691 "PROTOCOL_ERROR_ZMTP_UNSPECIFIED",
692 "PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND",
693 "PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE",
694 "PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE",
695 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED",
696 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE",
697 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO",
698 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE",
699 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR",
700 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY",
701 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME",
702 "PROTOCOL_ERROR_ZMTP_INVALID_METADATA",
703 "PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC",
704 "PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH",
705 "PROTOCOL_ERROR_ZAP_UNSPECIFIED",
706 "PROTOCOL_ERROR_ZAP_MALFORMED_REPLY",
707 "PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID",
708 "PROTOCOL_ERROR_ZAP_BAD_VERSION",
709 "PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE",
710 "PROTOCOL_ERROR_ZAP_INVALID_METADATA",
711 "EVENT_CONNECTED",
712 "EVENT_CONNECT_DELAYED",
713 "EVENT_CONNECT_RETRIED",
714 "EVENT_LISTENING",
715 "EVENT_BIND_FAILED",
716 "EVENT_ACCEPTED",
717 "EVENT_ACCEPT_FAILED",
718 "EVENT_CLOSED",
719 "EVENT_CLOSE_FAILED",
720 "EVENT_DISCONNECTED",
721 "EVENT_MONITOR_STOPPED",
722 "EVENT_HANDSHAKE_FAILED_NO_DETAIL",
723 "EVENT_HANDSHAKE_SUCCEEDED",
724 "EVENT_HANDSHAKE_FAILED_PROTOCOL",
725 "EVENT_HANDSHAKE_FAILED_AUTH",
726 "EVENT_ALL_V1",
727 "EVENT_ALL",
728 "EVENT_PIPES_STATS",
729 "EVENT_ALL_V2",
730 "Flag",
731 "DONTWAIT",
732 "SNDMORE",
733 "NOBLOCK",
734 "IntEnum",
735 "IntFlag",
736 "MessageOption",
737 "MORE",
738 "SHARED",
739 "SRCFD",
740 "PollEvent",
741 "POLLIN",
742 "POLLOUT",
743 "POLLERR",
744 "POLLPRI",
745 "ReconnectStop",
746 "RECONNECT_STOP_CONN_REFUSED",
747 "RECONNECT_STOP_HANDSHAKE_FAILED",
748 "RECONNECT_STOP_AFTER_DISCONNECT",
749 "SecurityMechanism",
750 "NULL",
751 "PLAIN",
752 "CURVE",
753 "GSSAPI",
754 "SocketOption",
755 "HWM",
756 "AFFINITY",
757 "ROUTING_ID",
758 "SUBSCRIBE",
759 "UNSUBSCRIBE",
760 "RATE",
761 "RECOVERY_IVL",
762 "SNDBUF",
763 "RCVBUF",
764 "RCVMORE",
765 "FD",
766 "EVENTS",
767 "TYPE",
768 "LINGER",
769 "RECONNECT_IVL",
770 "BACKLOG",
771 "RECONNECT_IVL_MAX",
772 "MAXMSGSIZE",
773 "SNDHWM",
774 "RCVHWM",
775 "MULTICAST_HOPS",
776 "RCVTIMEO",
777 "SNDTIMEO",
778 "LAST_ENDPOINT",
779 "ROUTER_MANDATORY",
780 "TCP_KEEPALIVE",
781 "TCP_KEEPALIVE_CNT",
782 "TCP_KEEPALIVE_IDLE",
783 "TCP_KEEPALIVE_INTVL",
784 "IMMEDIATE",
785 "XPUB_VERBOSE",
786 "ROUTER_RAW",
787 "IPV6",
788 "MECHANISM",
789 "PLAIN_SERVER",
790 "PLAIN_USERNAME",
791 "PLAIN_PASSWORD",
792 "CURVE_SERVER",
793 "CURVE_PUBLICKEY",
794 "CURVE_SECRETKEY",
795 "CURVE_SERVERKEY",
796 "PROBE_ROUTER",
797 "REQ_CORRELATE",
798 "REQ_RELAXED",
799 "CONFLATE",
800 "ZAP_DOMAIN",
801 "ROUTER_HANDOVER",
802 "TOS",
803 "CONNECT_ROUTING_ID",
804 "GSSAPI_SERVER",
805 "GSSAPI_PRINCIPAL",
806 "GSSAPI_SERVICE_PRINCIPAL",
807 "GSSAPI_PLAINTEXT",
808 "HANDSHAKE_IVL",
809 "SOCKS_PROXY",
810 "XPUB_NODROP",
811 "BLOCKY",
812 "XPUB_MANUAL",
813 "XPUB_WELCOME_MSG",
814 "STREAM_NOTIFY",
815 "INVERT_MATCHING",
816 "HEARTBEAT_IVL",
817 "HEARTBEAT_TTL",
818 "HEARTBEAT_TIMEOUT",
819 "XPUB_VERBOSER",
820 "CONNECT_TIMEOUT",
821 "TCP_MAXRT",
822 "THREAD_SAFE",
823 "MULTICAST_MAXTPDU",
824 "VMCI_BUFFER_SIZE",
825 "VMCI_BUFFER_MIN_SIZE",
826 "VMCI_BUFFER_MAX_SIZE",
827 "VMCI_CONNECT_TIMEOUT",
828 "USE_FD",
829 "GSSAPI_PRINCIPAL_NAMETYPE",
830 "GSSAPI_SERVICE_PRINCIPAL_NAMETYPE",
831 "BINDTODEVICE",
832 "IDENTITY",
833 "CONNECT_RID",
834 "TCP_ACCEPT_FILTER",
835 "IPC_FILTER_PID",
836 "IPC_FILTER_UID",
837 "IPC_FILTER_GID",
838 "IPV4ONLY",
839 "DELAY_ATTACH_ON_CONNECT",
840 "FAIL_UNROUTABLE",
841 "ROUTER_BEHAVIOR",
842 "ZAP_ENFORCE_DOMAIN",
843 "LOOPBACK_FASTPATH",
844 "METADATA",
845 "MULTICAST_LOOP",
846 "ROUTER_NOTIFY",
847 "XPUB_MANUAL_LAST_VALUE",
848 "SOCKS_USERNAME",
849 "SOCKS_PASSWORD",
850 "IN_BATCH_SIZE",
851 "OUT_BATCH_SIZE",
852 "WSS_KEY_PEM",
853 "WSS_CERT_PEM",
854 "WSS_TRUST_PEM",
855 "WSS_HOSTNAME",
856 "WSS_TRUST_SYSTEM",
857 "ONLY_FIRST_SUBSCRIBE",
858 "RECONNECT_STOP",
859 "HELLO_MSG",
860 "DISCONNECT_MSG",
861 "PRIORITY",
862 "SocketType",
863 "PAIR",
864 "PUB",
865 "SUB",
866 "REQ",
867 "REP",
868 "DEALER",
869 "ROUTER",
870 "PULL",
871 "PUSH",
872 "XPUB",
873 "XSUB",
874 "STREAM",
875 "XREQ",
876 "XREP",
877 "SERVER",
878 "CLIENT",
879 "RADIO",
880 "DISH",
881 "GATHER",
882 "SCATTER",
883 "DGRAM",
884 "PEER",
885 "CHANNEL",
886]