cchainvm

Dec 12, 2025

Changes in this version

type VM

+ func (vm *VM) CrossChainRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32, warpErr *warp.Error) error

+ func (vm *VM) RequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, warpErr *warp.Error) error

Dec 11, 2025

Changes in this version

type LuxAPI

+ func (api *LuxAPI) SetHead(blockNumber uint64) (map[string]interface{}, error)

Dec 5, 2025

Changes in this version

+ type ImportAccountState struct

+ Balance string

+ Code string

+ CodeHash string

+ Nonce uint64

+ Storage map[string]string

type ImportBlockEntry

+ StateChanges map[string]*ImportAccountState

Dec 4, 2025

Changes in this version

type DatabaseType

+ func ParseDatabaseType(s string) DatabaseType

type UnifiedReplayer

+ func (r *UnifiedReplayer) ReplayBlocks() error

Dec 4, 2025

Changes in this version

+ func InitializeCChainWithReplay(blockchain *gethcore.BlockChain, db ethdb.Database) error

type DatabaseType

+ const Namespaced

+ const Standard

+ type ImportBlockEntry struct

+ Body string

+ Hash string

+ Header string

+ Height uint64

+ Receipts string

+ type ImportBlocksRequest struct

+ Blocks []ImportBlockEntry

+ type ImportBlocksResponse struct

+ Errors []string

+ Failed int

+ FirstHeight uint64

+ HeadBlockHash string

+ Imported int

+ LastHeight uint64

+ type ImportJSONBlocksResponse struct

+ Errors []string

+ Failed int

+ FirstHeight uint64

+ HeadBlockHash string

+ Imported int

+ LastHeight uint64

+ type JSONBlock struct

+ BaseFeePerGas string

+ BlockGasCost string

+ Difficulty string

+ ExtraData string

+ GasLimit string

+ GasUsed string

+ Hash string

+ LogsBloom string

+ Miner string

+ MixHash string

+ Nonce string

+ Number string

+ ParentHash string

+ ReceiptsRoot string

+ Sha3Uncles string

+ StateRoot string

+ Timestamp string

+ Transactions []JSONBlockTransaction

+ TransactionsRoot string

+ Uncles []string

+ type JSONBlockTransaction struct

+ AccessList json.RawMessage

+ BlockHash string

+ BlockNumber string

+ ChainId string

+ From string

+ Gas string

+ GasPrice string

+ Hash string

+ Input string

+ MaxFeePerGas string

+ MaxPriorityFee string

+ Nonce string

+ R string

+ S string

+ To string

+ TransactionIndex string

+ Type string

+ V string

+ Value string

type LuxAPI

+ func (api *LuxAPI) Mine() (map[string]interface{}, error)

+ type MigrateAPI struct

+ func NewMigrateAPI(vm *VM) *MigrateAPI

+ func (api *MigrateAPI) ImportBlocks(blocks []ImportBlockEntry) (*ImportBlocksResponse, error)

+ func (api *MigrateAPI) ImportJSONBlocks(blocks []json.RawMessage) (*ImportJSONBlocksResponse, error)

+ func (api *MigrateAPI) SetGenesis(req SetGenesisRequest) (*SetGenesisResponse, error)

+ type SetGenesisRequest struct

+ Body string

+ Hash string

+ Header string

+ Height uint64

+ Receipts string

+ type SetGenesisResponse struct

+ Error string

+ NewGenesisHash string

+ OldGenesisHash string

+ Success bool

Nov 28, 2025

Changes in this version

+ func StartRegenesis(ctx context.Context, onBlock func(uint64, common.Hash, *types.Header)) error

+ type DebugAPI struct

+ func NewDebugAPI(backend *MinimalEthBackend) *DebugAPI

+ func (api *DebugAPI) TraceBlock(ctx context.Context, blockRlp hexutil.Bytes) (interface{}, error)

+ func (api *DebugAPI) TraceBlockByHash(ctx context.Context, hash common.Hash) (interface{}, error)

+ func (api *DebugAPI) TraceBlockByNumber(ctx context.Context, number rpc.BlockNumber) (interface{}, error)

+ func (api *DebugAPI) TraceTransaction(ctx context.Context, txHash common.Hash) (interface{}, error)

type EthAPI

+ func (api *EthAPI) Accounts() []common.Address

+ func (api *EthAPI) Call(ctx context.Context, args TransactionArgs, blockNrOrHash rpc.BlockNumberOrHash) (hexutil.Bytes, error)

+ func (api *EthAPI) GetLogs(ctx context.Context, criteria map[string]interface{}) ([]*types.Log, error)

+ func (api *EthAPI) GetStorageAt(ctx context.Context, address common.Address, key string, ...) (hexutil.Bytes, error)

