List of all items

Structs

• connection::Connection
• connection_pool::ConnectionPool
• connection_pool::ConnectionPoolConfig
• connection_pool::ConnectionPoolStats
• connection_pool::PooledConnection
• consumer::Consumer
• consumer::ConsumerConfig
• consumer::ConsumerStats
• consumer::Message
• producer::BackoffConfig
• producer::NsqProducer
• producer::ProducerConfig
• protocol::IdentifyConfig
• protocol::Message
• protocol::Protocol

Enums

• connection_pool::HealthStatus
• consumer::ConsumerError
• error::Error
• 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
• connection_pool::create_connection_pool
• connection_pool::create_default_connection_pool
• lookup::lookup_nodes
• producer::new_producer
• protocol::read_frame

Type Aliases

• error::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