ex_nsq

v1.1.0

ex_nsq v1.1.0 NSQ.ConnInfo

Link to this section Summary

Functions

all(agent_pid)

Get info for all connections in a map like %{conn_id: %{... data ...}}

conn_id(arg1)

Given a connection state object, return the connection ID

conn_id(parent, nsqd)

Given a consumer state object and an nsqd host/port tuple, return the connection ID

init(state)
reduce(agent_pid, start_acc, func)

func is passed conn_info for each connection

Link to this section Functions

Link to this function all(agent_pid)

Get info for all connections in a map like %{conn_id: %{... data ...}}.

Link to this function conn_id(arg1)

Given a connection state object, return the connection ID.

Link to this function conn_id(parent, nsqd)

Given a consumer state object and an nsqd host/port tuple, return the connection ID.

Link to this function init(state) 
init(map) :: any
Link to this function reduce(agent_pid, start_acc, func)

func is passed conn_info for each connection.