Versions in this module Expand all Collapse all v1 v1.9.25 Mar 23, 2024 Changes in this version + var MaxBlockFetch = 128 + var MaxHashFetch = 512 + var MaxHeaderFetch = 192 + var MaxReceiptFetch = 256 + var MaxSkeletonSize = 128 + var MaxStateFetch = 384 + type BlockChain interface + CurrentBlock func() *types.Block + CurrentFastBlock func() *types.Block + FastSyncCommitHead func(common.Hash) error + GetBlockByHash func(common.Hash) *types.Block + HasBlock func(common.Hash, uint64) bool + HasFastBlock func(common.Hash, uint64) bool + InsertChain func(types.Blocks) (int, error) + InsertReceiptChain func(types.Blocks, []types.Receipts, uint64) (int, error) + type DoneEvent struct + Latest *types.Header + type Downloader struct + func New(checkpoint uint64, stateDb ethdb.Database, stateBloom *trie.SyncBloom, ...) *Downloader + func (d *Downloader) Cancel() + func (d *Downloader) DeliverBodies(id string, transactions [][]*types.Transaction, uncles [][]*types.Header) (err error) + func (d *Downloader) DeliverHeaders(id string, headers []*types.Header) (err error) + func (d *Downloader) DeliverNodeData(id string, data [][]byte) (err error) + func (d *Downloader) DeliverReceipts(id string, receipts [][]*types.Receipt) (err error) + func (d *Downloader) Progress() tosnetwk.SyncProgress + func (d *Downloader) RegisterLightPeer(id string, version int, peer LightPeer) error + func (d *Downloader) RegisterPeer(id string, version int, peer Peer) error + func (d *Downloader) SyncBloomContains(hash []byte) bool + func (d *Downloader) Synchronise(id string, head common.Hash, td *big.Int, mode SyncMode) error + func (d *Downloader) Synchronising() bool + func (d *Downloader) Terminate() + func (d *Downloader) UnregisterPeer(id string) error + type FailedEvent struct + Err error + type FakePeer struct + func NewFakePeer(id string, db ethdb.Database, hc *core.HeaderChain, dl *Downloader) *FakePeer + func (p *FakePeer) Head() (common.Hash, *big.Int) + func (p *FakePeer) RequestBodies(hashes []common.Hash) error + func (p *FakePeer) RequestHeadersByHash(hash common.Hash, amount int, skip int, reverse bool) error + func (p *FakePeer) RequestHeadersByNumber(number uint64, amount int, skip int, reverse bool) error + func (p *FakePeer) RequestNodeData(hashes []common.Hash) error + func (p *FakePeer) RequestReceipts(hashes []common.Hash) error + type LightChain interface + CurrentHeader func() *types.Header + GetHeaderByHash func(common.Hash) *types.Header + GetTd func(common.Hash, uint64) *big.Int + HasHeader func(common.Hash, uint64) bool + InsertHeaderChain func([]*types.Header, int) (int, error) + SetHead func(uint64) error + type LightPeer interface + Head func() (common.Hash, *big.Int) + RequestHeadersByHash func(common.Hash, int, int, bool) error + RequestHeadersByNumber func(uint64, int, int, bool) error + type Peer interface + RequestBodies func([]common.Hash) error + RequestNodeData func([]common.Hash) error + RequestReceipts func([]common.Hash) error + type PublicDownloaderAPI struct + func NewPublicDownloaderAPI(d *Downloader, m *event.TypeMux) *PublicDownloaderAPI + func (api *PublicDownloaderAPI) SubscribeSyncStatus(status chan interface{}) *SyncStatusSubscription + func (api *PublicDownloaderAPI) Syncing(ctx context.Context) (*rpc.Subscription, error) + type StartEvent struct + type SyncMode uint32 + const FastSync + const FullSync + const LightSync + func (mode *SyncMode) UnmarshalText(text []byte) error + func (mode SyncMode) IsValid() bool + func (mode SyncMode) MarshalText() ([]byte, error) + func (mode SyncMode) String() string + type SyncStatusSubscription struct + func (s *SyncStatusSubscription) Unsubscribe() + type SyncingResult struct + Status tosnetwk.SyncProgress + Syncing bool
Go to main page