Versions in this module Expand all Collapse all v1 v1.0.0 Aug 4, 2023 Changes in this version + type Writer struct + func NewWriter(config *utils.Config, dbPool *db.DBPool) (writer *Writer, err error) + func (w *Writer) PrepareBlockInfo(blockNum int64, blockHash string, blockRoot string) *pb.BlockInfo + func (w *Writer) Recovery() error + func (w *Writer) WriteBlockHeaderToDB(info *pb.BlockInfo, batchs []db.BatchWithID) (err error) + func (w *Writer) WriteBlockHeaderToKafka() (err error) + func (w *Writer) WriteBlockHeaderToS3(info *pb.BlockInfo, batchs []db.BatchWithID) (err error) + func (w *Writer) WriteBlockToDB(batchs []db.BatchWithID) (err error) + func (w *Writer) WriteBlockToS3(info *pb.BlockInfo, batchs []db.BatchWithID) (err error)