anchor.diff:  		{ok, Fetched1} -> true;
   		{error, notfound} -> false
   	end.
  -
   
   impl_online(Pid, Id, Token) when is_list(Id) ->
   	BinId = erlang:list_to_binary(Id),
  
positive.code: 	{ok, {index_results_v1, L, _,_}} = riakc_pb_socket:get_index_eq(Pid, ?UTokenBucket,{integer_index, Attr}, Key),
  	L.
  
  
  
  impl_check_is_online(Pid, Id, Token) when is_list(Id) ->
  	BinId = erlang:list_to_binary(Id),
  	impl_check_is_online(Pid, BinId, Token);
  
negative.code: 	MetaData = riakc_obj:get_update_metadata(Obj1),
  	io:format("~p~n", [MetaData]),
  
  	MD1 = riakc_obj:set_secondary_index(MetaData, [{{integer_index, "expire_unixtime"}, [V#token.expire_unixtime]}]),
  
  	Obj2 = riakc_obj:update_metadata(Obj1, MD1),
  
  	riakc_pb_socket:put(Pid, Obj2),
  	{reply, {ok, V}, State};
  
  handle_call({add, Id, ExpireUnixtime}, From, State) when is_list(Id) ->
  	Pid = State,
  	BinId = erlang:list_to_binary(Id),
  
  	V = gen_token(ExpireUnixtime),
  
  	Obj1 = riakc_obj:new(?UTokenBucket, BinId, V),
  	io:format("~p~n", [Obj1]),
  
  	MetaData = riakc_obj:get_update_metadata(Obj1),
  	io:format("~p~n", [MetaData]),
  
  	MD1 = riakc_obj:set_secondary_index(MetaData, [{{integer_index, "expire_unixtime"}, [V#token.expire_unixtime]}]),
  
  	Obj2 = riakc_obj:update_metadata(Obj1, MD1),
  
  	riakc_pb_socket:put(Pid, Obj2),
  	{reply, {ok, V}, State};
  
  
  handle_call({remove_all}, From, State) ->
  	Pid = State,
  