+ func (api *EthAPI) GetUncleCountByBlockHash(ctx context.Context, hash common.Hash) *hexutil.Uint

+ func (api *EthAPI) GetUncleCountByBlockNumber(ctx context.Context, number rpc.BlockNumber) *hexutil.Uint

+ func (api *EthAPI) Hashrate() hexutil.Uint64

+ func (api *EthAPI) Mining() bool

+ func (api *EthAPI) SendTransaction(ctx context.Context, args TransactionArgs) (common.Hash, error)

+ func (api *EthAPI) Sign(addr common.Address, data hexutil.Bytes) (hexutil.Bytes, error)

+ func (api *EthAPI) SignTransaction(args TransactionArgs) (hexutil.Bytes, error)

+ func (api *EthAPI) Syncing() (interface{}, error)

+ type FetchedBlock struct

+ Header *types.Header

+ Num uint64

+ Receipts types.Receipts

+ Txs types.Transactions

+ type RPCBlock struct

+ BaseFee *hexutil.Big

+ Bloom types.Bloom

+ Difficulty *hexutil.Big

+ ExtraData hexutil.Bytes

+ GasLimit hexutil.Uint64

+ GasUsed hexutil.Uint64

+ Hash common.Hash

+ Miner common.Address

+ MixHash common.Hash

+ Nonce types.BlockNonce

+ Number *hexutil.Big

+ ParentHash common.Hash

+ ReceiptRoot common.Hash

+ Root common.Hash

+ Size hexutil.Uint64

+ Timestamp hexutil.Uint64

+ Transactions []RPCTx

+ TxRoot common.Hash

+ Uncles []common.Hash

+ type RPCLog struct

+ Address common.Address

+ BlockHash common.Hash

+ BlockNumber hexutil.Uint64

+ Data hexutil.Bytes

+ LogIndex hexutil.Uint64

+ Removed bool

+ Topics []common.Hash

+ TransactionHash common.Hash

+ TransactionIndex hexutil.Uint64

+ type RPCReceipt struct

+ BlockHash common.Hash

+ BlockNumber *hexutil.Big

+ ContractAddress *common.Address

+ CumulativeGasUsed hexutil.Uint64

+ From common.Address

+ GasUsed hexutil.Uint64

+ Logs []RPCLog

+ LogsBloom types.Bloom

+ Status hexutil.Uint64

+ To *common.Address

+ TransactionHash common.Hash

+ TransactionIndex hexutil.Uint64

+ Type hexutil.Uint64

+ type RPCReplayProgress struct

+ LastHash common.Hash

+ LastImported uint64

+ Timestamp time.Time

+ type RPCReplayer struct

+ type RPCTx struct

+ AccessList []interface{}

+ ChainID *hexutil.Big

+ From common.Address

+ Gas hexutil.Uint64

+ GasPrice *hexutil.Big

+ Hash common.Hash

+ Input hexutil.Bytes

+ MaxFeePerGas *hexutil.Big

+ MaxPriorityFee *hexutil.Big

+ Nonce hexutil.Uint64

+ R *hexutil.Big

+ S *hexutil.Big

+ To *common.Address

+ TransactionIndex hexutil.Uint64

+ Type hexutil.Uint64

+ V *hexutil.Big

+ Value *hexutil.Big

+ type Regenesis struct

type ReplayConfig

+ BackoffMax time.Duration

+ BackoffMin time.Duration

+ Batch int

+ End uint64

+ FetchConcurrency int

+ HardStopOnMismatch bool

+ MaxRetries int

+ ResumePath string

+ Start uint64

+ URL string

+ VerifyRoots bool

+ VerifySigs bool

+ func DefaultReplayConfig(url string) ReplayConfig

+ type TxPoolAPI struct

+ func NewTxPoolAPI(backend *MinimalEthBackend) *TxPoolAPI

+ func (api *TxPoolAPI) Content() map[string]map[string]map[string]interface{}

+ func (api *TxPoolAPI) Inspect() map[string]map[string]map[string]string

+ func (api *TxPoolAPI) Status() map[string]hexutil.Uint

type VM

+ func (vm *VM) StartRPCReplay(ctx context.Context, cfg ReplayConfig) error

Nov 12, 2025

Changes in this version

+ var EVMNamespace = []byte

+ var UseNetNamespace = false

+ func LoadEVMDatabase(targetDB ethdb.Database) error

+ func NewNetNamespaceStripper(db ethdb.Database) ethdb.Database

type DatabaseFormat

+ const EVMFormat

type DatabaseReplayConfig

+ NetReplayBatch uint64

+ NetReplayEnabled bool

+ NetReplayEnd uint64

+ NetReplayResume bool

+ NetReplaySourceURL string

+ NetReplayStart uint64

