Module rpc_store_ingestion_client

Module rpc_store_ingestion_client 

Source
Expand description

IngestionClientTrait backed by a fullnode’s local checkpoint and perpetual stores.

The embedded sui-rpc-store indexer fetches historical checkpoints by sequence number – to backfill the history cohort and to fill gaps the live broadcast stream drops. On a fullnode every executed checkpoint’s data already lives in the local stores, so this client assembles a Checkpoint from them via ReadStore::get_checkpoint_data rather than fetching from a remote object store or gRPC endpoint.

Structs§

PerpetualStoreIngestionClient
An IngestionClientTrait over any ReadStore. In production R is the fullnode’s RocksDbStore, which reads the local checkpoint and perpetual stores; the generic bound keeps it unit-testable against an in-memory store.