light

package

Go to main page

Versions in this module

v1

v1.10.1

Jul 4, 2021

Changes in this version

+ func GetTd(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) (*big.Int, error)

type BlockRequest

+ Header *types.Header

type BloomTrieIndexerBackend

+ func (b *BloomTrieIndexerBackend) Prune(threshold uint64) error

type ChtIndexerBackend

+ func (c *ChtIndexerBackend) Prune(threshold uint64) error

type LightChain

+ func (lc *LightChain) GetTdOdr(ctx context.Context, hash common.Hash, number uint64) *big.Int

+ func (lc *LightChain) StopInsert()

type OdrBackend

+ RetrieveTxStatus func(ctx context.Context, req *TxStatusRequest) error

v1.9.10

Feb 4, 2020

Changes in this version

+ var BloomTrieTablePrefix = "blt-"

+ var ChtTablePrefix = "cht-"

+ var DefaultClientIndexerConfig = &IndexerConfig

+ var DefaultServerIndexerConfig = &IndexerConfig

+ var ErrNoPeers = errors.New("no suitable peers available")

+ var TestClientIndexerConfig = &IndexerConfig

+ var TestServerIndexerConfig = &IndexerConfig

+ func GetBlockLogs(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) ([][]*types.Log, error)

+ func GetBloomBits(ctx context.Context, odr OdrBackend, bitIdx uint, sectionIdxList []uint64) ([][]byte, error)

+ func GetBloomTrieRoot(db ethdb.Database, sectionIdx uint64, sectionHead common.Hash) common.Hash

+ func GetChtRoot(db ethdb.Database, sectionIdx uint64, sectionHead common.Hash) common.Hash

+ func GetTransaction(ctx context.Context, odr OdrBackend, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, error)

+ func GetUntrustedBlockLogs(ctx context.Context, odr OdrBackend, header *types.Header) ([][]*types.Log, error)

+ func GetUntrustedHeaderByNumber(ctx context.Context, odr OdrBackend, number uint64, peerId string) (*types.Header, error)

+ func NewBloomTrieIndexer(db ethdb.Database, odr OdrBackend, parentSize, size uint64) *core.ChainIndexer

+ func NewChtIndexer(db ethdb.Database, odr OdrBackend, size, confirms uint64) *core.ChainIndexer

+ func StoreBloomTrieRoot(db ethdb.Database, sectionIdx uint64, sectionHead, root common.Hash)

+ func StoreChtRoot(db ethdb.Database, sectionIdx uint64, sectionHead, root common.Hash)

+ type BloomRequest struct

+ BitIdx uint

+ BloomBits [][]byte

+ BloomTrieNum uint64

+ BloomTrieRoot common.Hash

+ Config *IndexerConfig

+ Proofs *NodeSet

+ SectionIndexList []uint64

+ func (req *BloomRequest) StoreResult(db ethdb.Database)

+ type BloomTrieIndexerBackend struct

+ func (b *BloomTrieIndexerBackend) Commit() error

+ func (b *BloomTrieIndexerBackend) Process(ctx context.Context, header *types.Header) error

+ func (b *BloomTrieIndexerBackend) Reset(ctx context.Context, section uint64, lastSectionHead common.Hash) error

+ type ChtIndexerBackend struct

+ func (c *ChtIndexerBackend) Commit() error

+ func (c *ChtIndexerBackend) Process(ctx context.Context, header *types.Header) error

+ func (c *ChtIndexerBackend) Reset(ctx context.Context, section uint64, lastSectionHead common.Hash) error

type ChtRequest

+ Config *IndexerConfig

+ PeerId string

+ Untrusted bool

+ type IndexerConfig struct

+ BloomConfirms uint64

+ BloomSize uint64

+ BloomTrieConfirms uint64

+ BloomTrieSize uint64

+ ChtConfirms uint64

+ ChtSize uint64

type LightChain

+ func (bc *LightChain) GetCanonicalHash(number uint64) common.Hash