type DatabaseWrapper

+ func (d *DatabaseWrapper) AncientBytes(kind string, id, offset, length uint64) ([]byte, error)

+ type EVMHeader struct

+ BaseFee *big.Int

+ BlockGasCost *big.Int

+ Bloom types.Bloom

+ Coinbase common.Address

+ Difficulty *big.Int

+ ExtDataHash common.Hash

+ Extra []byte

+ GasLimit uint64

+ GasUsed uint64

+ MixDigest common.Hash

+ Nonce types.BlockNonce

+ Number *big.Int

+ ParentHash common.Hash

+ ReceiptHash common.Hash

+ Root common.Hash

+ Time uint64

+ TxHash common.Hash

+ UncleHash common.Hash

+ WithdrawalsHash common.Hash

type MigratedDataAdapter

+ func (m *MigratedDataAdapter) AncientBytes(kind string, id, offset, length uint64) ([]byte, error)

+ type NetNamespaceStripper struct

+ func (s *NetNamespaceStripper) Ancient(kind string, number uint64) ([]byte, error)

+ func (s *NetNamespaceStripper) AncientBytes(kind string, id, offset, length uint64) ([]byte, error)

+ func (s *NetNamespaceStripper) AncientDatadir() (string, error)

+ func (s *NetNamespaceStripper) AncientRange(kind string, start, count, maxBytes uint64) ([][]byte, error)

+ func (s *NetNamespaceStripper) AncientSize(kind string) (uint64, error)

+ func (s *NetNamespaceStripper) Ancients() (uint64, error)

+ func (s *NetNamespaceStripper) Close() error

+ func (s *NetNamespaceStripper) Compact(start []byte, limit []byte) error

+ func (s *NetNamespaceStripper) Delete(key []byte) error

+ func (s *NetNamespaceStripper) DeleteRange(start, end []byte) error

+ func (s *NetNamespaceStripper) Get(key []byte) ([]byte, error)

+ func (s *NetNamespaceStripper) Has(key []byte) (bool, error)

+ func (s *NetNamespaceStripper) LoadLastBlock() (*types.Block, error)

+ func (s *NetNamespaceStripper) ModifyAncients(fn func(ethdb.AncientWriteOp) error) (int64, error)

+ func (s *NetNamespaceStripper) NewBatch() ethdb.Batch

+ func (s *NetNamespaceStripper) NewBatchWithSize(size int) ethdb.Batch

+ func (s *NetNamespaceStripper) NewIterator(prefix []byte, start []byte) ethdb.Iterator

+ func (s *NetNamespaceStripper) Put(key []byte, value []byte) error

+ func (s *NetNamespaceStripper) ReadAncients(fn func(ethdb.AncientReaderOp) error) error

+ func (s *NetNamespaceStripper) Stat() (string, error)

+ func (s *NetNamespaceStripper) SyncAncient() error

+ func (s *NetNamespaceStripper) SyncKeyValue() error

+ func (s *NetNamespaceStripper) Tail() (uint64, error)

+ func (s *NetNamespaceStripper) TruncateHead(n uint64) (uint64, error)

+ func (s *NetNamespaceStripper) TruncateTail(n uint64) (uint64, error)

type PebbleWithAncient

+ func (db *PebbleWithAncient) AncientBytes(kind string, id, offset, length uint64) ([]byte, error)

Oct 28, 2025

Changes in this version

+ var SubnetEVMNamespace = []byte

+ func NewPebbleWithAncient(db *pebble.Database) ethdb.Database

+ func OpenPebbleDB(path string) (database.Database, error)

type DatabaseReplayConfig

+ SubnetReplayBatch uint64

+ SubnetReplayEnabled bool

+ SubnetReplayEnd uint64

+ SubnetReplayResume bool

+ SubnetReplaySourceURL string

+ SubnetReplayStart uint64

type DatabaseWrapper

+ func (d *DatabaseWrapper) DB() database.Database

+ type LegacyHeader struct

+ BaseFee *big.Int

+ Bloom types.Bloom

+ Coinbase common.Address

+ Difficulty *big.Int

+ ExtData rlp.RawValue

+ Extra []byte

+ GasLimit uint64

+ GasUsed uint64

+ MixDigest common.Hash

+ Nonce types.BlockNonce

+ Number *big.Int

+ ParentHash common.Hash

+ ReceiptHash common.Hash

+ Root common.Hash

+ Time uint64

+ TxHash common.Hash

+ UncleHash common.Hash

type LuxAPI

+ func (api *LuxAPI) ReloadBlockchain() (map[string]interface{}, error)

+ func (api *LuxAPI) ReplayStart(req StartReplayRequest) (map[string]interface{}, error)

+ func (api *LuxAPI) VerifyBlockchain() (map[string]interface{}, error)

