downloader

package

Go to main page

Versions in this module

v0

v0.2.1455559

Mar 25, 2022

v0.2.1455558

Mar 25, 2022

v0.2.1455557

Mar 25, 2022

v0.2.1455556

Mar 25, 2022

v0.2.1455555

Mar 25, 2022

Changes in this version

type BlockChain

+ Snapshots func() *snapshot.Tree

type Downloader

+ SnapSyncer *snap.Syncer

+ func (d *Downloader) DeliverSnapPacket(peer *snap.Peer, packet snap.Packet) error

type LightChain

+ SetHead func(uint64) error

type SyncMode

+ const SnapSync

v0.1.4

Mar 6, 2020

Changes in this version

+ var MaxBlockFetch = 128

+ var MaxBodyFetch = 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() ethereum.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) 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)

+ Rollback func([]common.Hash)

+ 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 int

+ 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 ethereum.SyncProgress

+ Syncing bool

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