cchainvm

package
v1.22.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2025 License: BSD-3-Clause Imports: 52 Imported by: 0

Documentation

Overview

Database key format helpers for both EVM and geth formats

Index

Constants

View Source 
const (
	// BadgerBackend uses Badger database
	BadgerBackend = "badger"
	// PebbleBackend uses Pebble database
	PebbleBackend = "pebble"
	// AutoDetectBackend automatically detects backend
	AutoDetectBackend = "auto"
)

Database backend types

Variables

View Source 
var EVMNamespace = []byte{
	0x33, 0x7f, 0xb7, 0x3f, 0x9b, 0xcd, 0xac, 0x8c,
	0x31, 0xa2, 0xd5, 0xf7, 0xb8, 0x77, 0xab, 0x1e,
	0x8a, 0x2b, 0x7f, 0x2a, 0x1e, 0x9b, 0xf0, 0x2a,
	0x0a, 0x0e, 0x6c, 0x6f, 0xd1, 0x64, 0xf1, 0xd1,
}

EVM namespace for LUX mainnet (blockchain ID 4aYc2FXx...)

View Source 
var UseNetNamespace = false

Flag to enable net namespace handling (set when using --genesis-db)

Functions

func InitializeCChainWithReplay added in v1.20.6 

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

InitializeCChainWithReplay imports blocks from migrated database using runtime replay NOTE: This assumes genesis has already been properly initialized via SetupGenesisBlock

func LoadEVMDatabase added in v1.20.3 

func LoadEVMDatabase(targetDB ethdb.Database) error

LoadEVMDatabase is DEPRECATED - we now use the migrated BadgerDB directly The migrated data is at /home/z/.luxd/chainData/C/db/badgerdb/ethdb

func NewBadgerDatabase 

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

NewBadgerDatabase creates a new BadgerDB with optional ancient store support

func NewNetNamespaceStripper added in v1.20.3 

func NewNetNamespaceStripper(db ethdb.Database) ethdb.Database

NewNetNamespaceStripper creates a new namespace stripping wrapper

func NewPebbleWithAncient added in v1.20.0 

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

NewPebbleWithAncient wraps a PebbleDB database with Ancient store stubs

func OpenPebbleDB added in v1.20.0 

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

OpenPebbleDB opens a PebbleDB database at the given path

func SlurpIntoAncient 

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

SlurpIntoAncient imports all historical data into the ancient store

func TriggerRuntimeReplay added in v1.17.2 

func TriggerRuntimeReplay(vm *VM) error

TriggerRuntimeReplay is the main entry point to trigger replay at runtime

func WrapDatabase 

func WrapDatabase(db database.Database) ethdb.Database

WrapDatabase creates a new database wrapper

Types

type BadgerDatabaseConfig 

type BadgerDatabaseConfig struct {
	DataDir         string
	EnableAncient   bool
	AncientDir      string
	ReadOnly        bool
	SharedAncient   bool
	FreezeThreshold uint64 // Blocks to keep in main DB before freezing
}

BadgerDatabaseConfig holds configuration for BadgerDB with ancient store

type BatchWrapper 

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

BatchWrapper wraps a Lux batch to implement ethdb.Batch

func (*BatchWrapper) Delete 

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

Delete removes the key from the batch

func (*BatchWrapper) DeleteRange 

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

DeleteRange removes the key range from the batch

func (*BatchWrapper) Put 

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

Put inserts the given value into the batch

func (*BatchWrapper) Replay 

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

Replay replays the batch contents to the given writer

func (*BatchWrapper) Reset 

func (b *BatchWrapper) Reset()

Reset resets the batch for reuse

func (*BatchWrapper) ValueSize 

func (b *BatchWrapper) ValueSize() int

ValueSize retrieves the amount of data queued up for writing

func (*BatchWrapper) Write 

func (b *BatchWrapper) Write() error

Write flushes any accumulated data to disk

type Block 

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

Block wraps an Ethereum block to implement the chain.Block interface

func (*Block) Accept 

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

Accept implements the chain.Block interface

func (*Block) Bytes 

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

Bytes implements the chain.Block interface

func (*Block) EpochBit added in v1.17.2 

func (b *Block) EpochBit() bool

EpochBit implements the chain.Block interface Returns the epoch fence bit for FPC

func (*Block) FPCVotes added in v1.17.2 

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

FPCVotes implements the chain.Block interface Returns embedded fast-path consensus vote references

func (*Block) Height 

func (b *Block) Height() uint64

Height implements the chain.Block interface

func (*Block) ID 

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

ID implements the chain.Block interface

func (*Block) Parent 

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

Parent implements the chain.Block interface

func (*Block) ParentID added in v1.17.2 

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

ParentID implements the chain.Block interface (alias for Parent)

func (*Block) Reject 

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

Reject implements the chain.Block interface

func (*Block) Status 

func (b *Block) Status() uint8

Status implements the chain.Block interface

func (*Block) Timestamp 

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

Timestamp implements the chain.Block interface

func (*Block) Verify 

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

Verify implements the chain.Block interface

type DatabaseBackend added in v1.18.26 

type DatabaseBackend = string

DatabaseBackend type alias for backend selection

type DatabaseFormat 

type DatabaseFormat int

DatabaseFormat represents the database format type 

const (
	UnknownFormat DatabaseFormat = iota
	EVMFormat
	GethFormat
)

type DatabaseReplayConfig 

type DatabaseReplayConfig struct {
	SourcePath               string `json:"source-path"`                 // Path to source database
	DatabaseType             string `json:"database-type,omitempty"`     // Type: "auto", "namespaced", or "standard"
	TestLimit                uint64 `json:"test-limit"`                  // If > 0, limit replay to this many blocks
	ExtractGenesisFromSource bool   `json:"extract-genesis-from-source"` // If true, extract genesis from block 0 of source
	CopyAllState             bool   `json:"copy-all-state"`              // If true, copy all state trie data

	// Net-EVM replay configuration
	NetReplayEnabled   bool   `json:"subnet-replay-enabled"`    // Enable replay from Net-EVM via RPC
	NetReplaySourceURL string `json:"subnet-replay-source-url"` // RPC URL e.g. http://127.0.0.1:9630/ext/bc/<chainID>/rpc
	NetReplayStart     uint64 `json:"subnet-replay-start"`      // Start block (default 0)
	NetReplayEnd       uint64 `json:"subnet-replay-end"`        // End block (0 = tip)
	NetReplayBatch     uint64 `json:"subnet-replay-batch"`      // Batch size (default 1000)
	NetReplayResume    bool   `json:"subnet-replay-resume"`     // Resume from checkpoint (default true)
}

