Implement range sync

This commit is contained in:
Pawan Dhananjay
2026-05-26 18:09:18 -07:00
parent dfb259171a
commit e867441220
21 changed files with 657 additions and 112 deletions

View File

@@ -33,6 +33,8 @@ pub enum SyncRequestId {
BlobsByRange(BlobsByRangeRequestId),
/// Data columns by range request
DataColumnsByRange(DataColumnsByRangeRequestId),
/// Payload envelopes by range request
PayloadEnvelopesByRange(PayloadEnvelopesByRangeRequestId),
}
/// Request ID for data_columns_by_root requests. Block lookups do not issue this request directly.
@@ -59,6 +61,12 @@ pub struct BlobsByRangeRequestId {
pub parent_request_id: ComponentsByRangeRequestId,
}
#[derive(Debug, Hash, PartialEq, Eq, Clone, Copy)]
pub struct PayloadEnvelopesByRangeRequestId {
pub id: Id,
pub parent_request_id: ComponentsByRangeRequestId,
}
#[derive(Debug, Hash, PartialEq, Eq, Clone, Copy)]
pub struct DataColumnsByRangeRequestId {
/// Id to identify this attempt at a data_columns_by_range request for `parent_request_id`
@@ -261,6 +269,12 @@ macro_rules! impl_display {
impl_display!(BlocksByRangeRequestId, "{}/{}", id, parent_request_id);
impl_display!(BlobsByRangeRequestId, "{}/{}", id, parent_request_id);
impl_display!(DataColumnsByRangeRequestId, "{}/{}", id, parent_request_id);
impl_display!(
PayloadEnvelopesByRangeRequestId,
"{}/{}",
id,
parent_request_id
);
impl_display!(ComponentsByRangeRequestId, "{}/{}", id, requester);
impl_display!(DataColumnsByRootRequestId, "{}/{}", id, requester);
impl_display!(SingleLookupReqId, "{}/Lookup/{}", req_id, lookup_id);