[][src]Crate libzmq

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

Re-exports

pub use failure;

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

Keeps the list of sockets and manages the async I/O thread and internal queries.

CtxBuilder

A convenience builder for 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.

Quantity

Represents a quantity.

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.