blockdao

Documentation

Index

• type BlockDAO
  • func NewBlockDAO(indexers []BlockIndexer, cfg db.Config, deser *block.Deserializer) BlockDAO
  • func NewBlockDAOInMemForTest(indexers []BlockIndexer) BlockDAO
• type BlockIndexer
• type BlockIndexerChecker
  • func NewBlockIndexerChecker(dao BlockDAO) *BlockIndexerChecker
  • func (bic *BlockIndexerChecker) CheckIndexer(ctx context.Context, indexer BlockIndexer, targetHeight uint64, ...) error

Types

type BlockDAO

type BlockDAO interface {
	filedao.FileDAO
	GetActionByActionHash(hash.Hash256, uint64) (action.SealedEnvelope, uint32, error)
	GetReceiptByActionHash(hash.Hash256, uint64) (*action.Receipt, error)
	DeleteBlockToTarget(uint64) error
}

BlockDAO represents the block data access object

func NewBlockDAO

func NewBlockDAO(indexers []BlockIndexer, cfg db.Config, deser *block.Deserializer) BlockDAO

NewBlockDAO instantiates a block DAO

func NewBlockDAOInMemForTest

func NewBlockDAOInMemForTest(indexers []BlockIndexer) BlockDAO

NewBlockDAOInMemForTest creates a in-memory block DAO for testing

type BlockIndexer

type BlockIndexer interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Height() (uint64, error)
	PutBlock(context.Context, *block.Block) error
	DeleteTipBlock(context.Context, *block.Block) error
}

BlockIndexer defines an interface to accept block to build index

type BlockIndexerChecker

type BlockIndexerChecker struct {
	// contains filtered or unexported fields
}

BlockIndexerChecker defines a checker of block indexer

func NewBlockIndexerChecker

func NewBlockIndexerChecker(dao BlockDAO) *BlockIndexerChecker

NewBlockIndexerChecker creates a new block indexer checker

func (*BlockIndexerChecker) CheckIndexer

func (bic *BlockIndexerChecker) CheckIndexer(ctx context.Context, indexer BlockIndexer, targetHeight uint64, progressReporter func(uint64)) error

CheckIndexer checks a block indexer against block dao