anchor.diff:  stream_list_keys(Pid, Table, Options)
     when is_pid(Pid), (is_binary(Table) orelse is_list(Table)), is_list(Options) ->
       ReqTimeout = proplists:get_value(timeout, Options),
  -    Req = #tslistkeysreq{table = iolist_to_binary(Table),
  -                         timeout = ReqTimeout},
  +    Req = #tslistkeysreq{table=convert_to_binary(Table),
  +                         timeout=ReqTimeout},
       ReqId = riakc_pb_socket:mk_reqid(),
       gen_server:call(Pid, {req, Req, ?DEFAULT_PB_TIMEOUT, {ReqId, self()}}, infinity).
   
  
positive.code:                    QueryText::binary()) -> {ok, Entries::[term()]} | {error, term()} | {'EXIT', any()}.
  get_coverage(Pid, Table, QueryText) ->
      server_call(Pid,
                  #tscoveragereq{query = #tsinterpolation{base=riakc_ts:convert_to_binary(QueryText)},
                                 replace_cover=undefined,
                                 table = riakc_ts:convert_to_binary(Table)}).
  
  
  -spec put(pid(), table_name(), [[ts_value()]]) ->
  
negative.code: delete(Pid, Table, Key, Options)
    when is_pid(Pid), (is_binary(Table) orelse is_list(Table)),
         is_list(Key), is_list(Options) ->
      Message = #tsdelreq{table  =convert_to_binary(Table),
                          key    =riak_pb_ts_codec:encode_cells_non_strict(Key),
                          vclock =proplists:get_value(vclock, Options),
                          timeout=proplists:get_value(timeout, Options)},
      _Response = server_call(Pid, Message).
  
  
  