DatabaseReplayConfig holds configuration for database replay

type DatabaseType 

type DatabaseType string

DatabaseType represents database format type 

const (
	// AutoDetect automatically detects database type
	AutoDetect DatabaseType = "auto"
	// Namespaced uses namespace-prefixed database
	Namespaced DatabaseType = "namespaced"
	// Standard uses standard database format
	Standard DatabaseType = "standard"
	// StandardDB is an alias for Standard
	StandardDB DatabaseType = "standard"
	// NamespacedDB is an alias for Namespaced
	NamespacedDB DatabaseType = "namespaced"
)

type DatabaseWrapper 

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

DatabaseWrapper wraps a Lux database to implement ethdb.Database

func (*DatabaseWrapper) Ancient 

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

Ancient retrieves an ancient binary blob from the append-only immutable files

func (*DatabaseWrapper) AncientBytes added in v1.20.3 

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

AncientBytes retrieves the value segment of the element specified by the id and value offsets

func (*DatabaseWrapper) AncientDatadir 

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

AncientDatadir returns the ancient datadir

func (*DatabaseWrapper) AncientRange 

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

AncientRange retrieves multiple items in sequence

func (*DatabaseWrapper) AncientSize 

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

AncientSize returns the ancient size of the specified category

func (*DatabaseWrapper) Ancients 

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

Ancients returns the ancient item numbers in the ancient store

func (*DatabaseWrapper) Close 

func (d *DatabaseWrapper) Close() error

Close closes the database

func (*DatabaseWrapper) Compact 

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

Compact flattens the underlying data store for the given key range

func (*DatabaseWrapper) DB added in v1.20.0 

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

DB returns the underlying database for unwrapping

func (*DatabaseWrapper) Delete 

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

Delete removes the key from the key-value data store

func (*DatabaseWrapper) DeleteRange 

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

DeleteRange removes all entries between the given markers

func (*DatabaseWrapper) Get 

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

Get retrieves the given key if it's present in the key-value data store

func (*DatabaseWrapper) Has 

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

Has retrieves if a key is present in the key-value data store

func (*DatabaseWrapper) MigrateTable 

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

MigrateTable processes and migrates entries of a given table to a new format

func (*DatabaseWrapper) ModifyAncients 

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

ModifyAncients runs a write operation on the ancient store

func (*DatabaseWrapper) NewBatch 

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

NewBatch creates a write-only database that buffers changes to its host db

func (*DatabaseWrapper) NewBatchWithSize 

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

NewBatchWithSize creates a write-only database batch with a specified size

func (*DatabaseWrapper) NewIterator 

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

NewIterator creates a binary-alphabetical iterator over a subset

func (*DatabaseWrapper) Put 

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

Put inserts the given value into the key-value data store

func (*DatabaseWrapper) ReadAncients 

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

ReadAncients applies the provided AncientReader function

func (*DatabaseWrapper) Stat 

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

Stat returns a particular internal stat of the database

func (*DatabaseWrapper) Sync 

func (d *DatabaseWrapper) Sync() error

Sync flushes the database to disk

func (*DatabaseWrapper) SyncAncient 

func (d *DatabaseWrapper) SyncAncient() error

SyncAncient syncs the ancient data directory

func (*DatabaseWrapper) SyncKeyValue 

func (d *DatabaseWrapper) SyncKeyValue() error

SyncKeyValue ensures that all pending writes are flushed to disk

func (*DatabaseWrapper) Tail 

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

Tail returns the number of first stored item in the freezer

func (*DatabaseWrapper) TruncateHead 

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

TruncateHead discards all but the first n ancient data from the ancient store

func (*DatabaseWrapper) TruncateTail 

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

TruncateTail discards the first n ancient data from the ancient store

type DebugAPI added in v1.20.5 

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

DebugAPI provides debug RPC API

func NewDebugAPI added in v1.20.5 

func NewDebugAPI(backend *MinimalEthBackend) *DebugAPI

NewDebugAPI creates a new Debug RPC API

func (*DebugAPI) TraceBlock added in v1.20.5 

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

TraceBlock returns traces for all transactions in a block

func (*DebugAPI) TraceBlockByHash added in v1.20.5 

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

TraceBlockByHash returns traces for all transactions in a block by hash

func (*DebugAPI) TraceBlockByNumber added in v1.20.5 

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

TraceBlockByNumber returns traces for all transactions in a block by number

func (*DebugAPI) TraceTransaction added in v1.20.5 

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

TraceTransaction returns the trace of a transaction

type EthAPI 

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

EthAPI provides an Ethereum RPC API

func NewEthAPI 

func NewEthAPI(backend *MinimalEthBackend) *EthAPI

NewEthAPI creates a new Ethereum RPC API

func (*EthAPI) Accounts added in v1.20.5 

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

Accounts returns the list of accounts owned by the client

func (*EthAPI) BlockNumber 

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

BlockNumber returns the current block number If historical blocks are available, returns the highest available block number

func (*EthAPI) Call added in v1.20.5 

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

Call executes a message call immediately without creating a transaction

func (*EthAPI) ChainId 

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

ChainId returns the chain ID

func (*EthAPI) EstimateGas 

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

EstimateGas estimates the gas needed for a transaction

func (*EthAPI) GasPrice 

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

GasPrice returns the current gas price

func (*EthAPI) GetBalance 

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

GetBalance returns the balance of an account

func (*EthAPI) GetBlockByHash 

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

GetBlockByHash returns the block for the given block hash Checks both canonical chain and historical blocks database

func (*EthAPI) GetBlockByNumber 

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

GetBlockByNumber returns the block for the given block number Checks both canonical chain and historical blocks database

func (*EthAPI) GetCode 

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

GetCode returns the code of a contract

func (*EthAPI) GetLogs added in v1.20.5 

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

GetLogs returns logs matching the filter criteria

func (*EthAPI) GetStorageAt added in v1.20.5 

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

GetStorageAt returns the value from a storage position at a given address

func (*EthAPI) GetTransactionByHash 

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

GetTransactionByHash returns a transaction by hash

func (*EthAPI) GetTransactionCount 

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

GetTransactionCount returns the nonce of an account

func (*EthAPI) GetTransactionReceipt 

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

GetTransactionReceipt returns the receipt of a transaction

func (*EthAPI) GetUncleCountByBlockHash added in v1.20.5 

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

GetUncleCountByBlockHash returns the number of uncles in a block by hash

func (*EthAPI) GetUncleCountByBlockNumber added in v1.20.5 

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

GetUncleCountByBlockNumber returns the number of uncles in a block by number

