anchor.diff:  %%
   %% This returns the value from the local ETS cache, returning 'not_found' if it was not found.
   -spec get_cache(Bucket::binary(), Key::binary()) ->
  -    {ok, Value :: json()} | {error, Msg :: list()} | not_found.
  +    {ok, Value :: json()} | not_found | {error, Msg :: list()}.
   
   get_cache(Bucket, Key) ->
   	case ets:lookup(?MODULE, {Bucket, Key}) of
   		[] ->
   			not_found;
  -		[Value] ->
  +		[{_, Value}] ->
   			Value;
   		Else ->
   			?error("Unexpected response from ETS. Response was: ~p", [Else]),
  
positive.code: 
  handle_info(_, State) ->
      {noreply, State}.
  
  %% --------------------------------------------------------------------------------------------------------------------
  
  parse_json(Bin) ->
  	{not_really_json}.
  
  %% --------------------------------------------------------------------------------------------------------------------
  
  
negative.code: 	{reply, Resp, State};
  
  handle_call({set, Bucket, Key, Value}, _From, State) ->
  	RiakConn = State#state.riak_conn,
  	JSONBin = pre_json:to_json(Value),
  	RiakObj = riakc_obj:new(Bucket, Key, JSONBin, "application/json"),
  	Resp = try riakc_pb_socket:put(RiakConn, RiakObj) of
  		Valid ->
  			Valid
  	catch
  		siblings ->
  			%TODO: Figure out how to retrieve the siblings.
  			{siblings, [RiakObj]}
  	end,
  	{reply, Resp, State};
  
  handle_call({delete, Bucket, Key}, _From, State) ->
  	RiakConn = State#state.riak_conn,
  	Resp = case riakc_pb_socket:delete(RiakConn, Bucket, Key) of
  		ok ->
  			ok;
  		{error, Error} ->
  			?error("Unexpected response from Riak. Response was: ~p", [Error]),
  			{error, "Error querying ETS cache."}
  	end,
  	{reply, Resp, State};
  
  handle_call(_, _From, State) ->
      {reply, invalid, State}.
  