anchor.diff:        end),
   
       {noreply, State};
  +handle_call({invalidate_remote_bucket, Cluster, Bucket}, _From, State) ->
  +    UUID = proplists:get_value(uuid, Cluster),
  +    true = (UUID =/= undefined),
  +    ets:delete(?CACHE, {bucket, UUID, Bucket}),
  +    {reply, ok, State};
   handle_call({get_remote_bucket, Cluster, Bucket, false, Timeout}, From, State) ->
       UUID = proplists:get_value(uuid, Cluster),
       true = (UUID =/= undefined),
  
positive.code:     gen_server:call(?MODULE,
                      {get_remote_bucket, Cluster, Bucket, Through, Timeout}, infinity).
  
  %% gen_server callbacks
  init([]) ->
      CachePath = path_config:component_path(data, "remote_clusters_cache"),
  
negative.code: -export([fetch_remote_cluster/1, fetch_remote_cluster/2,
           get_remote_bucket/3, get_remote_bucket/4,
           get_remote_bucket_by_ref/2, get_remote_bucket_by_ref/3,
           remote_bucket_reference/2,
           invalidate_remote_bucket/2, invalidate_remote_bucket_by_ref/1]).
  
  %% gen_server callbacks
  -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
  