anchor.diff:  	{reply, Resp, State};
   
   handle_call({set, Bucket, Key, Value}, _From, State) ->
  -	{reply, {error, 'FECK'}, 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) ->
  -	{reply, {error, 'FECK'}, 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}.
  
positive.code: %%
  %% This queries Riak for the given value, and caches the value in ETS.
  -spec get_checked(Bucket::binary(), Key::binary()) ->
      {ok, Value :: json()} | {error, Msg :: list()}.
  
  get_checked(Bucket, Key) ->
  	gen_server:call(?MODULE, {get, Bucket, Key}).
  
negative.code: %%
  %% 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()} | not_found | {error, Msg :: list()}.
  
  get_cache(Bucket, Key) ->
  	case ets:lookup(?MODULE, {Bucket, Key}) of
  		[] ->
  			not_found;
  		[{_, Value}] ->
  			Value;
  		Else ->
  			?error("Unexpected response from ETS. Response was: ~p", [Else]),
  