package zmq

You can search for identifiers within the package.

in-package search v0.2.0

OCaml bindings for ZeroMQ 4.x

Install

Dune Dependency

github.com Readme Changelog MIT License Edit opam file Versions (11)

Authors

Maintainers

A

Anders Fugmann <anders@fugmann.net>

Sources

zmq-5.3.0.tbz

sha256=b5eb42995836eff58767e1ccc0a6551c2ac74f358094ac2402334389b075fba8

sha512=712eac902ea9c52ac0b47c80a851ee29ca3ea5a69a16ecac2b1ba5c0ff83082a41524e41fdbdeddc7a1c3037e5a4d1494a17ebf7c0b202603f652edab5a1aee7

doc/zmq/Zmq/Monitor/index.html

Module `Zmq.Monitor`Source

Sourcetype t

Sourcetype address = string

Sourcetype error_no = int

Sourcetype error_text = string

Sourcetype event =

| Connected of address * Unix.file_descr
| Connect_delayed of address
| Connect_retried of address * int
| Listening of address * Unix.file_descr
| Bind_failed of address * error_no * error_text
| Accepted of address * Unix.file_descr
| Accept_failed of address * error_no * error_text
| Closed of address * Unix.file_descr
| Close_failed of address * error_no * error_text
| Disconnected of address * Unix.file_descr
| Monitor_stopped of address
| Handshake_failed_no_detail of address
| Handshake_succeeded of address
| Handshake_failed_protocol of address * int
| Handshake_failed_auth of address * int

Sourceval create : 'a Socket.t -> t

Sourceval connect : Context.t -> t -> [< `Monitor ] Socket.t

Sourceval recv : ?block:bool -> [< `Monitor ] Socket.t -> event

Receive an event from the monitor socket. block indicates if the call should be blocking or non-blocking. Default true

Sourceval string_of_event : event -> string

Sourceval mk_string_of_event : unit -> event -> string

Create a memorizing function for converting an event to a string. As its it not possible to reliably retrieve the peer address of a closed socket dues to a race condition, this function pairs connects and disconnects and returns the matching connect peer address to disconnects.

Note that it is not possible to retrieve the peer address of connect events is the peer has disconnected before string_of_event is called