+ func (lc *LightChain) AddTrustedCheckpoint(cp *params.TrustedCheckpoint)

+ func (lc *LightChain) Config() *params.ChainConfig

+ func (lc *LightChain) DisableCheckFreq()

+ func (lc *LightChain) EnableCheckFreq()

+ func (lc *LightChain) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

+ func (lc *LightChain) HeaderChain() *core.HeaderChain

+ func (lc *LightChain) StateCache() state.Database

+ func (lc *LightChain) SyncCheckpoint(ctx context.Context, checkpoint *params.TrustedCheckpoint) bool

+ type NodeList []rlp.RawValue

+ func (n *NodeList) Delete(key []byte) error

+ func (n *NodeList) Put(key []byte, value []byte) error

+ func (n NodeList) DataSize() int

+ func (n NodeList) NodeSet() *NodeSet

+ func (n NodeList) Store(db ethdb.KeyValueWriter)

+ type NodeSet struct

+ func NewNodeSet() *NodeSet

+ func (db *NodeSet) DataSize() int

+ func (db *NodeSet) Delete(key []byte) error

+ func (db *NodeSet) Get(key []byte) ([]byte, error)

+ func (db *NodeSet) Has(key []byte) (bool, error)

+ func (db *NodeSet) KeyCount() int

+ func (db *NodeSet) NodeList() NodeList

+ func (db *NodeSet) Put(key []byte, value []byte) error

+ func (db *NodeSet) Store(target ethdb.KeyValueWriter)

type OdrBackend

+ BloomIndexer func() *core.ChainIndexer

+ BloomTrieIndexer func() *core.ChainIndexer

+ ChtIndexer func() *core.ChainIndexer

+ IndexerConfig func() *IndexerConfig

type ReceiptsRequest

+ Header *types.Header

+ Untrusted bool

type TxPool

+ func (pool *TxPool) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription

+ type TxStatus struct

+ Error string

+ Lookup *rawdb.LegacyTxLookupEntry

+ Status core.TxStatus

+ type TxStatusRequest struct

+ Hashes []common.Hash

+ Status []TxStatus

+ func (req *TxStatusRequest) StoreResult(db ethdb.Database)

v1.8.12

Oct 17, 2017

v1.7.2

Oct 17, 2017

Changes in this version

+ func NewState(ctx context.Context, head *types.Header, odr OdrBackend) *state.StateDB

+ func NewStateDatabase(ctx context.Context, head *types.Header, odr OdrBackend) state.Database

type LightChain

+ func (self *LightChain) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription

+ func (self *LightChain) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription

+ func (self *LightChain) SubscribeChainSideEvent(ch chan<- core.ChainSideEvent) event.Subscription

+ func (self *LightChain) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (self *LightChain) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription

type TxPool

+ func (pool *TxPool) SubscribeTxPreEvent(ch chan<- core.TxPreEvent) event.Subscription

v1.6.6

Jun 4, 2017

Changes in this version

+ var ChtConfirmations = uint64(2048)

+ var ChtFrequency = uint64(4096)

+ var ErrNoHeader = errors.New("Header not found")

+ var ErrNoTrustedCht = errors.New("No trusted canonical hash trie")

+ var NoOdr = context.Background()

+ func DeleteTrustedCht(db ethdb.Database)

+ func GetBlock(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) (*types.Block, error)

+ func GetBlockReceipts(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) (types.Receipts, error)

+ func GetBody(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) (*types.Body, error)

+ func GetBodyRLP(ctx context.Context, odr OdrBackend, hash common.Hash, number uint64) (rlp.RawValue, error)

+ func GetCanonicalHash(ctx context.Context, odr OdrBackend, number uint64) (common.Hash, error)

+ func GetHeaderByNumber(ctx context.Context, odr OdrBackend, number uint64) (*types.Header, error)

+ func WriteTrustedCht(db ethdb.Database, cht TrustedCht)

