sui_indexer/backfill/backfill_instances/ingestion_backfills/
digest_task.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
// Copyright (c) Mysten Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

use crate::backfill::backfill_instances::ingestion_backfills::IngestionBackfillTrait;
use crate::database::ConnectionPool;
use sui_types::full_checkpoint_content::CheckpointData;
use tracing::info;

/// Dummy backfill that only prints the sequence number and checkpoint of the digest. Intended to
/// benchmark backfill performance.
pub struct DigestBackfill;

#[async_trait::async_trait]
impl IngestionBackfillTrait for DigestBackfill {
    type ProcessedType = ();

    fn process_checkpoint(checkpoint: &CheckpointData) -> Vec<Self::ProcessedType> {
        let cp = checkpoint.checkpoint_summary.sequence_number;
        let digest = checkpoint.checkpoint_summary.content_digest;
        info!("{cp}: {digest}");

        vec![]
    }

    async fn commit_chunk(_pool: ConnectionPool, _processed_data: Vec<Self::ProcessedType>) {}
}