func (*EthAPI) Hashrate added in v1.20.5 

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

Hashrate returns the client's hashrate

func (*EthAPI) Mining added in v1.20.5 

func (api *EthAPI) Mining() bool

Mining returns whether the client is actively mining

func (*EthAPI) SendRawTransaction 

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

SendRawTransaction sends a raw transaction

func (*EthAPI) SendTransaction added in v1.20.5 

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

SendTransaction sends a transaction (creates and signs if needed)

func (*EthAPI) Sign added in v1.20.5 

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

Sign signs data with the given account

func (*EthAPI) SignTransaction added in v1.20.5 

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

SignTransaction signs a transaction

func (*EthAPI) Syncing added in v1.20.5 

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

Syncing returns the syncing status

type Factory 

type Factory struct{}

Factory creates new instances of the C-Chain VM

func (*Factory) New 

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

New creates a new C-Chain VM instance

type FetchedBlock added in v1.20.5 

type FetchedBlock struct {
	Num      uint64
	Header   *types.Header
	Txs      types.Transactions
	Receipts types.Receipts
}

FetchedBlock contains block data from RPC

type ImportAccountState added in v1.21.4 

type ImportAccountState struct {
	Balance  string            `json:"balance"`
	Nonce    uint64            `json:"nonce"`
	Code     string            `json:"code,omitempty"`
	Storage  map[string]string `json:"storage,omitempty"`
	CodeHash string            `json:"codeHash,omitempty"`
}

ImportAccountState represents account state to import

type ImportBlockEntry added in v1.20.6 

type ImportBlockEntry struct {
	Height       uint64                         `json:"height"`
	Hash         string                         `json:"hash"`
	Header       string                         `json:"header"`
	Body         string                         `json:"body"`
	Receipts     string                         `json:"receipts"`
	StateChanges map[string]*ImportAccountState `json:"stateChanges,omitempty"`
}

ImportBlockEntry represents a single block to import

type ImportBlocksRequest added in v1.20.6 

type ImportBlocksRequest struct {
	Blocks []ImportBlockEntry `json:"blocks"`
}

ImportBlocksRequest represents the request for importing blocks

type ImportBlocksResponse added in v1.20.6 

type ImportBlocksResponse struct {
	Imported      int      `json:"imported"`
	Failed        int      `json:"failed"`
	FirstHeight   uint64   `json:"firstHeight"`
	LastHeight    uint64   `json:"lastHeight"`
	Errors        []string `json:"errors,omitempty"`
	HeadBlockHash string   `json:"headBlockHash"`
}

ImportBlocksResponse represents the response from importing blocks

type ImportJSONBlocksResponse added in v1.20.6 

type ImportJSONBlocksResponse struct {
	Imported      int      `json:"imported"`
	Failed        int      `json:"failed"`
	FirstHeight   uint64   `json:"firstHeight"`
	LastHeight    uint64   `json:"lastHeight"`
	Errors        []string `json:"errors,omitempty"`
	HeadBlockHash string   `json:"headBlockHash"`
}

ImportJSONBlocksResponse represents the response from importing JSON blocks

type IteratorWrapper 

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

IteratorWrapper wraps a Lux iterator to implement ethdb.Iterator

func (*IteratorWrapper) Error 

func (i *IteratorWrapper) Error() error

Error returns any accumulated error

func (*IteratorWrapper) Key 

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

Key returns the key of the current key/value pair

func (*IteratorWrapper) Next 

func (i *IteratorWrapper) Next() bool

Next moves the iterator to the next key/value pair

func (*IteratorWrapper) Release 

func (i *IteratorWrapper) Release()

Release releases associated resources

func (*IteratorWrapper) Value 

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

Value returns the value of the current key/value pair

type JSONBlock added in v1.20.6 

type JSONBlock struct {
	BaseFeePerGas    string                 `json:"baseFeePerGas,omitempty"`
	BlockGasCost     string                 `json:"blockGasCost,omitempty"`
	Difficulty       string                 `json:"difficulty"`
	ExtraData        string                 `json:"extraData"`
	GasLimit         string                 `json:"gasLimit"`
	GasUsed          string                 `json:"gasUsed"`
	Hash             string                 `json:"hash"`
	LogsBloom        string                 `json:"logsBloom"`
	Miner            string                 `json:"miner"`
	MixHash          string                 `json:"mixHash"`
	Nonce            string                 `json:"nonce"`
	Number           string                 `json:"number"`
	ParentHash       string                 `json:"parentHash"`
	ReceiptsRoot     string                 `json:"receiptsRoot"`
	Sha3Uncles       string                 `json:"sha3Uncles"`
	StateRoot        string                 `json:"stateRoot"`
	Timestamp        string                 `json:"timestamp"`
	TransactionsRoot string                 `json:"transactionsRoot"`
	Transactions     []JSONBlockTransaction `json:"transactions"`
	Uncles           []string               `json:"uncles"`
}

JSONBlock represents a block in JSON-RPC format (eth_getBlockByNumber response)

type JSONBlockTransaction added in v1.20.6 

type JSONBlockTransaction struct {
	BlockHash        string `json:"blockHash"`
	BlockNumber      string `json:"blockNumber"`
	From             string `json:"from"`
	Gas              string `json:"gas"`
	GasPrice         string `json:"gasPrice"`
	MaxFeePerGas     string `json:"maxFeePerGas,omitempty"`
	MaxPriorityFee   string `json:"maxPriorityFeePerGas,omitempty"`
	Hash             string `json:"hash"`
	Input            string `json:"input"`
	Nonce            string `json:"nonce"`
	To               string `json:"to"`
	TransactionIndex string `json:"transactionIndex"`
	Value            string `json:"value"`
	Type             string `json:"type,omitempty"`
	ChainId          string `json:"chainId,omitempty"`
	V                string `json:"v"`
	R                string `json:"r"`
	S                string `json:"s"`
	// Access list for EIP-2930/EIP-1559 transactions
	AccessList json.RawMessage `json:"accessList,omitempty"`
}

JSONBlockTransaction represents a transaction in JSON-RPC format

type LegacyHeader added in v1.20.0 

