ex_nsq

v1.1.0

ex_nsq v1.1.0 NSQ.Consumer.Helpers

Link to this section Summary

Functions

conn_from_nsqd(cons, nsqd, cons_state)
now()
per_conn_max_in_flight(cons_state)

Returns how much max_in_flight should be distributed to each connection. If max_in_flight is less than the number of connections, then this always returns 1 and they are randomly distributed via redistribute_rdy. Not for external use

total_rdy_count(agent_pid)

Convenience function; uses the consumer state to get the conn info pid. Not for external use

Link to this section Functions

Link to this function conn_from_nsqd(cons, nsqd, cons_state) 
conn_from_nsqd(pid, NSQ.Consumer.host_with_port, NSQ.Consumer.state) :: NSQ.Consumer.connection
Link to this function now() 
now() :: integer
Link to this function per_conn_max_in_flight(cons_state) 
per_conn_max_in_flight(NSQ.Consumer.state) :: integer

Returns how much max_in_flight should be distributed to each connection. If max_in_flight is less than the number of connections, then this always returns 1 and they are randomly distributed via redistribute_rdy. Not for external use.

Link to this function total_rdy_count(agent_pid) 
total_rdy_count(pid) :: integer
total_rdy_count(NSQ.Consumer.state) :: integer

Convenience function; uses the consumer state to get the conn info pid. Not for external use.