Struct AccountIndexer 

pub struct AccountIndexer { /* private fields */ }

One account’s indexer: its own channel, its own worker, its own tables.

Implementations

impl AccountIndexer

pub fn start( account: &str, archive: Arc<File>, journal: Option<PathBuf>, ) -> Self

Start an indexer for account reading extents back out of archive. journal is the ack-path durable record a not-yet-indexed read falls back to scanning; None for a writer that keeps none.

Pack rows only. For the object rows as well, see start_with_absorber — a writer bench has no git store behind it and wants exactly this.

pub fn start_with_absorber( account: &str, archive: Arc<File>, journal: Option<PathBuf>, absorber: Option<Arc<dyn ObjectAbsorb>>, ) -> Self

The same indexer with the object-level half wired in: each drained job’s objects are absorbed through absorber before the pack’s indexed bit goes up.

pub fn account(&self) -> &str

The account this indexer belongs to.

pub fn submit(&self, job: IndexJob) -> Result<()>

Hand an extent over. Returns immediately: 24 bytes onto a channel.

pub fn cancel(&self)

Tell the worker to stop: every job still queued is dropped unabsorbed (its pack keeps a clear bit — nothing is declared indexed), and the absorber’s own cancel flag is what aborts the pack in flight.

pub fn is_cancelled(&self) -> bool

pub fn wait_caught_up(&self)

Block until this account’s index has caught up with everything submitted so far. Used by tests and by the bench’s “with index” column.

pub fn is_indexed(&self, pack_id: u64) -> bool

Is this pack’s indexed bit set?

pub fn rows(&self) -> usize

Number of index rows built so far.

pub fn absorb_failures(&self) -> u64

How many packs failed ObjectAbsorb::absorb in this indexer. Their indexed bits are clear and their reads still fall back.

pub fn last_absorb_error(&self) -> Option<String>

The most recent absorb error, if any.

pub fn tables(&self) -> Vec<RecordBatch>

The built index tables.

pub fn lookup(&self, pack_id: u64) -> Lookup

Answer a read, honestly, whether or not the index is ready.

pub fn finish(self) -> Vec<RecordBatch>

Close the channel and join the worker, returning the final tables.

Trait Implementations

impl Drop for AccountIndexer

fn drop(&mut self)

Cancel, then join — never join a worker that may be hours into a pack or parked by the memory watchdog. The queued jobs are dropped unabsorbed and the pack in flight is aborted at its next checkpoint; their bits stay clear, so the next open re-queues them from the journal (resumed 0%). Nobody waits on the indexer, and that includes the process shutting down and a repo delete.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.