+ type BlockRequest struct

+ Hash common.Hash

+ Number uint64

+ Rlp []byte

+ func (req *BlockRequest) StoreResult(db ethdb.Database)

+ type ChtNode struct

+ Hash common.Hash

+ Td *big.Int

+ type ChtRequest struct

+ BlockNum uint64

+ ChtNum uint64

+ ChtRoot common.Hash

+ Header *types.Header

+ Proof []rlp.RawValue

+ Td *big.Int

+ func (req *ChtRequest) StoreResult(db ethdb.Database)

+ type CodeRequest struct

+ Data []byte

+ Hash common.Hash

+ Id *TrieID

+ func (req *CodeRequest) StoreResult(db ethdb.Database)

+ type LightChain struct

+ func NewLightChain(odr OdrBackend, config *params.ChainConfig, engine consensus.Engine, ...) (*LightChain, error)

+ func (bc *LightChain) Engine() consensus.Engine

+ func (bc *LightChain) Genesis() *types.Block

+ func (bc *LightChain) HasBlock(hash common.Hash) bool

+ func (bc *LightChain) HasHeader(hash common.Hash) bool

+ func (bc *LightChain) Reset()

+ func (bc *LightChain) ResetWithGenesisBlock(genesis *types.Block)

+ func (bc *LightChain) SetHead(head uint64)

+ func (bc *LightChain) Stop()

+ func (self *LightChain) CurrentHeader() *types.Header

+ func (self *LightChain) GasLimit() *big.Int

+ func (self *LightChain) GetBlock(ctx context.Context, hash common.Hash, number uint64) (*types.Block, error)

+ func (self *LightChain) GetBlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

+ func (self *LightChain) GetBlockByNumber(ctx context.Context, number uint64) (*types.Block, error)

+ func (self *LightChain) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash

+ func (self *LightChain) GetBody(ctx context.Context, hash common.Hash) (*types.Body, error)

+ func (self *LightChain) GetBodyRLP(ctx context.Context, hash common.Hash) (rlp.RawValue, error)

+ func (self *LightChain) GetHeader(hash common.Hash, number uint64) *types.Header

+ func (self *LightChain) GetHeaderByHash(hash common.Hash) *types.Header

+ func (self *LightChain) GetHeaderByNumber(number uint64) *types.Header

+ func (self *LightChain) GetHeaderByNumberOdr(ctx context.Context, number uint64) (*types.Header, error)

+ func (self *LightChain) GetTd(hash common.Hash, number uint64) *big.Int

+ func (self *LightChain) GetTdByHash(hash common.Hash) *big.Int

+ func (self *LightChain) InsertHeaderChain(chain []*types.Header, checkFreq int) (int, error)

+ func (self *LightChain) LastBlockHash() common.Hash

+ func (self *LightChain) LockChain()

+ func (self *LightChain) Odr() OdrBackend

+ func (self *LightChain) Rollback(chain []common.Hash)

+ func (self *LightChain) State() *LightState

+ func (self *LightChain) Status() (td *big.Int, currentBlock common.Hash, genesisBlock common.Hash)

+ func (self *LightChain) SyncCht(ctx context.Context) bool

+ func (self *LightChain) UnlockChain()

type LightState

+ func (self *LightState) AddRefund(gas *big.Int)

+ func (self *LightState) ForEachStorage(ctx context.Context, addr common.Address, cb func(key, value common.Hash) bool) error

+ func (self *LightState) GetRefund() *big.Int

+ func (self *LightState) HasSuicided(ctx context.Context, addr common.Address) (bool, error)

+ func (self *LightState) SubBalance(ctx context.Context, addr common.Address, amount *big.Int) error

+ func (self *LightState) Suicide(ctx context.Context, addr common.Address) (bool, error)

+ type ReceiptsRequest struct

+ Hash common.Hash

+ Number uint64

+ Receipts types.Receipts

+ func (req *ReceiptsRequest) StoreResult(db ethdb.Database)