+ type PebbleWithAncient struct

+ func (db *PebbleWithAncient) Ancient(kind string, number uint64) ([]byte, error)

+ func (db *PebbleWithAncient) AncientBatch() ethdb.AncientWriteOp

+ func (db *PebbleWithAncient) AncientDatadir() (string, error)

+ func (db *PebbleWithAncient) AncientOffSet() uint64

+ func (db *PebbleWithAncient) AncientRange(kind string, start, count, maxBytes uint64) ([][]byte, error)

+ func (db *PebbleWithAncient) AncientSize(kind string) (uint64, error)

+ func (db *PebbleWithAncient) Ancients() (uint64, error)

+ func (db *PebbleWithAncient) HasAncient(kind string, number uint64) (bool, error)

+ func (db *PebbleWithAncient) ModifyAncients(fn func(ethdb.AncientWriteOp) error) (int64, error)

+ func (db *PebbleWithAncient) ReadAncients(fn func(ethdb.AncientReaderOp) error) error

+ func (db *PebbleWithAncient) Sync() error

+ func (db *PebbleWithAncient) SyncAncient() error

+ func (db *PebbleWithAncient) SyncKeyValue() error

+ func (db *PebbleWithAncient) Tail() (uint64, error)

+ func (db *PebbleWithAncient) TruncateHead(n uint64) (uint64, error)

+ func (db *PebbleWithAncient) TruncateTail(n uint64) (uint64, error)

+ type PreShanghaiHeader struct

+ BaseFee *big.Int

+ Bloom types.Bloom

+ Coinbase common.Address

+ Difficulty *big.Int

+ ExtDataHash []byte

+ Extra []byte

+ GasLimit uint64

+ GasUsed uint64

+ MixDigest common.Hash

+ Nonce types.BlockNonce

+ Number *big.Int

+ ParentHash common.Hash

+ ReceiptHash common.Hash

+ Root common.Hash

+ Time uint64

+ TxHash common.Hash

+ UncleHash common.Hash

+ func (h *PreShanghaiHeader) ToPostShanghai() *types.Header

type ReplayProgress

+ func (p *ReplayProgress) IsReplaying() bool

+ func (p *ReplayProgress) Update(blockCount uint64)

+ func (p *ReplayProgress) UpdatePhase(phase string)

+ type StartReplayRequest struct

+ BatchSize uint64

+ EndBlock uint64

+ SourcePath string

+ StartBlock uint64

type UnifiedReplayer

+ func NewUnifiedReplayerWithTrieDB(config *UnifiedReplayConfig, targetDB ethdb.Database, ...) (*UnifiedReplayer, error)

type VM

+ func (vm *VM) ForceBlockchainReload(targetHeight uint64, targetHash common.Hash) error

+ func (vm *VM) RecreateBackendAfterReplay(genesis *gethcore.Genesis) error

+ func (vm *VM) ReloadBlockchainState() error

+ func (vm *VM) RunReplay(config *DatabaseReplayConfig) error

+ func (vm *VM) VerifyBlockchainIntegrity() error

Oct 4, 2025

Changes in this version

type VM

+ func (vm *VM) InitializeWithReplay() error

Oct 4, 2025

Changes in this version

+ func NewSubnetNamespaceStripper(db ethdb.Database) ethdb.Database

+ type DatabaseBackend string

+ const AutoDetectBackend

+ const BadgerBackend

+ const PebbleBackend

+ type DatabaseIterator interface

+ Close func()

+ First func() bool

+ Key func() []byte

+ Next func() bool

+ Valid func() bool

+ Value func() []byte

+ type EVMReplayProgress struct

+ CurrentBlock uint64

+ FailedTxs uint64

+ LastLogTime time.Time

+ ProcessedTxs uint64

+ StartTime time.Time

+ StateVerifications uint64

+ TargetWalletBalance *uint256.Int

+ TotalBlocks uint64

+ type NamespaceStrippingBatch struct

+ func (b *NamespaceStrippingBatch) Delete(key []byte) error

+ func (b *NamespaceStrippingBatch) DeleteRange(start, end []byte) error

+ func (b *NamespaceStrippingBatch) Put(key []byte, value []byte) error

+ func (b *NamespaceStrippingBatch) Replay(w ethdb.KeyValueWriter) error

+ func (b *NamespaceStrippingBatch) Reset()

+ func (b *NamespaceStrippingBatch) ValueSize() int

+ func (b *NamespaceStrippingBatch) Write() error

+ type NamespaceStrippingIterator struct

+ func (i *NamespaceStrippingIterator) Error() error

+ func (i *NamespaceStrippingIterator) Key() []byte

+ func (i *NamespaceStrippingIterator) Next() bool

