List of all items

Structs

• connection::Connection
• consumer::Consumer
• consumer::ConsumerConfig
• consumer::ConsumerStats
• consumer::Message
• pool::Pool
• pool::PoolConfig
• pool::PooledConn
• producer::BackoffConfig
• producer::NsqProducer
• producer::ProducerConfig
• protocol::IdentifyConfig
• protocol::Message
• protocol::Protocol

Enums

• consumer::ConsumerError
• error::Error
• pool::PoolError
• protocol::Command
• protocol::Frame
• protocol::FrameType
• protocol::ProtocolError

Traits

• consumer::Handler
• producer::Producer

Functions

• commands::create_nsqd_connection
• commands::lookup_nsqd_nodes
• commands::mpublish_messages
• commands::publish_message
• commands::subscribe
• connection::close_connection
• lookup::lookup_nodes
• producer::new_producer
• protocol::read_frame

Type Aliases

• error::Result
• pool::Result

Constants

• protocol::AUTH
• protocol::CLS
• protocol::FIN
• protocol::FRAME_TYPE_ERROR
• protocol::FRAME_TYPE_MESSAGE
• protocol::FRAME_TYPE_RESPONSE
• protocol::HEARTBEAT
• protocol::IDENTIFY
• protocol::MAGIC_V2
• protocol::MPUB
• protocol::NOP
• protocol::OK
• protocol::PUB
• protocol::RDY
• protocol::REQ
• protocol::SUB
• protocol::TOUCH