protoblock 0.1.6

Asynchronous Bitcoin block ingestion pipeline with built-in reorg handling, backpressure, and observability
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Worker module split across focused submodules:
//! - `types`: shared enums/aliases for worker control & batching
//! - `shared`: state shared across workers (queue, telemetry, activity)
//! - `process`: worker struct plus run/process logic
//! - `batch`: helper impls for planning/fetching batches
//! - `tests`: worker integration/unit tests

mod batch;
mod process;
mod shared;
mod types;

#[cfg(test)]
mod tests;

pub use process::Worker;
pub use shared::{WorkerActivityTracker, WorkerShared, WorkerSharedParams};
pub use types::{
    worker_control_channel, FetcherEvent, FetcherEventSender, WorkerControl, WorkerControlReceiver,
    WorkerControlSender,
};