type LegacyHeader struct {
	ParentHash  common.Hash      `json:"parentHash"`
	UncleHash   common.Hash      `json:"sha3Uncles"`
	Coinbase    common.Address   `json:"miner"`
	Root        common.Hash      `json:"stateRoot"`
	TxHash      common.Hash      `json:"transactionsRoot"`
	ReceiptHash common.Hash      `json:"receiptsRoot"`
	Bloom       types.Bloom      `json:"logsBloom"`
	Difficulty  *big.Int         `json:"difficulty"`
	Number      *big.Int         `json:"number"`
	GasLimit    uint64           `json:"gasLimit"`
	GasUsed     uint64           `json:"gasUsed"`
	Time        uint64           `json:"timestamp"`
	Extra       []byte           `json:"extraData"`
	MixDigest   common.Hash      `json:"mixHash"`
	Nonce       types.BlockNonce `json:"nonce"`
	BaseFee     *big.Int         `json:"baseFeePerGas" rlp:"optional"`
	ExtData     rlp.RawValue     `rlp:"tail"` // Capture any extra EVM fields
}

LegacyHeader represents the EVM header format without newer fields

type LuxAPI added in v1.18.2 

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

LuxAPI provides Lux-specific RPC API

func NewLuxAPI added in v1.18.2 

func NewLuxAPI(vm *VM) *LuxAPI

NewLuxAPI creates a new Lux RPC API

func (*LuxAPI) Mine added in v1.20.6 

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

Mine manually triggers block building and acceptance for dev mode This is useful when the consensus engine isn't running to auto-mine Accessible as lux_mine

func (*LuxAPI) ReloadBlockchain added in v1.20.0 

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

ReloadBlockchain forces the blockchain to reload and recognize database changes This is useful after replay or direct database modifications

func (*LuxAPI) ReplayStart added in v1.20.0 

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

ReplayStart starts the database replay process from the specified source This is the lux_replayStart RPC method

func (*LuxAPI) ReplayStatus added in v1.18.2 

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

ReplayStatus returns the status of database replay

func (*LuxAPI) SetHead added in v1.21.25 

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

SetHead forces the blockchain to set its head to a specific block number This is useful after importing blocks via migrate_importBlocks Accessible as lux_setHead

func (*LuxAPI) VerifyBlockchain added in v1.20.0 

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

VerifyBlockchain checks the integrity of the blockchain

type MigrateAPI added in v1.20.6 

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

MigrateAPI provides migration RPC API for block import operations

func NewMigrateAPI added in v1.20.6 

func NewMigrateAPI(vm *VM) *MigrateAPI

NewMigrateAPI creates a new Migrate RPC API

func (*MigrateAPI) ImportBlocks added in v1.20.6 

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

ImportBlocks imports an array of blocks into the C-Chain database Each block should have header, body, and receipts as RLP hex-encoded data This is the migrate_importBlocks RPC method Note: Accepts array directly (not wrapped in struct) for CLI compatibility

func (*MigrateAPI) ImportJSONBlocks added in v1.20.6 

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

ImportJSONBlocks imports an array of blocks in JSON-RPC format into the C-Chain database This accepts the raw output from eth_getBlockByNumber and converts to RLP internally This is the migrate_importJSONBlocks RPC method

func (*MigrateAPI) SetGenesis added in v1.20.6 

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

SetGenesis sets the genesis block from imported data and reloads the blockchain This should be called BEFORE importing other blocks to ensure the chain is consistent This is the migrate_setGenesis RPC method

type MigratedDataAdapter added in v1.17.2 

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

MigratedDataAdapter wraps a BadgerDB with migrated data and converts it to geth format

func NewMigratedDataAdapter added in v1.17.2 

func NewMigratedDataAdapter(underlying ethdb.Database) *MigratedDataAdapter

NewMigratedDataAdapter creates an adapter for migrated blockchain data

func (*MigratedDataAdapter) Ancient added in v1.17.2 

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

Ancient retrieves an ancient binary blob from the append-only immutable files.

func (*MigratedDataAdapter) AncientBytes added in v1.20.3 

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

AncientBytes retrieves the value segment of the element specified by the id and value offsets.

func (*MigratedDataAdapter) AncientDatadir added in v1.17.2 

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

AncientDatadir returns the path of the ancient store directory.

func (*MigratedDataAdapter) AncientRange added in v1.17.2 

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

AncientRange retrieves multiple items in sequence, starting from the index 'start'.

func (*MigratedDataAdapter) AncientSize added in v1.17.2 

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

AncientSize returns the ancient size of the specified category.

func (*MigratedDataAdapter) Ancients added in v1.17.2 

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

Ancients returns the ancient item numbers in the ancient store.

func (*MigratedDataAdapter) Close added in v1.17.2 

func (m *MigratedDataAdapter) Close() error

Close closes the database

func (*MigratedDataAdapter) Compact added in v1.17.2 

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

Compact compacts the database

func (*MigratedDataAdapter) Delete added in v1.17.2 

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

Delete removes a key

func (*MigratedDataAdapter) DeleteRange added in v1.17.2 

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

DeleteRange deletes all of the keys (and values) in the range [start,end)

func (*MigratedDataAdapter) Get added in v1.17.2 

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

Get retrieves a value, converting migrated format to geth format

func (*MigratedDataAdapter) Has added in v1.17.2 

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

Has checks if a key exists, converting migrated format to geth format

func (*MigratedDataAdapter) ModifyAncients added in v1.17.2 

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

ModifyAncients runs a write operation on the ancient store.

func (*MigratedDataAdapter) NewBatch added in v1.17.2 

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

NewBatch creates a new batch

func (*MigratedDataAdapter) NewBatchWithSize added in v1.17.2 

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

NewBatchWithSize creates a write-only database batch with pre-allocated buffer

func (*MigratedDataAdapter) NewIterator added in v1.17.2 

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

NewIterator creates a new iterator

func (*MigratedDataAdapter) Put added in v1.17.2 

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

Put stores a value

func (*MigratedDataAdapter) ReadAncients added in v1.17.2 

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

ReadAncients runs the given read operation while ensuring that no writes take place on the underlying ancient store.

func (*MigratedDataAdapter) Stat added in v1.17.2 

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

Stat returns database statistics

func (*MigratedDataAdapter) SyncAncient added in v1.17.2 

func (m *MigratedDataAdapter) SyncAncient() error

SyncAncient flushes all in-memory ancient store data to disk.

func (*MigratedDataAdapter) SyncKeyValue added in v1.17.2 

func (m *MigratedDataAdapter) SyncKeyValue() error

SyncKeyValue ensures that all pending writes are flushed to disk

func (*MigratedDataAdapter) Tail added in v1.17.2 

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

Tail returns the number of first stored item in the ancient store.

func (*MigratedDataAdapter) TruncateHead added in v1.17.2 

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

TruncateHead discards all but the first n ancient data from the ancient store.

func (*MigratedDataAdapter) TruncateTail added in v1.17.2 

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

TruncateTail discards the first n ancient data from the ancient store.

type MinimalEthBackend 

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

