anchor.diff:  
   debug() ->
       gen_server2:cast(?SERVER, debug).
  +
  +qos_traverse_finished(_QosEntryId, _) ->
  +    ok.
   
   %%%===================================================================
   %%% Spawning and gen_server implementation
  
positive.code:         [{since, 0}, {until, Until}], [self()]
      ).
  
  % fixme almost the same as in dbsync_changes
  links_save(Model, RoutingKey, Doc = #document{key = Key}) ->
      Ctx = datastore_model_default:get_ctx(Model),
      Ctx2 = Ctx#{
          local_links_tree_id => oneprovider:get_id(),
          routing_key => RoutingKey
      },
      Ctx3 = datastore_multiplier:extend_name(RoutingKey, Ctx2),
      case datastore_router:route(save, [Ctx3#{expiry => ?EXPIRY}, Key, Doc]) of
          {ok, Doc2} ->
              Doc2;
          {error, ignored} ->
              undefined
      end.
  
negative.code: -author("Michal Stanisz").
  
  -behaviour(gen_server).
  % fixme not needed (and maybe whole behaviour and callbacks not needed)
  -behaviour(qos_caller_behaviour).
  
  -include("modules/datastore/qos.hrl").
  -include("modules/fslogic/fslogic_common.hrl").
  