type StateObject

+ func (c *StateObject) ReturnGas(gas *big.Int)

+ func (self *StateObject) ForEachStorage(cb func(key, value common.Hash) bool)

+ func (self *StateObject) Value() *big.Int

+ type TrieID struct

+ AccKey []byte

+ BlockHash common.Hash

+ BlockNumber uint64

+ Root common.Hash

+ func StateTrieID(header *types.Header) *TrieID

+ func StorageTrieID(state *TrieID, addr common.Address, root common.Hash) *TrieID

type TrieRequest

+ Id *TrieID

+ Key []byte

+ Proof []rlp.RawValue

+ type TrustedCht struct

+ Number uint64

+ Root common.Hash

+ func GetTrustedCht(db ethdb.Database) TrustedCht

+ type TxPool struct

+ func NewTxPool(config *params.ChainConfig, eventMux *event.TypeMux, chain *LightChain, ...) *TxPool

+ func (pool *TxPool) GetNonce(ctx context.Context, addr common.Address) (uint64, error)

+ func (pool *TxPool) RemoveTx(hash common.Hash)

+ func (pool *TxPool) Stats() (pending int)

+ func (pool *TxPool) Stop()

+ func (self *TxPool) Add(ctx context.Context, tx *types.Transaction) error

+ func (self *TxPool) AddBatch(ctx context.Context, txs []*types.Transaction)

+ func (self *TxPool) Content() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)

+ func (self *TxPool) GetTransactions() (txs types.Transactions, err error)

+ func (self *TxPool) RemoveTransactions(txs types.Transactions)

+ func (tp *TxPool) GetTransaction(hash common.Hash) *types.Transaction

+ type TxRelayBackend interface

+ Discard func(hashes []common.Hash)

+ NewHead func(head common.Hash, mined []common.Hash, rollback []common.Hash)

+ Send func(txs types.Transactions)

+ type VMState struct

+ func NewVMState(ctx context.Context, state *LightState) *VMState

+ func (s *VMState) AddBalance(addr common.Address, amount *big.Int)

+ func (s *VMState) AddLog(log *types.Log)

+ func (s *VMState) AddPreimage(hash common.Hash, preimage []byte)

+ func (s *VMState) AddRefund(gas *big.Int)

+ func (s *VMState) CreateAccount(addr common.Address)

+ func (s *VMState) Empty(addr common.Address) bool

+ func (s *VMState) Error() error

+ func (s *VMState) Exist(addr common.Address) bool

+ func (s *VMState) ForEachStorage(addr common.Address, cb func(key, value common.Hash) bool)

+ func (s *VMState) GetBalance(addr common.Address) *big.Int

+ func (s *VMState) GetCode(addr common.Address) []byte

+ func (s *VMState) GetCodeHash(addr common.Address) common.Hash

+ func (s *VMState) GetCodeSize(addr common.Address) int

+ func (s *VMState) GetNonce(addr common.Address) uint64

+ func (s *VMState) GetRefund() *big.Int

+ func (s *VMState) GetState(a common.Address, b common.Hash) common.Hash

+ func (s *VMState) HasSuicided(addr common.Address) bool

+ func (s *VMState) SetCode(addr common.Address, code []byte)

+ func (s *VMState) SetNonce(addr common.Address, nonce uint64)

+ func (s *VMState) SetState(addr common.Address, key common.Hash, value common.Hash)

+ func (s *VMState) SubBalance(addr common.Address, amount *big.Int)

+ func (s *VMState) Suicide(addr common.Address) bool

+ func (self *VMState) RevertToSnapshot(idx int)

+ func (self *VMState) Snapshot() int

v1.6.1-beta.2

Apr 1, 2017

v1.6.0-beta.2

Apr 1, 2017

v1.6.0-beta.1

Mar 30, 2017

v1.4.16

Oct 8, 2016

v1.4.7

Jun 19, 2016

v1.4.5

May 26, 2016