MinimalEthBackend provides a minimal Ethereum backend without p2p networking

func NewMigratedBackend 

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

NewMigratedBackend creates a special backend for fully migrated data This completely bypasses genesis initialization

func NewMinimalEthBackend 

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

NewMinimalEthBackend creates a new minimal Ethereum backend

func NewMinimalEthBackendForMigration 

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

NewMinimalEthBackendForMigration creates a backend that loads from migrated data

func (*MinimalEthBackend) APIs 

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

APIs returns the collection of RPC services the ethereum package offers

func (*MinimalEthBackend) BlockChain 

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

BlockChain returns the blockchain

func (*MinimalEthBackend) ChainConfig 

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

ChainConfig returns the chain configuration

func (*MinimalEthBackend) TxPool 

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

TxPool returns the transaction pool

type NamespaceStrippingBatch added in v1.18.26 

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

NamespaceStrippingBatch wraps a batch to handle namespace stripping

func (*NamespaceStrippingBatch) Delete added in v1.18.26 

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

func (*NamespaceStrippingBatch) DeleteRange added in v1.18.26 

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

func (*NamespaceStrippingBatch) Put added in v1.18.26 

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

func (*NamespaceStrippingBatch) Replay added in v1.18.26 

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

func (*NamespaceStrippingBatch) Reset added in v1.18.26 

func (b *NamespaceStrippingBatch) Reset()

func (*NamespaceStrippingBatch) ValueSize added in v1.18.26 

func (b *NamespaceStrippingBatch) ValueSize() int

func (*NamespaceStrippingBatch) Write added in v1.18.26 

func (b *NamespaceStrippingBatch) Write() error

type NamespaceStrippingIterator added in v1.18.26 

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

NamespaceStrippingIterator strips namespace from keys during iteration

func (*NamespaceStrippingIterator) Error added in v1.18.26 

func (i *NamespaceStrippingIterator) Error() error

func (*NamespaceStrippingIterator) Key added in v1.18.26 

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

func (*NamespaceStrippingIterator) Next added in v1.18.26 

func (i *NamespaceStrippingIterator) Next() bool

func (*NamespaceStrippingIterator) Release added in v1.18.26 

func (i *NamespaceStrippingIterator) Release()

func (*NamespaceStrippingIterator) Value added in v1.18.26 

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

type NetAPI 

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

NetAPI provides network RPC API

func (*NetAPI) Listening 

func (api *NetAPI) Listening() bool

Listening returns whether the node is listening for network connections

func (*NetAPI) PeerCount 

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

PeerCount returns the number of connected peers

func (*NetAPI) Version 

func (api *NetAPI) Version() string

Version returns the network ID

type NetNamespaceStripper added in v1.20.3 

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

NetNamespaceStripper wraps a database and strips the 32-byte namespace prefix from EVM migrated data, making it readable by C-Chain

func (*NetNamespaceStripper) Ancient added in v1.20.3 

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

Ancient store methods (delegate to underlying)

func (*NetNamespaceStripper) AncientBytes added in v1.20.3 

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

func (*NetNamespaceStripper) AncientDatadir added in v1.20.3 

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

func (*NetNamespaceStripper) AncientRange added in v1.20.3 

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

func (*NetNamespaceStripper) AncientSize added in v1.20.3 

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

func (*NetNamespaceStripper) Ancients added in v1.20.3 

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

func (*NetNamespaceStripper) Close added in v1.20.3 

func (s *NetNamespaceStripper) Close() error

func (*NetNamespaceStripper) Compact added in v1.20.3 

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

func (*NetNamespaceStripper) Delete added in v1.20.3 

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

Delete removes a key

func (*NetNamespaceStripper) DeleteRange added in v1.20.3 

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

func (*NetNamespaceStripper) Get added in v1.20.3 

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

Get retrieves a value, handling namespace translation

func (*NetNamespaceStripper) Has added in v1.20.3 

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

Has checks if a key exists

func (*NetNamespaceStripper) LoadLastBlock added in v1.20.3 

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

LoadLastBlock loads the highest block from the migrated database

func (*NetNamespaceStripper) ModifyAncients added in v1.20.3 

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

func (*NetNamespaceStripper) NewBatch added in v1.20.3 

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

NewBatch creates a new batch

func (*NetNamespaceStripper) NewBatchWithSize added in v1.20.3 

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

NewBatchWithSize creates a batch with size hint

func (*NetNamespaceStripper) NewIterator added in v1.20.3 

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

NewIterator creates an iterator

func (*NetNamespaceStripper) Put added in v1.20.3 

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

Put stores a value (no namespace manipulation on writes)

func (*NetNamespaceStripper) ReadAncients added in v1.20.3 

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

func (*NetNamespaceStripper) Stat added in v1.20.3 

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

func (*NetNamespaceStripper) SyncAncient added in v1.20.3 

func (s *NetNamespaceStripper) SyncAncient() error

func (*NetNamespaceStripper) SyncKeyValue added in v1.20.3 

func (s *NetNamespaceStripper) SyncKeyValue() error

func (*NetNamespaceStripper) Tail added in v1.20.3 

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

func (*NetNamespaceStripper) TruncateHead added in v1.20.3 

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

func (*NetNamespaceStripper) TruncateTail added in v1.20.3 

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

type PebbleWithAncient added in v1.20.0 

type PebbleWithAncient struct {
	*pebble.Database
}

PebbleWithAncient wraps a PebbleDB database to add Ancient store method stubs This allows PebbleDB to be used with geth's blockchain, which expects Ancient methods

func (*PebbleWithAncient) Ancient added in v1.20.0 

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

func (*PebbleWithAncient) AncientBatch added in v1.20.0 

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

func (*PebbleWithAncient) AncientBytes added in v1.20.3 

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

func (*PebbleWithAncient) AncientDatadir added in v1.20.0 

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

func (*PebbleWithAncient) AncientOffSet added in v1.20.0 

func (db *PebbleWithAncient) AncientOffSet() uint64

func (*PebbleWithAncient) AncientRange added in v1.20.0 

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

func (*PebbleWithAncient) AncientSize added in v1.20.0 

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

func (*PebbleWithAncient) Ancients added in v1.20.0 

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

func (*PebbleWithAncient) HasAncient added in v1.20.0 

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

func (*PebbleWithAncient) ModifyAncients added in v1.20.0 

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

func (*PebbleWithAncient) ReadAncients added in v1.20.0 

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

func (*PebbleWithAncient) Sync added in v1.20.0 

func (db *PebbleWithAncient) Sync() error

func (*PebbleWithAncient) SyncAncient added in v1.20.0 

