chain_index

Documentation

Index

• Constants
• type Chain
• type FilterTokenIndex
  • func NewFilterTokenIndex(cfg *config.Config, chainInstance Chain) (*FilterTokenIndex, error)
  • func (fti *FilterTokenIndex) GetBlockHashList(account *ledger.Account, originBlockHash *types.Hash, ...) ([]types.Hash, error)
  • func (fti *FilterTokenIndex) Start()
  • func (fti *FilterTokenIndex) Stop()

Constants

const (
	DBKP_BLOCK_LIST_BY_TOKEN = byte(1)

	DBKP_ACCOUNT_TOKEN_META = byte(2)

	DBKP_FILTER_TOKEN_CONSUME_ID = byte(3)

	DBKP_HEAD_HASH = byte(4)
)

const (
	STOP  = 1
	START = 2
)

Types

type Chain

type Chain interface {
	GetLatestBlockEventId() (uint64, error)

	GetEvent(eventId uint64) (byte, []types.Hash, error)
	GetAccountBlockByHash(blockHash *types.Hash) (*ledger.AccountBlock, error)

	GetAccount(address *types.Address) (*ledger.Account, error)
	IsAccountBlockExisted(hash types.Hash) (bool, error)
	ChainDb() *chain_db.ChainDb
	IsGenesisAccountBlock(block *ledger.AccountBlock) bool
}

type FilterTokenIndex

type FilterTokenIndex struct {
	EventNumPerBatch uint64
	// contains filtered or unexported fields
}

func NewFilterTokenIndex

func NewFilterTokenIndex(cfg *config.Config, chainInstance Chain) (*FilterTokenIndex, error)

func (*FilterTokenIndex) GetBlockHashList

func (fti *FilterTokenIndex) GetBlockHashList(account *ledger.Account, originBlockHash *types.Hash, tokenTypeId types.TokenTypeId, count uint64) ([]types.Hash, error)

func (*FilterTokenIndex) Start

func (fti *FilterTokenIndex) Start()

func (*FilterTokenIndex) Stop

func (fti *FilterTokenIndex) Stop()