ex_nsq v1.1.0 NSQ.Consumer.Backoff
When messages fail unexpectedly hard, we go into “backoff mode”.
Link to this section Summary
Functions
This function is called asynchronously from resume_later. It
will cause one connection to have RDY 1. We only resume after this if
messages succeed a number of times == backoff_counter. (That logic is in
start_stop_continue.)
Decision point about whether to continue/end/ignore backoff
Link to this section Functions
Link to this function
resume(cons, cons_state)
resume(pid, NSQ.Consumer.state) :: {:ok, NSQ.Consumer.state}
This function is called asynchronously from resume_later. It
will cause one connection to have RDY 1. We only resume after this if
messages succeed a number of times == backoff_counter. (That logic is in
start_stop_continue.)
Link to this function
resume!(cons, cons_state)
Link to this function
start_stop_continue(cons, backoff_signal, cons_state)
start_stop_continue(pid, atom, NSQ.Consumer.state) :: {:ok, NSQ.Consumer.state}
Decision point about whether to continue/end/ignore backoff.
Link to this function
start_stop_continue!(cons, backoff_signal, cons_state)