anchor.diff:  
   
   retrieve_last_entry_at(StreamID,At) ->
  -    File = cake_stream_manager:stream_filename(StreamID),
  +    {ok,File} = cake_stream_manager:stream_filename(StreamID),
       Offset = get_indexed_offset(StreamID,At),
       lager:debug("Offset from get_indexed_offset: ~p", [Offset]),
       DataFile = open_data_file(File),
  
positive.code: 
  
  all_since_query(StreamID,From) ->
      File = cake_stream_manager:stream_filename(StreamID),
      Offset = get_indexed_offset(StreamID,From),
      lager:debug("Offset from get_indexed_offset: ~p", [Offset]),
      DataFile = open_data_file(File),
  
negative.code: 
  
  get_indexed_offset(StreamID,From) ->
      {ok,File} = cake_stream_manager:stream_filename(StreamID),
      {ok,DataDir} = application:get_env(cake,data_dir),
      {ok,Data} = file:read_file(DataDir ++ File ++ "/" ++ File ++ ".index"),
      get_indexed_offset(Data,From,0).
  