net/zeromq¶
type frameZeroMQ frame.
meth frame(Bytes: address): frameReturns a new frame with the contents of
Bytes.meth (Frame: frame):data: stringReturns the contents of
Frame.meth (Arg₁: string::buffer):append(Arg₂: frame)TBD
type message < sequenceZeroMQ message.
meth message(): messageReturns a new empty message.
meth message(Frame₁: any, ...): messageReturns a new message with the specified content.
Frameᵢcan be bytes (address / string), a frame, another message ornilto add an empty frame.meth message(Signal: integer): messageReturns a new signal message with specified value.
meth message(Socket: socket): message | nilReturns the next message read from
Socket, blocking until a message is available.meth message(Socket: socket, Block: boolean): message | nilReturns the next message read from
Socket; ifBlock = truethen blocks until a message is available.meth (Message: message):pop: frame | nilRemoves and returns the first frame in
Messageornilif there are no frames.meth (Message: message):popmsg: message | nilRemoves and returns the first sub message in
Messageornilif there are no sub messages.meth (Message: message):put(Frame: frame): messageAppends
Frameto the end ofMessage.meth (Message: message):put(Bytes: address): messageAppends a new frame to the end of
Messagewith the specified content.meth (Message: message):put(Nil: nil): messageAppends an empty frame to the end of
Message.meth (Message: message):put(SubMessage: message): messageAppends
SubMessageto the end ofMessage.meth (Message: message):send(Socket: socket)Sends
MessageonSocket.meth (Message: message):sendm(Socket: socket)Sends
MessageonSocketwithout the final flag.meth (Arg₁: string::buffer):append(Arg₂: message)TBD
type socketZeroMQ socket.
meth socket(Type: sockettype): socketReturns a new socket of the specified type.
meth (Socket: socket):affinity: integerReturns the current affinity setting of
Socket.meth (Socket: socket):affinity(Integer: integer)Updates the affinity setting of
Socket.meth (Arg₁: socket):attach(Arg₂: string, Arg₃: boolean)TBD
meth (Socket: socket):backlog: integerReturns the current backlog setting of
Socket.meth (Socket: socket):backlog(Integer: integer)Updates the backlog setting of
Socket.meth (Arg₁: socket):bind(Arg₂: string)TBD
meth (Socket: socket):conflate(Integer: integer)Updates the conflate setting of
Socket.meth (Arg₁: socket):connect(Arg₂: string)TBD
meth (Socket: socket):connect_rid(Integer: string)Updates the connect_rid setting of
Socket.meth (Socket: socket):connect_timeout: integerReturns the current connect_timeout setting of
Socket.meth (Socket: socket):connect_timeout(Integer: integer)Updates the connect_timeout setting of
Socket.meth (Socket: socket):curve_publickey: integerReturns the current curve_publickey setting of
Socket.meth (Socket: socket):curve_publickey(Integer: string)Updates the curve_publickey setting of
Socket.meth (Socket: socket):curve_secretkey: integerReturns the current curve_secretkey setting of
Socket.meth (Socket: socket):curve_secretkey(Integer: string)Updates the curve_secretkey setting of
Socket.meth (Socket: socket):curve_server: integerReturns the current curve_server setting of
Socket.meth (Socket: socket):curve_server(Integer: integer)Updates the curve_server setting of
Socket.meth (Socket: socket):delay_attach_on_connect(Integer: integer)Updates the delay_attach_on_connect setting of
Socket.meth (Arg₁: socket):destroyTBD
meth (Arg₁: socket):disconnect(Arg₂: string)TBD
meth (Arg₁: socket):endpointTBD
meth (Socket: socket):events: integerReturns the current events setting of
Socket.meth (Socket: socket):fd: integerReturns the current fd setting of
Socket.meth (Arg₁: socket):flushTBD
meth (Socket: socket):gssapi_plaintext: integerReturns the current gssapi_plaintext setting of
Socket.meth (Socket: socket):gssapi_plaintext(Integer: integer)Updates the gssapi_plaintext setting of
Socket.meth (Socket: socket):gssapi_principal: integerReturns the current gssapi_principal setting of
Socket.meth (Socket: socket):gssapi_principal(Integer: string)Updates the gssapi_principal setting of
Socket.meth (Socket: socket):gssapi_server: integerReturns the current gssapi_server setting of
Socket.meth (Socket: socket):gssapi_server(Integer: integer)Updates the gssapi_server setting of
Socket.meth (Socket: socket):gssapi_service_principal: integerReturns the current gssapi_service_principal setting of
Socket.meth (Socket: socket):gssapi_service_principal(Integer: string)Updates the gssapi_service_principal setting of
Socket.meth (Socket: socket):handshake_ivl: integerReturns the current handshake_ivl setting of
Socket.meth (Socket: socket):handshake_ivl(Integer: integer)Updates the handshake_ivl setting of
Socket.meth (Socket: socket):heartbeat_ivl: integerReturns the current heartbeat_ivl setting of
Socket.meth (Socket: socket):heartbeat_ivl(Integer: integer)Updates the heartbeat_ivl setting of
Socket.meth (Socket: socket):heartbeat_timeout: integerReturns the current heartbeat_timeout setting of
Socket.meth (Socket: socket):heartbeat_timeout(Integer: integer)Updates the heartbeat_timeout setting of
Socket.meth (Socket: socket):heartbeat_ttl: integerReturns the current heartbeat_ttl setting of
Socket.meth (Socket: socket):heartbeat_ttl(Integer: integer)Updates the heartbeat_ttl setting of
Socket.meth (Socket: socket):identity: integerReturns the current identity setting of
Socket.meth (Socket: socket):identity(Integer: string)Updates the identity setting of
Socket.meth (Socket: socket):immediate: integerReturns the current immediate setting of
Socket.meth (Socket: socket):immediate(Integer: integer)Updates the immediate setting of
Socket.meth (Socket: socket):invert_matching: integerReturns the current invert_matching setting of
Socket.meth (Socket: socket):invert_matching(Integer: integer)Updates the invert_matching setting of
Socket.meth (Socket: socket):ipv4only: integerReturns the current ipv4only setting of
Socket.meth (Socket: socket):ipv4only(Integer: integer)Updates the ipv4only setting of
Socket.meth (Socket: socket):ipv6: integerReturns the current ipv6 setting of
Socket.meth (Socket: socket):ipv6(Integer: integer)Updates the ipv6 setting of
Socket.meth (Socket: socket):linger: integerReturns the current linger setting of
Socket.meth (Socket: socket):linger(Integer: integer)Updates the linger setting of
Socket.meth (Socket: socket):maxmsgsize: integerReturns the current maxmsgsize setting of
Socket.meth (Socket: socket):maxmsgsize(Integer: integer)Updates the maxmsgsize setting of
Socket.meth (Socket: socket):multicast_hops: integerReturns the current multicast_hops setting of
Socket.meth (Socket: socket):multicast_hops(Integer: integer)Updates the multicast_hops setting of
Socket.meth (Socket: socket):multicast_maxtpdu: integerReturns the current multicast_maxtpdu setting of
Socket.meth (Socket: socket):multicast_maxtpdu(Integer: integer)Updates the multicast_maxtpdu setting of
Socket.meth (Socket: socket):plain_password: integerReturns the current plain_password setting of
Socket.meth (Socket: socket):plain_password(Integer: string)Updates the plain_password setting of
Socket.meth (Socket: socket):plain_server: integerReturns the current plain_server setting of
Socket.meth (Socket: socket):plain_server(Integer: integer)Updates the plain_server setting of
Socket.meth (Socket: socket):plain_username: integerReturns the current plain_username setting of
Socket.meth (Socket: socket):plain_username(Integer: string)Updates the plain_username setting of
Socket.meth (Socket: socket):probe_router(Integer: integer)Updates the probe_router setting of
Socket.meth (Socket: socket):rate: integerReturns the current rate setting of
Socket.meth (Socket: socket):rate(Integer: integer)Updates the rate setting of
Socket.meth (Socket: socket):rcvbuf: integerReturns the current rcvbuf setting of
Socket.meth (Socket: socket):rcvbuf(Integer: integer)Updates the rcvbuf setting of
Socket.meth (Socket: socket):rcvhwm: integerReturns the current rcvhwm setting of
Socket.meth (Socket: socket):rcvhwm(Integer: integer)Updates the rcvhwm setting of
Socket.meth (Socket: socket):rcvmore: integerReturns the current rcvmore setting of
Socket.meth (Socket: socket):rcvtimeo: integerReturns the current rcvtimeo setting of
Socket.meth (Socket: socket):rcvtimeo(Integer: integer)Updates the rcvtimeo setting of
Socket.meth (Socket: socket):reconnect_ivl: integerReturns the current reconnect_ivl setting of
Socket.meth (Socket: socket):reconnect_ivl(Integer: integer)Updates the reconnect_ivl setting of
Socket.meth (Socket: socket):reconnect_ivl_max: integerReturns the current reconnect_ivl_max setting of
Socket.meth (Socket: socket):reconnect_ivl_max(Integer: integer)Updates the reconnect_ivl_max setting of
Socket.meth (Socket: socket):recovery_ivl: integerReturns the current recovery_ivl setting of
Socket.meth (Socket: socket):recovery_ivl(Integer: integer)Updates the recovery_ivl setting of
Socket.meth (Socket: socket):req_correlate(Integer: integer)Updates the req_correlate setting of
Socket.meth (Socket: socket):req_relaxed(Integer: integer)Updates the req_relaxed setting of
Socket.meth (Socket: socket):router_handover(Integer: integer)Updates the router_handover setting of
Socket.meth (Socket: socket):router_mandatory(Integer: integer)Updates the router_mandatory setting of
Socket.meth (Socket: socket):router_raw(Integer: integer)Updates the router_raw setting of
Socket.meth (Arg₁: socket):signal(Arg₂: integer)TBD
meth (Socket: socket):sndbuf: integerReturns the current sndbuf setting of
Socket.meth (Socket: socket):sndbuf(Integer: integer)Updates the sndbuf setting of
Socket.meth (Socket: socket):sndhwm: integerReturns the current sndhwm setting of
Socket.meth (Socket: socket):sndhwm(Integer: integer)Updates the sndhwm setting of
Socket.meth (Socket: socket):sndtimeo: integerReturns the current sndtimeo setting of
Socket.meth (Socket: socket):sndtimeo(Integer: integer)Updates the sndtimeo setting of
Socket.meth (Socket: socket):socks_proxy: integerReturns the current socks_proxy setting of
Socket.meth (Socket: socket):socks_proxy(Integer: string)Updates the socks_proxy setting of
Socket.meth (Socket: socket):stream_notify(Integer: integer)Updates the stream_notify setting of
Socket.meth (Socket: socket):subscribe(Integer: string)Updates the subscribe setting of
Socket.meth (Socket: socket):tcp_accept_filter: integerReturns the current tcp_accept_filter setting of
Socket.meth (Socket: socket):tcp_accept_filter(Integer: string)Updates the tcp_accept_filter setting of
Socket.meth (Socket: socket):tcp_keepalive: integerReturns the current tcp_keepalive setting of
Socket.meth (Socket: socket):tcp_keepalive(Integer: integer)Updates the tcp_keepalive setting of
Socket.meth (Socket: socket):tcp_keepalive_cnt: integerReturns the current tcp_keepalive_cnt setting of
Socket.meth (Socket: socket):tcp_keepalive_cnt(Integer: integer)Updates the tcp_keepalive_cnt setting of
Socket.meth (Socket: socket):tcp_keepalive_idle: integerReturns the current tcp_keepalive_idle setting of
Socket.meth (Socket: socket):tcp_keepalive_idle(Integer: integer)Updates the tcp_keepalive_idle setting of
Socket.meth (Socket: socket):tcp_keepalive_intvl: integerReturns the current tcp_keepalive_intvl setting of
Socket.meth (Socket: socket):tcp_keepalive_intvl(Integer: integer)Updates the tcp_keepalive_intvl setting of
Socket.meth (Socket: socket):tcp_maxrt: integerReturns the current tcp_maxrt setting of
Socket.meth (Socket: socket):tcp_maxrt(Integer: integer)Updates the tcp_maxrt setting of
Socket.meth (Socket: socket):tos: integerReturns the current tos setting of
Socket.meth (Socket: socket):tos(Integer: integer)Updates the tos setting of
Socket.meth (Arg₁: socket):unbind(Arg₂: string)TBD
meth (Socket: socket):unsubscribe(Integer: string)Updates the unsubscribe setting of
Socket.meth (Socket: socket):use_fd: integerReturns the current use_fd setting of
Socket.meth (Socket: socket):use_fd(Integer: integer)Updates the use_fd setting of
Socket.meth (Socket: socket):vmci_buffer_max_size: integerReturns the current vmci_buffer_max_size setting of
Socket.meth (Socket: socket):vmci_buffer_max_size(Integer: integer)Updates the vmci_buffer_max_size setting of
Socket.meth (Socket: socket):vmci_buffer_min_size: integerReturns the current vmci_buffer_min_size setting of
Socket.meth (Socket: socket):vmci_buffer_min_size(Integer: integer)Updates the vmci_buffer_min_size setting of
Socket.meth (Socket: socket):vmci_buffer_size: integerReturns the current vmci_buffer_size setting of
Socket.meth (Socket: socket):vmci_buffer_size(Integer: integer)Updates the vmci_buffer_size setting of
Socket.meth (Socket: socket):vmci_connect_timeout: integerReturns the current vmci_connect_timeout setting of
Socket.meth (Socket: socket):vmci_connect_timeout(Integer: integer)Updates the vmci_connect_timeout setting of
Socket.meth (Arg₁: socket):waitTBD
meth (Socket: socket):xpub_manual(Integer: integer)Updates the xpub_manual setting of
Socket.meth (Socket: socket):xpub_nodrop(Integer: integer)Updates the xpub_nodrop setting of
Socket.meth (Socket: socket):xpub_verbose(Integer: integer)Updates the xpub_verbose setting of
Socket.meth (Socket: socket):xpub_verboser(Integer: integer)Updates the xpub_verboser setting of
Socket.meth (Socket: socket):xpub_welcome_msg(Integer: string)Updates the xpub_welcome_msg setting of
Socket.meth (Socket: socket):zap_domain: integerReturns the current zap_domain setting of
Socket.meth (Socket: socket):zap_domain(Integer: string)Updates the zap_domain setting of
Socket.meth (Arg₁: string::buffer):append(Arg₂: socket)TBD
type socketevent < enum::In::Out::Err::Pri
type sockettype < enumZeroMQ socket type.
::Pair::Pub::Sub::Req::Rep::Dealer::Router::Pull::Push::XPub::XSub::Stream