+ func (i *NamespaceStrippingIterator) Release()

+ func (i *NamespaceStrippingIterator) Value() []byte

+ type SourceDatabase interface

+ Close func() error

+ Get func(key []byte) ([]byte, io.Closer, error)

+ NewIterator func(prefix []byte, upperBound []byte) (DatabaseIterator, error)

+ type SubnetNamespaceStripper struct

+ func (s *SubnetNamespaceStripper) Ancient(kind string, number uint64) ([]byte, error)

+ func (s *SubnetNamespaceStripper) AncientDatadir() (string, error)

+ func (s *SubnetNamespaceStripper) AncientRange(kind string, start, count, maxBytes uint64) ([][]byte, error)

+ func (s *SubnetNamespaceStripper) AncientSize(kind string) (uint64, error)

+ func (s *SubnetNamespaceStripper) Ancients() (uint64, error)

+ func (s *SubnetNamespaceStripper) Close() error

+ func (s *SubnetNamespaceStripper) Compact(start []byte, limit []byte) error

+ func (s *SubnetNamespaceStripper) Delete(key []byte) error

+ func (s *SubnetNamespaceStripper) DeleteRange(start, end []byte) error

+ func (s *SubnetNamespaceStripper) Get(key []byte) ([]byte, error)

+ func (s *SubnetNamespaceStripper) Has(key []byte) (bool, error)

+ func (s *SubnetNamespaceStripper) LoadLastBlock() (*types.Block, error)

+ func (s *SubnetNamespaceStripper) ModifyAncients(fn func(ethdb.AncientWriteOp) error) (int64, error)

+ func (s *SubnetNamespaceStripper) NewBatch() ethdb.Batch

+ func (s *SubnetNamespaceStripper) NewBatchWithSize(size int) ethdb.Batch

+ func (s *SubnetNamespaceStripper) NewIterator(prefix []byte, start []byte) ethdb.Iterator

+ func (s *SubnetNamespaceStripper) Put(key []byte, value []byte) error

+ func (s *SubnetNamespaceStripper) ReadAncients(fn func(ethdb.AncientReaderOp) error) error

+ func (s *SubnetNamespaceStripper) Stat() (string, error)

+ func (s *SubnetNamespaceStripper) SyncAncient() error

+ func (s *SubnetNamespaceStripper) SyncKeyValue() error

+ func (s *SubnetNamespaceStripper) Tail() (uint64, error)

+ func (s *SubnetNamespaceStripper) TruncateHead(n uint64) (uint64, error)

+ func (s *SubnetNamespaceStripper) TruncateTail(n uint64) (uint64, error)

type UnifiedReplayConfig

+ ChainConfig *params.ChainConfig

+ DatabaseBackend DatabaseBackend

+ LogInterval uint64

+ ReplayTransactions bool

+ TargetHeight uint64

+ TargetWallet common.Address

+ VerifyStateRoots bool

type UnifiedReplayer

+ func (r *UnifiedReplayer) ReplayWithEVM() error

Sep 26, 2025

Changes in this version

type DatabaseReplayConfig

+ DatabaseType string

Sep 26, 2025

Changes in this version

type DatabaseReplayConfig

+ CopyAllState bool

Sep 26, 2025

Changes in this version

+ type LuxAPI struct

+ func NewLuxAPI(vm *VM) *LuxAPI

+ func (api *LuxAPI) ReplayStatus() map[string]interface{}

+ type ReplayProgress struct

+ func NewReplayProgress() *ReplayProgress

+ func (p *ReplayProgress) Complete()

+ func (p *ReplayProgress) Fail(err error)

+ func (p *ReplayProgress) GetStatus() map[string]interface{}

+ func (p *ReplayProgress) IncrementBlock() uint64

+ func (p *ReplayProgress) SetPhase(phase string)

+ func (p *ReplayProgress) Start(totalBlocks uint64)

+ func (p *ReplayProgress) UpdateBlock(blockNum uint64)

+ type ReplayState int32

+ const ReplayCompleted

+ const ReplayFailed

+ const ReplayInProgress

+ const ReplayNotStarted

type UnifiedReplayer

+ func (r *UnifiedReplayer) SetProgressTracker(progress *ReplayProgress)

Sep 24, 2025

Changes in this version

+ func TriggerRuntimeReplay(vm *VM) error

type Block

+ func (b *Block) EpochBit() bool

+ func (b *Block) FPCVotes() [][]byte

+ func (b *Block) ParentID() ids.ID

+ type MigratedDataAdapter struct

+ func NewMigratedDataAdapter(underlying ethdb.Database) *MigratedDataAdapter

+ func (m *MigratedDataAdapter) Ancient(kind string, number uint64) ([]byte, error)

