Crate libzmq

Source
Expand description

libzmq - A strict subset of ØMQ with a high level API.

Modules§

addr
Address related types.
auth
Socket authentication and encryption.
config
Configurations for libzmq types.
poll
Asynchronous polling mechanim.
prelude
A “prelude” for users of the libzmq crate.

Structs§

Client
A Client socket is used for advanced request-reply messaging.
ClientBuilder
A builder for a Client.
Ctx
A owning pointer to a ØMQ context.
CtxBuilder
A convenience builder for a Ctx.
CtxHandle
A non-owning pointer to a Ctx.
Dish
A Dish socket is used by a subscriber to subscribe to groups distributed by a Radio.
DishBuilder
A builder for a Dish.
EpgmAddr
A socket address with the Encapsulated PGM transport.
Error
An error with a kind and a msg.
Gather
A Gather socket is used to receive pipelined messages.
GatherBuilder
A builder for a Gather.
Group
An CString that is a valid ØMQ group identifier.
GroupParseError
An error returned when trying to parse a GroupSlice or Group.
GroupSlice
A slice to a Group
Heartbeat
Socket heartbeating configuration.
InprocAddr
A socket address with inter-thread transport.
Msg
A handle to a message owned by ØMQ.
PgmAddr
A socket address with the PGM transport.
Radio
A Radio socket is used by a publisher to distribute data to Dish sockets.
RadioBuilder
A builder for a Radio.
RoutingId
A generated ID used to route messages to the approriate client.
Scatter
A Scatter socket is used to pipeline messages to workers.
ScatterBuilder
A builder for a Scatter.
Server
A Server socket is a socket used for advanced request-reply messaging.
ServerBuilder
A builder for a Server.
TcpAddr
A socket address with the TCP transport.
UdpAddr
A socket address with the UDP transport.

Enums§

ErrorKind
Used to give context to an Error.
Period
Represents a period of time.
SocketType
An enum containing all the socket types.

Constants§

INPROC_MAX_SIZE
The maximum number of characters in a inproc address.
MAX_GROUP_SIZE
The maximum allowed number of characters in a group.

Functions§

proxy
Start a built-in ØMQ proxy between a frontend and a backend socket.
version
Reports the ØMQ library version.