anchor.diff:  msg_code(rpbyokozunaindexdeletereq) -> 57;
   msg_code(rpbyokozunaschemagetreq)   -> 58;
   msg_code(rpbyokozunaschemagetresp)  -> 59;
  -msg_code(rpbyokozunaschemaputreq)   -> 60.
  +msg_code(rpbyokozunaschemaputreq)   -> 60;
  +msg_code(dtfetch)                -> 80;
  +msg_code(dtfetchresponse)        -> 81;
  +msg_code(dtupdate)               -> 82;
  +msg_code(dtupdateresponse)       -> 83.
   
   %% @doc Selects the appropriate PB decoder for a message code.
   -spec decoder_for(pos_integer()) -> module().
  
positive.code: decoder_for(N) when N >= 27, N =< 28 ->
      riak_search_pb;
  decoder_for(N) when N >= 54, N =< 60 ->
      riak_yokozuna_pb.
  
  %% @doc Selects the appropriate PB encoder for a given message name.
  -spec encoder_for(atom()) -> module().
  
negative.code: msg_type(58) -> rpbyokozunaschemagetreq;
  msg_type(59) -> rpbyokozunaschemagetresp;
  msg_type(60) -> rpbyokozunaschemaputreq;
  msg_type(80) -> dtfetch;
  msg_type(81) -> dtfetchresponse;
  msg_type(82) -> dtupdate;
  msg_type(83) -> dtupdateresponse;
  msg_type(_) -> undefined.
  
  %% @doc Converts a symbolic message name into a message code. Replaces
  