+ func (m *MigratedDataAdapter) AncientDatadir() (string, error)

+ func (m *MigratedDataAdapter) AncientRange(kind string, start, count, maxBytes uint64) ([][]byte, error)

+ func (m *MigratedDataAdapter) AncientSize(kind string) (uint64, error)

+ func (m *MigratedDataAdapter) Ancients() (uint64, error)

+ func (m *MigratedDataAdapter) Close() error

+ func (m *MigratedDataAdapter) Compact(start []byte, limit []byte) error

+ func (m *MigratedDataAdapter) Delete(key []byte) error

+ func (m *MigratedDataAdapter) DeleteRange(start, end []byte) error

+ func (m *MigratedDataAdapter) Get(key []byte) ([]byte, error)

+ func (m *MigratedDataAdapter) Has(key []byte) (bool, error)

+ func (m *MigratedDataAdapter) ModifyAncients(fn func(ethdb.AncientWriteOp) error) (int64, error)

+ func (m *MigratedDataAdapter) NewBatch() ethdb.Batch

+ func (m *MigratedDataAdapter) NewBatchWithSize(size int) ethdb.Batch

+ func (m *MigratedDataAdapter) NewIterator(prefix []byte, start []byte) ethdb.Iterator

+ func (m *MigratedDataAdapter) Put(key []byte, value []byte) error

+ func (m *MigratedDataAdapter) ReadAncients(fn func(ethdb.AncientReaderOp) error) error

+ func (m *MigratedDataAdapter) Stat() (string, error)

+ func (m *MigratedDataAdapter) SyncAncient() error

+ func (m *MigratedDataAdapter) SyncKeyValue() error

+ func (m *MigratedDataAdapter) Tail() (uint64, error)

+ func (m *MigratedDataAdapter) TruncateHead(n uint64) (uint64, error)

+ func (m *MigratedDataAdapter) TruncateTail(n uint64) (uint64, error)

+ type RuntimeReplayManager struct

+ func NewRuntimeReplayManager(vm *VM) *RuntimeReplayManager

+ func (r *RuntimeReplayManager) DetectAndLoadMigratedData() error

Aug 6, 2025

Changes in this version

+ func VerifyChaindata(path string) error

+ type BlockReplayer struct

+ func NewBlockReplayer(config *ReplayConfig, blockchain *gethcore.BlockChain) (*BlockReplayer, error)

+ func (r *BlockReplayer) Close() error

+ func (r *BlockReplayer) Replay() error

+ type ReplayConfig struct

+ BatchSize uint64

+ EndBlock uint64

+ GenesisDB string

+ StartBlock uint64

type SubnetEVMHeader

+ AcceptedTime *big.Int

+ func (h *SubnetEVMHeader) ToGethHeader() *types.Header

Aug 12, 2025

Changes in this version

+ var UseSubnetNamespace = false

+ func LoadSubnetEVMDatabase(targetDB ethdb.Database) error

+ func NewBadgerDatabase(luxDB database.Database, config BadgerDatabaseConfig) (ethdb.Database, error)

+ func SlurpIntoAncient(sourceDB ethdb.Database, targetPath string, startBlock, endBlock uint64) error

+ func WrapDatabase(db database.Database) ethdb.Database

+ type BadgerDatabaseConfig struct

+ AncientDir string

+ DataDir string

+ EnableAncient bool

+ FreezeThreshold uint64

+ ReadOnly bool

+ SharedAncient bool

+ type BatchWrapper struct

+ func (b *BatchWrapper) Delete(key []byte) error

+ func (b *BatchWrapper) DeleteRange(start, end []byte) error

+ func (b *BatchWrapper) Put(key []byte, value []byte) error

+ func (b *BatchWrapper) Replay(w ethdb.KeyValueWriter) error

+ func (b *BatchWrapper) Reset()

+ func (b *BatchWrapper) ValueSize() int

+ func (b *BatchWrapper) Write() error

+ type Block struct

+ func (b *Block) Accept(ctx context.Context) error

+ func (b *Block) Bytes() []byte

+ func (b *Block) Height() uint64

+ func (b *Block) ID() ids.ID

+ func (b *Block) Parent() ids.ID

+ func (b *Block) Reject(ctx context.Context) error

+ func (b *Block) Status() choices.Status

+ func (b *Block) Timestamp() time.Time

+ func (b *Block) Verify(ctx context.Context) error

+ type DatabaseFormat int

+ const GethFormat

+ const SubnetEVMFormat

+ const UnknownFormat

+ type DatabaseReplayConfig struct

+ ExtractGenesisFromSource bool

+ SourcePath string

+ TestLimit uint64

+ type DatabaseType string

+ const AutoDetect

+ const NamespacedDB

+ const StandardDB

+ type DatabaseWrapper struct