func (db *PebbleWithAncient) SyncAncient() error

func (*PebbleWithAncient) SyncKeyValue added in v1.20.0 

func (db *PebbleWithAncient) SyncKeyValue() error

func (*PebbleWithAncient) Tail added in v1.20.0 

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

func (*PebbleWithAncient) TruncateHead added in v1.20.0 

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

func (*PebbleWithAncient) TruncateTail added in v1.20.0 

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

type PreShanghaiHeader added in v1.20.0 

type PreShanghaiHeader struct {
	ParentHash  common.Hash
	UncleHash   common.Hash
	Coinbase    common.Address
	Root        common.Hash
	TxHash      common.Hash
	ReceiptHash common.Hash
	Bloom       types.Bloom
	Difficulty  *big.Int
	Number      *big.Int
	GasLimit    uint64
	GasUsed     uint64
	Time        uint64
	Extra       []byte
	MixDigest   common.Hash
	Nonce       types.BlockNonce
	BaseFee     *big.Int `rlp:"optional"` // EIP-1559
	// ExtDataHash can be present as empty bytes, so use []byte instead of Hash
	// to allow RLP decoder to handle variable-length data
	ExtDataHash []byte `rlp:"optional"` // EVM specific, may be empty or 32 bytes
}

PreShanghaiHeader represents header format from EVM before Shanghai upgrade EVM headers may have 16 or 17 fields depending on presence of ExtDataHash

func (*PreShanghaiHeader) ToPostShanghai added in v1.20.0 

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

ToPostShanghai converts pre-Shanghai header to post-Shanghai types.Header

type RPCBlock added in v1.20.5 

type RPCBlock struct {
	Number       *hexutil.Big     `json:"number"`
	Hash         common.Hash      `json:"hash"`
	ParentHash   common.Hash      `json:"parentHash"`
	Nonce        types.BlockNonce `json:"nonce"`
	MixHash      common.Hash      `json:"mixHash"`
	Miner        common.Address   `json:"miner"`
	Difficulty   *hexutil.Big     `json:"difficulty"`
	ExtraData    hexutil.Bytes    `json:"extraData"`
	Size         hexutil.Uint64   `json:"size"`
	GasLimit     hexutil.Uint64   `json:"gasLimit"`
	GasUsed      hexutil.Uint64   `json:"gasUsed"`
	Timestamp    hexutil.Uint64   `json:"timestamp"`
	Transactions []RPCTx          `json:"transactions"`
	Uncles       []common.Hash    `json:"uncles"`
	Root         common.Hash      `json:"stateRoot"`
	TxRoot       common.Hash      `json:"transactionsRoot"`
	ReceiptRoot  common.Hash      `json:"receiptsRoot"`
	Bloom        types.Bloom      `json:"logsBloom"`
	BaseFee      *hexutil.Big     `json:"baseFeePerGas,omitempty"`
}

RPCBlock is the JSON-RPC block structure

type RPCLog added in v1.20.5 

type RPCLog struct {
	Address          common.Address `json:"address"`
	Topics           []common.Hash  `json:"topics"`
	Data             hexutil.Bytes  `json:"data"`
	BlockNumber      hexutil.Uint64 `json:"blockNumber"`
	TransactionHash  common.Hash    `json:"transactionHash"`
	TransactionIndex hexutil.Uint64 `json:"transactionIndex"`
	BlockHash        common.Hash    `json:"blockHash"`
	LogIndex         hexutil.Uint64 `json:"logIndex"`
	Removed          bool           `json:"removed"`
}

RPCLog is the JSON-RPC log structure

type RPCReceipt added in v1.20.5 

type RPCReceipt struct {
	TransactionHash   common.Hash     `json:"transactionHash"`
	TransactionIndex  hexutil.Uint64  `json:"transactionIndex"`
	BlockHash         common.Hash     `json:"blockHash"`
	BlockNumber       *hexutil.Big    `json:"blockNumber"`
	From              common.Address  `json:"from"`
	To                *common.Address `json:"to"`
	CumulativeGasUsed hexutil.Uint64  `json:"cumulativeGasUsed"`
	GasUsed           hexutil.Uint64  `json:"gasUsed"`
	ContractAddress   *common.Address `json:"contractAddress,omitempty"`
	Logs              []RPCLog        `json:"logs"`
	LogsBloom         types.Bloom     `json:"logsBloom"`
	Type              hexutil.Uint64  `json:"type"`
	Status            hexutil.Uint64  `json:"status"`
}

RPCReceipt is the JSON-RPC receipt structure

type RPCReplayProgress added in v1.20.5 

type RPCReplayProgress struct {
	LastImported uint64      `json:"lastImported"`
	LastHash     common.Hash `json:"lastHash"`
	Timestamp    time.Time   `json:"timestamp"`
}

type RPCReplayer added in v1.20.5 

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

RPCReplayer fetches blocks via RPC and executes into blockchain

type RPCTransaction 

type RPCTransaction struct {
	BlockHash        *common.Hash      `json:"blockHash"`
	BlockNumber      *hexutil.Big      `json:"blockNumber"`
	From             common.Address    `json:"from"`
	Gas              hexutil.Uint64    `json:"gas"`
	GasPrice         *hexutil.Big      `json:"gasPrice"`
	GasFeeCap        *hexutil.Big      `json:"maxFeePerGas,omitempty"`
	GasTipCap        *hexutil.Big      `json:"maxPriorityFeePerGas,omitempty"`
	Hash             common.Hash       `json:"hash"`
	Input            hexutil.Bytes     `json:"input"`
	Nonce            hexutil.Uint64    `json:"nonce"`
	To               *common.Address   `json:"to"`
	TransactionIndex *hexutil.Uint64   `json:"transactionIndex"`
	Value            *hexutil.Big      `json:"value"`
	Type             hexutil.Uint64    `json:"type"`
	Accesses         *types.AccessList `json:"accessList,omitempty"`
	ChainID          *hexutil.Big      `json:"chainId,omitempty"`
	V                *hexutil.Big      `json:"v"`
	R                *hexutil.Big      `json:"r"`
	S                *hexutil.Big      `json:"s"`
}

RPCTransaction represents a transaction for RPC

type RPCTx added in v1.20.5 

