anchor.diff:                                          Scheme, Host,
                                           Port, ?CONNECT_TIMEOUT) of
           {ok, Pid} ->
  +            start_idle_timer(),
               ConnectEnd = os:timestamp(),
               ?INFO("drain_id=~p channel_id=~p dest=~s at=try_connect "
                     "attempt=success connect_time=~p",
  
positive.code: disconnected(timeout, S = #state{}) ->
      %% Sleep when inactive, trigger fullsweep GC & Compact
      {next_state, disconnected, S, hibernate};
  disconnected(Msg, State) ->
      ?WARN("drain_id=~p channel_id=~p dest=~s err=unexpected_info "
            "data=\"~1000p\" state=disconnected",
  
negative.code: -define(CONTENT_TYPE, <<"application/logplex-1">>).
  -define(HTTP_VERSION, 'HTTP/1.1').
  -define(RECONNECT_MSG, reconnect).
  -define(IDLE_TIMEOUT_MSG, idle_timeout).
  -define(CONNECT_TIMEOUT, 3000).
  -define(REQUEST_TIMEOUT, 5000).
  
  