+ func (d *DatabaseWrapper) Ancient(kind string, number uint64) ([]byte, error)

+ func (d *DatabaseWrapper) AncientDatadir() (string, error)

+ func (d *DatabaseWrapper) AncientRange(kind string, start, count, maxBytes uint64) ([][]byte, error)

+ func (d *DatabaseWrapper) AncientSize(kind string) (uint64, error)

+ func (d *DatabaseWrapper) Ancients() (uint64, error)

+ func (d *DatabaseWrapper) Close() error

+ func (d *DatabaseWrapper) Compact(start []byte, limit []byte) error

+ func (d *DatabaseWrapper) Delete(key []byte) error

+ func (d *DatabaseWrapper) DeleteRange(start, end []byte) error

+ func (d *DatabaseWrapper) Get(key []byte) ([]byte, error)

+ func (d *DatabaseWrapper) Has(key []byte) (bool, error)

+ func (d *DatabaseWrapper) MigrateTable(string, func([]byte) ([]byte, error)) error

+ func (d *DatabaseWrapper) ModifyAncients(fn func(ethdb.AncientWriteOp) error) (int64, error)

+ func (d *DatabaseWrapper) NewBatch() ethdb.Batch

+ func (d *DatabaseWrapper) NewBatchWithSize(size int) ethdb.Batch

+ func (d *DatabaseWrapper) NewIterator(prefix []byte, start []byte) ethdb.Iterator

+ func (d *DatabaseWrapper) Put(key []byte, value []byte) error

+ func (d *DatabaseWrapper) ReadAncients(fn func(ethdb.AncientReaderOp) error) (err error)

+ func (d *DatabaseWrapper) Stat() (string, error)

+ func (d *DatabaseWrapper) Sync() error

+ func (d *DatabaseWrapper) SyncAncient() error

+ func (d *DatabaseWrapper) SyncKeyValue() error

+ func (d *DatabaseWrapper) Tail() (uint64, error)

+ func (d *DatabaseWrapper) TruncateHead(n uint64) (uint64, error)

+ func (d *DatabaseWrapper) TruncateTail(n uint64) (uint64, error)

+ type EthAPI struct

+ func NewEthAPI(backend *MinimalEthBackend) *EthAPI

+ func (api *EthAPI) BlockNumber() (hexutil.Uint64, error)

+ func (api *EthAPI) ChainId() (*hexutil.Big, error)

+ func (api *EthAPI) EstimateGas(ctx context.Context, args TransactionArgs, ...) (hexutil.Uint64, error)

+ func (api *EthAPI) GasPrice(ctx context.Context) (*hexutil.Big, error)

+ func (api *EthAPI) GetBalance(ctx context.Context, address common.Address, ...) (*hexutil.Big, error)

+ func (api *EthAPI) GetBlockByHash(ctx context.Context, hash common.Hash, fullTx bool) (map[string]interface{}, error)

+ func (api *EthAPI) GetBlockByNumber(ctx context.Context, number rpc.BlockNumber, fullTx bool) (map[string]interface{}, error)

+ func (api *EthAPI) GetCode(ctx context.Context, address common.Address, ...) (hexutil.Bytes, error)

+ func (api *EthAPI) GetTransactionByHash(ctx context.Context, hash common.Hash) (*RPCTransaction, error)

+ func (api *EthAPI) GetTransactionCount(ctx context.Context, address common.Address, ...) (*hexutil.Uint64, error)

+ func (api *EthAPI) GetTransactionReceipt(ctx context.Context, hash common.Hash) (map[string]interface{}, error)

+ func (api *EthAPI) SendRawTransaction(ctx context.Context, input hexutil.Bytes) (common.Hash, error)

+ type Factory struct

+ func (f *Factory) New(log log.Logger) (interface{}, error)

+ type IteratorWrapper struct

+ func (i *IteratorWrapper) Error() error

+ func (i *IteratorWrapper) Key() []byte

+ func (i *IteratorWrapper) Next() bool

+ func (i *IteratorWrapper) Release()

+ func (i *IteratorWrapper) Value() []byte

+ type MinimalEthBackend struct

+ func NewMigratedBackend(db ethdb.Database, migratedHeight uint64) (*MinimalEthBackend, error)

+ func NewMinimalEthBackend(db ethdb.Database, config *ethconfig.Config, genesis *gethcore.Genesis) (*MinimalEthBackend, error)

+ func NewMinimalEthBackendForMigration(db ethdb.Database, config *ethconfig.Config, genesis *gethcore.Genesis, ...) (*MinimalEthBackend, error)

+ func (b *MinimalEthBackend) APIs() []rpc.API

+ func (b *MinimalEthBackend) BlockChain() *gethcore.BlockChain

