anchor.diff:  		checkpoint_path,
   		options_pl,
   		ttl,
  -		it_mon}).
  +		it_mon,
  +		reader}).
   
   %%%===================================================================
   %%% API
  
positive.code:     {ok, State :: #state{}, Timeout :: pos_integer() | infinity} |
      ignore |
      {stop, Reason :: term()}.
  init(Args) ->
      Shard = maps:get(shard, Args),
      enterdb_ns:register_pid(self(), Shard),
  
negative.code:                     WriteOptionsRec = build_writeoptions([]),
                      {ok, WriteOptions} = rocksdb:writeoptions(WriteOptionsRec),
                      process_flag(trap_exit, true),
  		    State =
  			#state{name = Subdir,
  			       db_ref = DB,
  			       options = Options,
  			       readoptions = ReadOptions,
  			       writeoptions = WriteOptions,
  			       shard = Shard,
  			       column_mapper = ColumnMapper,
  			       db_path = DbPath,
  			       wal_path = WalPath,
  			       backup_path = BackupPath,
  			       checkpoint_path = CheckpointPath,
  			       options_pl = OptionsPL,
  			       ttl = TTL,
  			       it_mon = maps:new()},
  		    %% start a reader version of our self
  		    gen_server:cast(self(), start_reader),
  		    {ok, State}
              end;
          {error, Reason} ->
              {stop, {error, Reason}}
  