anchor.diff:  %%--------------------------------------------------------------------
   init([]) ->
       ?INFO("at=init", []),
  -    Urls = lookup_urls(),
  +    Urls = logs_redis_urls(),
   
       erlang:process_flag(trap_exit, true),
   
  
positive.code: prepare_new_urls(NewIps) ->
      NewIpsSorted = lists:sort(NewIps),
      OldUrls = lists:sort([binary_to_list(Url)
                            || Url <- redis_helper:shard_urls()]),
      length(OldUrls) =:= length(NewIpsSorted)
          orelse erlang:error({invalid_ip_list, different_length_to_existing}),
      NewUrls = [ update_redis_host(OldUrl, NewIp)
  
negative.code: %%--------------------------------------------------------------------
  %%% Internal functions
  %%--------------------------------------------------------------------
  logs_redis_urls() ->
      URLs = case os:getenv("LOGPLEX_SHARD_URLS") of
                 [] ->
                     case os:getenv("LOGPLEX_CONFIG_REDIS_URL") of
  