module ZMQ

Defined in:

lib_zmq/constants.cr
zeromq.cr
zeromq/device.cr
zeromq/exceptions.cr
zeromq/message.cr
zeromq/socket.cr
zeromq/version.cr

Constant Summary

AFFINITY = 4
BACKLOG = 19
BLOCKY = 70
CONFLATE = 54
CONNECT_RID = 61
CURVE = 2
CURVE_PUBLICKEY = 48
CURVE_SECRETKEY = 49
CURVE_SERVER = 47
CURVE_SERVERKEY = 50
DEALER = XREQ
DELAY_ATTACH_ON_CONNECT = 39
DONTWAIT = 1

Send/recv options

EADDRINUSE = Errno::EADDRINUSE
EADDRNOTAVAIL = Errno::EADDRNOTAVAIL
EAFNOSUPPORT = Errno::EAFNOSUPPORT
EAGAIN = Errno::EAGAIN

Socket errors

ECONNABORTED = Errno::ECONNABORTED
ECONNREFUSED = Errno::ECONNREFUSED
ECONNRESET = Errno::ECONNRESET
EFAULT = Errno::EFAULT
EFSM = (HAUSNUMERO + 51)
EHOSTUNREACH = Errno::EHOSTUNREACH
EINPROGRESS = Errno::EINPROGRESS
EINTR = Errno::EINTR
EINVAL = Errno::EINVAL
EMFILE = Errno::EMFILE
EMSGSIZE = Errno::EMSGSIZE
EMTHREAD = (HAUSNUMERO + 54)
ENETDOWN = Errno::ENETDOWN
ENETRESET = Errno::ENETRESET
ENETUNREACH = Errno::ENETUNREACH
ENOBUFS = Errno::ENOBUFS
ENOCOMPATPROTO = (HAUSNUMERO + 52)
ENODEV = Errno::ENODEV
ENOMEM = Errno::ENOMEM
ENOTCONN = Errno::ENOTCONN
ENOTSOCK = Errno::ENOTSOCK
ENOTSUP = Errno::ENOTSUP

Rescue unknown constants and use the ZeroMQ defined values Usually only happens on Windows though some don't resolve on OSX too (ENOTSUP)

EPROTONOSUPPORT = Errno::EPROTONOSUPPORT
ETERM = (HAUSNUMERO + 53)
ETIMEDOUT = Errno::ETIMEDOUT
EVENT_ACCEPT_FAILED = 64
EVENT_ACCEPTED = 32
EVENT_ALL = ((((((((((EVENT_CONNECTED | EVENT_CONNECT_DELAYED) | EVENT_CONNECT_RETRIED) | EVENT_LISTENING) | EVENT_BIND_FAILED) | EVENT_ACCEPTED) | EVENT_ACCEPT_FAILED) | EVENT_CLOSED) | EVENT_CLOSE_FAILED) | EVENT_DISCONNECTED) | EVENT_MONITOR_STOPPED)
EVENT_BIND_FAILED = 16
EVENT_CLOSE_FAILED = 256
EVENT_CLOSED = 128
EVENT_CONNECT_DELAYED = 2
EVENT_CONNECT_RETRIED = 4
EVENT_CONNECTED = 1

Socket events and monitoring

EVENT_DISCONNECTED = 512
EVENT_LISTENING = 8
EVENT_MONITOR_STOPPED = 1024
EVENTS = 15
FAIL_UNROUTABLE = ROUTER_MANDATORY
FD = 14
FORWARDER = 2
GSSAPI_PLAINTEXT = 65
GSSAPI_PRINCIPAL = 63
GSSAPI_SERVER = 62
GSSAPI_SERVICE_PRINCIPAL = 64
HANDSHAKE_IVL = 66
HAUSNUMERO = 156384712

ZMQ errors