type RPCTx struct {
	Hash             common.Hash     `json:"hash"`
	Nonce            hexutil.Uint64  `json:"nonce"`
	From             common.Address  `json:"from"`
	To               *common.Address `json:"to"`
	Value            *hexutil.Big    `json:"value"`
	GasPrice         *hexutil.Big    `json:"gasPrice"`
	MaxFeePerGas     *hexutil.Big    `json:"maxFeePerGas,omitempty"`
	MaxPriorityFee   *hexutil.Big    `json:"maxPriorityFeePerGas,omitempty"`
	Gas              hexutil.Uint64  `json:"gas"`
	Input            hexutil.Bytes   `json:"input"`
	V                *hexutil.Big    `json:"v"`
	R                *hexutil.Big    `json:"r"`
	S                *hexutil.Big    `json:"s"`
	Type             hexutil.Uint64  `json:"type,omitempty"`
	AccessList       []interface{}   `json:"accessList,omitempty"`
	ChainID          *hexutil.Big    `json:"chainId,omitempty"`
	TransactionIndex hexutil.Uint64  `json:"transactionIndex"`
}

RPCTx is the JSON-RPC transaction structure

type ReplayConfig added in v1.16.15 

type ReplayConfig struct {
	URL                string        // Source subnet RPC endpoint
	Start              uint64        // Start block (0 = auto-detect)
	End                uint64        // End block (0 = fetch tip)
	Batch              int           // Blocks per batch (default: 500)
	FetchConcurrency   int           // Parallel fetchers (default: 8)
	MaxRetries         int           // Retry attempts (default: 8)
	BackoffMin         time.Duration // Min backoff (default: 300ms)
	BackoffMax         time.Duration // Max backoff (default: 5s)
	ResumePath         string        // Progress checkpoint file
	VerifyRoots        bool          // Verify tx/receipt roots (default: true)
	VerifySigs         bool          // Verify signatures (default: true)
	HardStopOnMismatch bool          // Stop on verification failure (default: true)
}

ReplayConfig for RPC-based block replay

func DefaultReplayConfig added in v1.20.5 

func DefaultReplayConfig(url string) ReplayConfig

DefaultReplayConfig returns safe defaults

type ReplayProgress added in v1.18.2 

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

ReplayProgress tracks the progress of database replay

func NewReplayProgress added in v1.18.2 

func NewReplayProgress() *ReplayProgress

NewReplayProgress creates a new replay progress tracker

func (*ReplayProgress) Complete added in v1.18.2 

func (p *ReplayProgress) Complete()

Complete marks the replay as completed

func (*ReplayProgress) Fail added in v1.18.2 

func (p *ReplayProgress) Fail(err error)

Fail marks the replay as failed

func (*ReplayProgress) GetStatus added in v1.18.2 

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

GetStatus returns the current status

func (*ReplayProgress) IncrementBlock added in v1.18.2 

func (p *ReplayProgress) IncrementBlock() uint64

IncrementBlock increments the current block counter

func (*ReplayProgress) IsReplaying added in v1.20.0 

func (p *ReplayProgress) IsReplaying() bool

IsReplaying returns true if replay is currently in progress

func (*ReplayProgress) SetPhase added in v1.18.2 

func (p *ReplayProgress) SetPhase(phase string)

SetPhase updates the current phase

func (*ReplayProgress) Start added in v1.18.2 

func (p *ReplayProgress) Start(totalBlocks uint64)

Start marks the replay as started

func (*ReplayProgress) Update added in v1.20.0 

func (p *ReplayProgress) Update(blockCount uint64)

Update updates the current block count

func (*ReplayProgress) UpdateBlock added in v1.18.2 

func (p *ReplayProgress) UpdateBlock(blockNum uint64)

UpdateBlock updates the current block number

func (*ReplayProgress) UpdatePhase added in v1.20.0 

func (p *ReplayProgress) UpdatePhase(phase string)

UpdatePhase is an alias for SetPhase for compatibility

type ReplayState added in v1.18.2 

type ReplayState int32

ReplayState represents the state of database replay 

const (
	ReplayNotStarted ReplayState = 0
	ReplayInProgress ReplayState = 1
	ReplayCompleted  ReplayState = 2
	ReplayFailed     ReplayState = 3
)

type RuntimeReplayManager added in v1.17.2 

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

RuntimeReplayManager handles runtime detection and loading of migrated blockchain data

func NewRuntimeReplayManager added in v1.17.2 

func NewRuntimeReplayManager(vm *VM) *RuntimeReplayManager

NewRuntimeReplayManager creates a new runtime replay manager

func (*RuntimeReplayManager) DetectAndLoadMigratedData added in v1.17.2 

func (r *RuntimeReplayManager) DetectAndLoadMigratedData() error

DetectAndLoadMigratedData checks for migrated BadgerDB data and loads it into the chain

type SetGenesisRequest added in v1.20.6 

type SetGenesisRequest struct {
	Height   uint64 `json:"height"`
	Hash     string `json:"hash"`
	Header   string `json:"header"`
	Body     string `json:"body"`
	Receipts string `json:"receipts"`
}

SetGenesisRequest represents the request for setting genesis from imported block 0

type SetGenesisResponse added in v1.20.6 

type SetGenesisResponse struct {
	Success        bool   `json:"success"`
	OldGenesisHash string `json:"oldGenesisHash"`
	NewGenesisHash string `json:"newGenesisHash"`
	Error          string `json:"error,omitempty"`
}

SetGenesisResponse represents the response from setting genesis

type StartReplayRequest added in v1.20.0 

type StartReplayRequest struct {
	SourcePath string `json:"sourcePath"`
	StartBlock uint64 `json:"startBlock"`
	EndBlock   uint64 `json:"endBlock"`
	BatchSize  uint64 `json:"batchSize"`
}

StartReplayRequest represents the request for starting database replay

type TransactionArgs 

type TransactionArgs struct {
	From     *common.Address `json:"from"`
	To       *common.Address `json:"to"`
	Gas      *hexutil.Uint64 `json:"gas"`
	GasPrice *hexutil.Big    `json:"gasPrice"`
	Value    *hexutil.Big    `json:"value"`
	Nonce    *hexutil.Uint64 `json:"nonce"`
	Data     *hexutil.Bytes  `json:"data"`
	Input    *hexutil.Bytes  `json:"input"`
}

TransactionArgs represents the arguments for a transaction

type TxPoolAPI added in v1.20.5 

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

TxPoolAPI provides transaction pool RPC API

func NewTxPoolAPI added in v1.20.5 

func NewTxPoolAPI(backend *MinimalEthBackend) *TxPoolAPI

NewTxPoolAPI creates a new TxPool RPC API

func (*TxPoolAPI) Content added in v1.20.5 

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

Content returns the transactions in the pool

func (*TxPoolAPI) Inspect added in v1.20.5 

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

Inspect returns a summary of the pool

func (*TxPoolAPI) Status added in v1.20.5 

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

Status returns the status of the transaction pool

