Module rpc_store_streaming_client 

CheckpointStreamingClient backed by the checkpoint executor’s broadcast stream.

The embedded sui-rpc-store indexer consumes the tip of the chain from the same tokio::sync::broadcast channel the executor publishes to (see CheckpointExecutor), avoiding a gRPC round-trip to the node’s own subscription endpoint. The ingestion framework only engages the streaming client once the indexer is within catch-up range of the tip; any gap (for example after the receiver lags) surfaces as a stream error, which the framework fills from the PerpetualStoreIngestionClient instead.

Structs

BroadcastStreamingClient

A CheckpointStreamingClient that subscribes to the executor’s checkpoint broadcast channel. connect seeds the stream with the current tip read from the local store, then follows the broadcast for checkpoints published after the call.