HEARTBEAT_IVL = 75
HEARTBEAT_TIMEOUT = 77
HEARTBEAT_TTL = 76
IDENTITY = 5
IMMEDIATE = DELAY_ATTACH_ON_CONNECT
INT32_SOCKET_OPTIONS = [EVENTS, LINGER, RCVTIMEO, SNDTIMEO, RECONNECT_IVL, FD, TYPE, BACKLOG, RECONNECT_IVL_MAX, RCVHWM, SNDHWM, RATE, RECOVERY_IVL, SNDBUF, RCVBUF, IPV4ONLY, ROUTER_BEHAVIOR, TCP_KEEPALIVE, TCP_KEEPALIVE_CNT, TCP_KEEPALIVE_IDLE, TCP_KEEPALIVE_INTVL, TCP_ACCEPT_FILTER, MULTICAST_HOPS, IMMEDIATE]
INT32_SOCKET_OPTIONS_V4 = [IPV6, MECHANISM, PLAIN_SERVER, CURVE_SERVER, PROBE_ROUTER, REQ_CORRELATE, REQ_RELAXED, CONFLATE]
INT64_SOCKET_OPTIONS = [RCVMORE, AFFINITY, MAXMSGSIZE]
INVERT_MATCHING = 74
IO_THREADS = 1

Context options

IO_THREADS_DFLT = 1
IPV4ONLY = 31
IPV6 = 42
LAST_ENDPOINT = 32
LINGER = 17
MAX_SOCKETS = 2
MAX_SOCKETS_DFLT = 1023
MAXMSGSIZE = 22
MECHANISM = 43
MORE = 1

Message options

MULTICAST_HOPS = 25
NOBLOCK = DONTWAIT
NULL = 0

Socket Security Types

PAIR = 0
PLAIN = 1
PLAIN_PASSWORD = 46
PLAIN_SERVER = 44
PLAIN_USERNAME = 45
POLL = 1

I/O multiplexing

POLLERR = 4
POLLIN = 1
POLLOUT = 2
PROBE_ROUTER = 51
PUB = 1
PULL = 7
PUSH = 8
QUEUE = 3
RATE = 8
RCVBUF = 12
RCVHWM = 24
RCVMORE = 13
RCVTIMEO = 27
RECONNECT_IVL = 18
RECONNECT_IVL_MAX = 21
RECOVERY_IVL = 9
REP = 4
REQ = 3
REQ_CORRELATE = 52
REQ_RELAXED = 53
ROUTER = XREP
ROUTER_BEHAVIOR = ROUTER_MANDATORY
ROUTER_HANDOVER = 56
ROUTER_MANDATORY = 33
ROUTER_RAW = 41
SNDBUF = 11
SNDHWM = 23
SNDLABEL = 4
SNDMORE = 2
SNDTIMEO = 28
SocketTypeNameMap = {PAIR => "PAIR", PUB => "PUB", SUB => "SUB", REQ => "REQ", REP => "REP", PULL => "PULL", PUSH => "PUSH", XREQ => "XREQ", XREP => "XREP", ROUTER => "ROUTER", DEALER => "DEALER", XPUB => "XPUB", XSUB => "XSUB", STREAM => "STREAM"}
SOCKS_PROXY = 68
STREAM = 11
STREAM_NOTIFY = 73
STREAMER = 1

Device Types

STRING_SOCKET_OPTIONS = [IDENTITY, SUBSCRIBE, UNSUBSCRIBE, LAST_ENDPOINT]
STRING_SOCKET_OPTIONS_V4 = [ZAP_DOMAIN, PLAIN_USERNAME, PLAIN_PASSWORD, CURVE_PUBLICKEY, CURVE_SERVERKEY, CURVE_SECRETKEY]
SUB = 2
SUBSCRIBE = 6
TCP_ACCEPT_FILTER = 38
TCP_KEEPALIVE = 34
TCP_KEEPALIVE_CNT = 35
TCP_KEEPALIVE_IDLE = 36
TCP_KEEPALIVE_INTVL = 37
TOS = 57
TYPE = 16
UNSUBSCRIBE = 7
VERSION = "0.3.0"
XPUB = 9
XPUB_MANUAL = 71
XPUB_NODROP = 69
XPUB_VERBOSE = 40
XPUB_VERBOSE_UNSUBSCRIBE = 78
XPUB_WELCOME_MSG = 72
XREP = 6
XREQ = 5
XSUB = 10
ZAP_DOMAIN = 55

Class Method Summary

Class Method Detail

def self.version #

[View source]