Class IndexingLedgerPoller

java.lang.Object

ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller

@ApplicationScoped
public class IndexingLedgerPoller
extends Object

Polls repository-service's indexing ledger for per-crawl receipt progress. Ledger rows are written when opensearch-manager emits a DocumentIndexedEvent receipt, so the aggregate answers "how many of this crawl's docs has OSM finished indexing, and how" — the drain-side counterpart to the dispatch count the orchestrator already knows. crawl_id driven, one blocking gRPC call per tick on a virtual thread.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	IndexingLedgerPoller.CrawlProgress	Receipt counts for one crawl, partitioned the way the run report wants them.

Constructor Summary

Constructors

Constructor	Description
IndexingLedgerPoller()	Creates the poller; its gRPC stub is injected and it is managed by CDI.

Method Summary

Modifier and Type	Method	Description
IndexingLedgerPoller.CrawlProgress	progress(String crawlId)	Fetch the indexing-ledger receipt progress for one crawl.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IndexingLedgerPoller

public IndexingLedgerPoller()

Creates the poller; its gRPC stub is injected and it is managed by CDI.

Method Details

progress

public IndexingLedgerPoller.CrawlProgress progress(String crawlId)

Fetch the indexing-ledger receipt progress for one crawl.

Parameters:

crawlId - the crawl id whose ledger progress to read

Returns:

the partitioned receipt counts for the crawl