Versions in this module Expand all Collapse all v0 v0.0.1 Sep 6, 2021 Changes in this version + type CKBBlockChain struct + Ctx context.Context + ReqTryCfg *types.RetryConfig + RpcClient rpc.Client + func NewCKBBlockChain(ctx context.Context, nodeUrl string, reqTryCfg *types.RetryConfig) *CKBBlockChain + func NewCKBBlockChainWithRpcClient(ctx context.Context, rpcClient rpc.Client, reqTryCfg *types.RetryConfig) *CKBBlockChain + func (ckb *CKBBlockChain) Close() + func (ckb *CKBBlockChain) GetBlockInfoByNumber(blockNumber *big.Int) (*types.ScannerBlockInfo, error) + func (ckb *CKBBlockChain) GetLatestBlockNumber() (*big.Int, error) + func (ckb *CKBBlockChain) GetParentHash(childHash string) (string, error) + type CKBRocksDb struct + func NewCKBRocksDb(dataDir string, handler MsgHandler) *CKBRocksDb + func (ckb *CKBRocksDb) Close() error + func (ckb *CKBRocksDb) GetDbBlockByHash(blockHash string) (*types.Block, error) + func (ckb *CKBRocksDb) GetDbLastBlock() (*types.Block, error) + func (ckb *CKBRocksDb) HandleForkEvent(info *types.BlockForkInfo) error + func (ckb *CKBRocksDb) RecordBlock(block *types.Block, isUpdate, commitAfterOpt bool) error + func (ckb *CKBRocksDb) TransactionHandler(block *types.ScannerBlockInfo, dbTx interface{}, blockTxs interface{}) error + func (ckb *CKBRocksDb) TxClose() + func (ckb *CKBRocksDb) TxCommit() error + func (ckb *CKBRocksDb) TxOpen() (interface{}, error) + func (ckb *CKBRocksDb) TxRollBack() error + type MsgHandler struct + Close func() + Receive func(info *TxMsgData) error + type TxMsgData struct + BlockBaseInfo blockparserTypes.ScannerBlockInfo + Txs []*types.Transaction