sui_indexer::handlers::committer

Function start_tx_checkpoint_commit_task

Source
pub async fn start_tx_checkpoint_commit_task<S>(
    state: S,
    metrics: IndexerMetrics,
    tx_indexing_receiver: Receiver<CheckpointDataToCommit>,
    cancel: CancellationToken,
    next_checkpoint_sequence_number: CheckpointSequenceNumber,
    end_checkpoint_opt: Option<CheckpointSequenceNumber>,
) -> IndexerResult<()>
where S: IndexerStore + Clone + Sync + Send + 'static,