Struct ColdStorageTask 

pub struct ColdStorageTask<B: ColdStorage> { /* private fields */ }

The cold storage task that processes requests.

This task receives requests over separate read and write channels and dispatches them to the storage backend. It supports graceful shutdown via a cancellation token.

Processing Model

• Reads: Spawned as concurrent tasks (up to 64 in flight). Multiple reads can execute in parallel.
• Writes: Processed inline (sequential). Each write completes before the next is started, ensuring ordering.

This design prioritizes write ordering for correctness while allowing read throughput to scale with concurrency.

Log Streaming

The task owns the streaming configuration (max deadline, concurrency limit) and delegates the streaming loop to the backend via ColdStorage::produce_log_stream. Callers supply a per-request deadline that is clamped to the task’s configured maximum.

Caching

Transaction, receipt, and header lookups are served from an LRU cache when possible. Cache entries are invalidated on truncate_above to handle reorgs.

Implementations

impl<B: ColdStorage> ColdStorageTask<B>

pub fn new( backend: B, cancel_token: CancellationToken, ) -> (Self, ColdStorageHandle)

Create a new cold storage task and return its handle.

pub fn spawn(backend: B, cancel_token: CancellationToken) -> ColdStorageHandle

Spawn the task and return the handle.

The task will run until the cancellation token is triggered or the channels are closed.

pub async fn run(self)

Run the task, processing requests until shutdown.

Trait Implementations

impl<B: ColdStorage> Debug for ColdStorageTask<B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.