Versions in this module Expand all Collapse all v1 v1.6.9 May 31, 2018 Changes in this version + var MaxBlockFetch = 128 + var MaxBodyFetch = 128 + var MaxForkAncestry = 3 * params.EpochDuration + 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 + HasBlockAndState func(common.Hash) bool + InsertChain func(types.Blocks) (int, error) + InsertReceiptChain func(types.Blocks, []types.Receipts) (int, error) + type DoneEvent struct + type Downloader struct + func New(mode SyncMode, stateDb ethdb.Database, mux *event.TypeMux, chain BlockChain, ...) *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 LightChain interface + CurrentHeader func() *types.Header + GetHeaderByHash func(common.Hash) *types.Header + GetTdByHash func(common.Hash) *big.Int + HasHeader func(common.Hash) 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
Go to main page