ex_nsq v1.1.0 NSQ.Connection.Initializer
Link to this section Summary
Functions
Immediately after connecting to the NSQ socket, both consumers and producers follow this protocol
Link to this section Functions
Link to this function
connect(state)
connect(%{nsqd: NSQ.Connection.host_with_port}) ::
{:ok, NSQ.Connection.state} |
{:error, String.t}
Link to this function
do_handshake(conn_state)
do_handshake(NSQ.Connection.state) :: {:ok, NSQ.Connection.state}
Immediately after connecting to the NSQ socket, both consumers and producers follow this protocol.
Link to this function
do_handshake!(conn_state)
Link to this function
inflate(data)