v1.4.4

May 22, 2016

Changes in this version

+ var StartingNonce uint64

+ type Code []byte

+ func (self Code) String() string

+ type LightState struct

+ func NewLightState(root common.Hash, odr OdrBackend) *LightState

+ func (self *LightState) AddBalance(ctx context.Context, addr common.Address, amount *big.Int) error

+ func (self *LightState) Copy() *LightState

+ func (self *LightState) CreateStateObject(ctx context.Context, addr common.Address) (*StateObject, error)

+ func (self *LightState) Delete(ctx context.Context, addr common.Address) (bool, error)

+ func (self *LightState) GetBalance(ctx context.Context, addr common.Address) (*big.Int, error)

+ func (self *LightState) GetCode(ctx context.Context, addr common.Address) ([]byte, error)

+ func (self *LightState) GetNonce(ctx context.Context, addr common.Address) (uint64, error)

+ func (self *LightState) GetOrNewStateObject(ctx context.Context, addr common.Address) (*StateObject, error)

+ func (self *LightState) GetState(ctx context.Context, a common.Address, b common.Hash) (common.Hash, error)

+ func (self *LightState) GetStateObject(ctx context.Context, addr common.Address) (stateObject *StateObject, err error)

+ func (self *LightState) HasAccount(ctx context.Context, addr common.Address) (bool, error)

+ func (self *LightState) IsDeleted(ctx context.Context, addr common.Address) (bool, error)

+ func (self *LightState) Set(state *LightState)

+ func (self *LightState) SetCode(ctx context.Context, addr common.Address, code []byte) error

+ func (self *LightState) SetNonce(ctx context.Context, addr common.Address, nonce uint64) error

+ func (self *LightState) SetState(ctx context.Context, addr common.Address, key common.Hash, value common.Hash) error

+ func (self *LightState) SetStateObject(object *StateObject)

+ type LightTrie struct

+ func NewLightTrie(root common.Hash, odr OdrBackend, useFakeMap bool) *LightTrie

+ func (t *LightTrie) Delete(ctx context.Context, key []byte) (err error)

+ func (t *LightTrie) Get(ctx context.Context, key []byte) (res []byte, err error)

+ func (t *LightTrie) Update(ctx context.Context, key, value []byte) (err error)

+ type NodeDataRequest struct

+ func (req *NodeDataRequest) GetData() []byte

+ func (req *NodeDataRequest) StoreResult(db ethdb.Database)

+ type OdrBackend interface

+ Database func() ethdb.Database

+ Retrieve func(ctx context.Context, req OdrRequest) error

+ type OdrRequest interface

+ StoreResult func(db ethdb.Database)

+ type StateObject struct

+ func DecodeObject(ctx context.Context, address common.Address, odr OdrBackend, data []byte) (*StateObject, error)

+ func NewStateObject(address common.Address, odr OdrBackend) *StateObject

+ func (c *StateObject) AddBalance(amount *big.Int)

+ func (c *StateObject) Address() common.Address

+ func (c *StateObject) SetBalance(amount *big.Int)

+ func (c *StateObject) SubBalance(amount *big.Int)

+ func (self *StateObject) Balance() *big.Int

+ func (self *StateObject) Code() []byte

+ func (self *StateObject) Copy() *StateObject

+ func (self *StateObject) GetState(ctx context.Context, key common.Hash) (common.Hash, error)

+ func (self *StateObject) MarkForDeletion()

+ func (self *StateObject) Nonce() uint64

+ func (self *StateObject) SetCode(code []byte)

+ func (self *StateObject) SetNonce(nonce uint64)

+ func (self *StateObject) SetState(k, value common.Hash)

+ func (self *StateObject) Storage() Storage

+ type Storage map[string]common.Hash

+ func (self Storage) Copy() Storage

+ func (self Storage) String() (str string)

+ type TrieRequest struct

+ func (req *TrieRequest) StoreResult(db ethdb.Database)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL