ex_nsq v1.1.0 NSQ.Protocol

Link to this section Summary

Functions

decode(msg)

decode_as_message(data)

encode(cmd)

Refer to http://nsq.io/clients/tcp_protocol_spec.html

is_valid_channel_name?(topic)

is_valid_topic_name?(topic)

ok_msg()

response_msg(body)

Link to this section Functions

Link to this function decode(msg)

Link to this function decode_as_message(data)

decode_as_message(binary) ::
  {atom, Map.t} |
  {atom, String.t}

Link to this function encode(cmd)

Refer to http://nsq.io/clients/tcp_protocol_spec.html.

Link to this function is_valid_channel_name?(topic)

Link to this function is_valid_topic_name?(topic)

Link to this function ok_msg()

Link to this function response_msg(body)