anchor.diff:        {queue_overflow_suspend_period,
          State#state.queue_overflow_suspend_period,
          get_queue_overflow_suspend_period(State)},
  +      {counters,
  +       [{?max_processes_reached, get(?max_processes_reached)},
  +        {?max_messages_reached, get(?max_messages_reached)}]},
         {options, State#state.options}
        ],
        State};
  
positive.code:     QOSP = proplists:get_value(queue_overflow_suspend_period, Options),
      %% initialize gauge for spawned cast workers
      undefined = put(?async_workers, 0),
      {ok,
       #state{socket = Socket,
              ready = false, %% will wait for 'ready' signal
  
negative.code:             end
      end.
  
  %% @doc Increment value for internal counter or gauge.
  -spec increment_counter(Counter :: atom()) -> ok.
  increment_counter(Counter) ->
      _OldValue = put(Counter, get(Counter) + 1),
      ok.
  
  %% @doc Return current message queue length.
  -spec get_message_queue_len() -> non_neg_integer().
  get_message_queue_len() ->
  