type UnifiedReplayConfig 

type UnifiedReplayConfig struct {
	SourcePath               string
	DatabaseType             DatabaseType
	ExtractGenesisFromSource bool
	TestMode                 bool
	TestLimit                uint64
	CopyAllState             bool
	DatabaseBackend          string      // Database backend type
	TargetHeight             uint64      // Target block height
	TargetWallet             interface{} // Target wallet address (can be string or common.Address)
	ReplayTransactions       bool        // Whether to replay transactions
	VerifyStateRoots         bool        // Whether to verify state roots
	LogInterval              uint64      // Logging interval
	ChainConfig              interface{} // Chain configuration
}

UnifiedReplayConfig configures the unified replayer

type UnifiedReplayer 

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

UnifiedReplayer is a stub - needs proper implementation

func NewUnifiedReplayer 

func NewUnifiedReplayer(config *UnifiedReplayConfig, db ethdb.Database, chain *gethcore.BlockChain) (*UnifiedReplayer, error)

NewUnifiedReplayer creates a new replayer - STUB IMPLEMENTATION

func NewUnifiedReplayerWithTrieDB added in v1.20.0 

func NewUnifiedReplayerWithTrieDB(config *UnifiedReplayConfig, db ethdb.Database, chain *gethcore.BlockChain, trieDB interface{}, stateCache state.Database) (*UnifiedReplayer, error)

NewUnifiedReplayerWithTrieDB creates replayer with trie database - STUB IMPLEMENTATION

func (*UnifiedReplayer) Close 

func (r *UnifiedReplayer) Close() error

Close cleans up resources - STUB IMPLEMENTATION

func (*UnifiedReplayer) ExtractGenesis 

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

ExtractGenesis extracts genesis block from source - STUB IMPLEMENTATION

func (*UnifiedReplayer) ReplayWithEVM added in v1.18.26 

func (r *UnifiedReplayer) ReplayWithEVM() error

ReplayWithEVM executes replay using the provided EVM - STUB IMPLEMENTATION

func (*UnifiedReplayer) Run 

func (r *UnifiedReplayer) Run() error

Run executes the replay - STUB IMPLEMENTATION

type VM 

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

VM implements the C-Chain VM interface using geth

func (*VM) AppGossip 

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

AppGossip implements the block.ChainVM interface

func (*VM) AppRequest 

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

AppRequest implements the block.ChainVM interface

func (*VM) AppRequestFailed 

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

AppRequestFailed implements the block.ChainVM interface

func (*VM) AppResponse 

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

AppResponse implements the block.ChainVM interface

func (*VM) BuildBlock 

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

BuildBlock implements the block.ChainVM interface

func (*VM) Connected 

func (vm *VM) Connected(ctx context.Context, nodeID ids.NodeID, version interface{}) error

Connected implements the block.ChainVM interface

func (*VM) CreateHandlers 

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

CreateHandlers implements the block.ChainVM interface

func (*VM) CrossChainAppRequest 

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

CrossChainAppRequest implements the block.ChainVM interface

func (*VM) CrossChainAppRequestFailed 

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

CrossChainAppRequestFailed implements the block.ChainVM interface

func (*VM) CrossChainAppResponse 

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

CrossChainAppResponse implements the block.ChainVM interface

func (*VM) Disconnected 

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

Disconnected implements the block.ChainVM interface

func (*VM) ForceBlockchainReload added in v1.20.0 

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

ForceBlockchainReload forces the blockchain to recognize replayed blocks This is called after replay completes to ensure eth_blockNumber returns the correct value

func (*VM) GetBlock 

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

GetBlock implements the block.ChainVM interface

func (*VM) GetBlockIDAtHeight 

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

GetBlockIDAtHeight implements the block.ChainVM interface

func (*VM) HealthCheck 

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

HealthCheck implements the block.ChainVM interface

func (*VM) Initialize 

func (vm *VM) Initialize(
	ctx context.Context,
	chainCtx interface{},
	db interface{},
	genesisBytes []byte,
	upgradeBytes []byte,
	configBytes []byte,
	msgChan interface{},
	fxs []interface{},
	appSender interface{},
) error

Initialize implements the block.ChainVM interface

func (*VM) InitializeWithReplay added in v1.18.28 

func (vm *VM) InitializeWithReplay() error

InitializeWithReplay initializes the VM with migrated blockchain data

func (*VM) LastAccepted 

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

LastAccepted implements the block.ChainVM interface

func (*VM) NewHTTPHandler 

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

NewHTTPHandler implements the block.ChainVM interface

func (*VM) ParseBlock 

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

ParseBlock implements the block.ChainVM interface

func (*VM) RecreateBackendAfterReplay added in v1.20.0 

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

RecreateBackendAfterReplay recreates the backend and blockchain after replay This ensures all components properly recognize the replayed data

func (*VM) ReloadBlockchainState added in v1.20.0 

func (vm *VM) ReloadBlockchainState() error

ReloadBlockchainState forces the blockchain to reload its state from the database This is useful after direct database modifications or replay operations

func (*VM) RunReplay added in v1.20.0 

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

RunReplay executes the runtime replay of blocks from EVM to C-Chain This method is called by the lux_replayStart RPC method

func (*VM) SetPreference 

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

SetPreference implements the block.ChainVM interface

func (*VM) SetState 

func (vm *VM) SetState(ctx context.Context, state uint32) error

SetState implements the block.ChainVM interface

func (*VM) Shutdown 

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

Shutdown implements the block.ChainVM interface

func (*VM) StartRPCReplay added in v1.20.5 

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

StartRPCReplay begins RPC-based block replay

func (*VM) VerifyBlockchainIntegrity added in v1.20.0 

func (vm *VM) VerifyBlockchainIntegrity() error

VerifyBlockchainIntegrity checks that the blockchain properly recognizes replayed data

func (*VM) Version 

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

Version implements the block.ChainVM interface

func (*VM) WaitForEvent 

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

WaitForEvent implements the block.ChainVM interface

type Web3API 

type Web3API struct{}

Web3API provides web3 RPC API

func (*Web3API) ClientVersion 

func (api *Web3API) ClientVersion() string

ClientVersion returns the node client version

func (*Web3API) Sha3 

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

Sha3 returns the Keccak-256 hash of the given data

Source Files

View all Source files

Directories

Path Synopsis
cmd
replay command
replay-standalone command
replay-standalone is a standalone tool for replaying EVM data into C-Chain format It doesn't depend on the node package, making it more portable.
 replay-standalone is a standalone tool for replaying EVM data into C-Chain format It doesn't depend on the node package, making it more portable.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.