anchor.diff:      gen_server:call(?MODULE,
                       {get_remote_bucket, Cluster, Bucket, Through, Timeout}, infinity).
   
  +
  +invalidate_remote_bucket(ClusterName, Bucket) ->
  +    Cluster = find_cluster_by_name(ClusterName),
  +    gen_server:call(?MODULE,
  +                    {invalidate_remote_bucket, Cluster, Bucket}, infinity).
  +
   %% gen_server callbacks
   init([]) ->
       CachePath = path_config:component_path(data, "remote_clusters_cache"),
  
positive.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]).
  
  %% gen_server callbacks
  -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
  
negative.code:       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),
  