+ func (b *MinimalEthBackend) ChainConfig() *params.ChainConfig

+ func (b *MinimalEthBackend) TxPool() *txpool.TxPool

+ type NetAPI struct

+ func (api *NetAPI) Listening() bool

+ func (api *NetAPI) PeerCount() hexutil.Uint

+ func (api *NetAPI) Version() string

+ type RPCTransaction struct

+ Accesses *types.AccessList

+ BlockHash *common.Hash

+ BlockNumber *hexutil.Big

+ ChainID *hexutil.Big

+ From common.Address

+ Gas hexutil.Uint64

+ GasFeeCap *hexutil.Big

+ GasPrice *hexutil.Big

+ GasTipCap *hexutil.Big

+ Hash common.Hash

+ Input hexutil.Bytes

+ Nonce hexutil.Uint64

+ R *hexutil.Big

+ S *hexutil.Big

+ To *common.Address

+ TransactionIndex *hexutil.Uint64

+ Type hexutil.Uint64

+ V *hexutil.Big

+ Value *hexutil.Big

+ type SubnetEVMHeader struct

+ BaseFee *big.Int

+ BlockGasCost *big.Int

+ Bloom types.Bloom

+ Coinbase common.Address

+ Difficulty *big.Int

+ ExtDataHash common.Hash

+ Extra []byte

+ GasLimit uint64

+ GasUsed uint64

+ MixDigest common.Hash

+ Nonce types.BlockNonce

+ Number *big.Int

+ ParentHash common.Hash

+ ReceiptHash common.Hash

+ Root common.Hash

+ Time uint64

+ TxHash common.Hash

+ UncleHash common.Hash

+ WithdrawalsHash common.Hash

+ type TransactionArgs struct

+ Data *hexutil.Bytes

+ From *common.Address

+ Gas *hexutil.Uint64

+ GasPrice *hexutil.Big

+ Input *hexutil.Bytes

+ Nonce *hexutil.Uint64

+ To *common.Address

+ Value *hexutil.Big

+ type UnifiedReplayConfig struct

+ BatchSize int

+ CopyAllState bool

+ DatabaseType DatabaseType

+ ExtractGenesisFromSource bool

+ MaxStateNodes uint64

+ Namespace []byte

+ ParallelWorkers int

+ SourcePath string

+ TestLimit uint64

+ TestMode bool

+ type UnifiedReplayer struct

+ func NewUnifiedReplayer(config *UnifiedReplayConfig, targetDB ethdb.Database, ...) (*UnifiedReplayer, error)

+ func (r *UnifiedReplayer) Close() error

+ func (r *UnifiedReplayer) ExtractGenesis() (*types.Block, error)

+ func (r *UnifiedReplayer) ParallelReplay() error

+ func (r *UnifiedReplayer) Run() error

+ type VM struct

+ func (vm *VM) AppGossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error

+ func (vm *VM) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error

+ func (vm *VM) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, ...) error

+ func (vm *VM) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ func (vm *VM) BuildBlock(ctx context.Context) (chain.Block, error)

+ func (vm *VM) Connected(ctx context.Context, nodeID ids.NodeID, version *version.Application) error

+ func (vm *VM) CreateHandlers(ctx context.Context) (map[string]http.Handler, error)

+ func (vm *VM) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error

+ func (vm *VM) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32, appErr *core.AppError) error

+ func (vm *VM) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ func (vm *VM) Disconnected(ctx context.Context, nodeID ids.NodeID) error

+ func (vm *VM) GetBlock(ctx context.Context, blkID ids.ID) (chain.Block, error)

+ func (vm *VM) GetBlockIDAtHeight(ctx context.Context, height uint64) (ids.ID, error)

+ func (vm *VM) HealthCheck(ctx context.Context) (interface{}, error)

+ func (vm *VM) Initialize(ctx context.Context, chainCtx *consensusNode.Context, db database.Database, ...) error

+ func (vm *VM) LastAccepted(ctx context.Context) (ids.ID, error)

+ func (vm *VM) NewHTTPHandler(ctx context.Context) (http.Handler, error)

+ func (vm *VM) ParseBlock(ctx context.Context, blockBytes []byte) (chain.Block, error)

+ func (vm *VM) SetPreference(ctx context.Context, blkID ids.ID) error

+ func (vm *VM) SetState(ctx context.Context, state consensusNode.State) error

+ func (vm *VM) Shutdown(ctx context.Context) error

+ func (vm *VM) Version(ctx context.Context) (string, error)

+ func (vm *VM) WaitForEvent(ctx context.Context) (core.Message, error)

+ type Web3API struct

+ func (api *Web3API) ClientVersion() string

+ func (api *Web3API) Sha3(input hexutil.Bytes) hexutil.Bytes