Documentation ¶
Index ¶
- type Writer
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Writer ¶
Writer represents a writer that appends db's write batch to the wal and broadcasts to the reader by message queue.
func (*Writer) PrepareBlockInfo ¶
func (*Writer) WriteBlockHeaderToDB ¶
func (*Writer) WriteBlockHeaderToKafka ¶
func (*Writer) WriteBlockHeaderToS3 ¶
func (*Writer) WriteBlockToDB ¶
func (w *Writer) WriteBlockToDB(batchs []db.BatchWithID) (err error)
func (*Writer) WriteBlockToS3 ¶
Click to show internal directories.
Click to hide internal directories.