downloader

Apr 14, 2017

Changes in this version

type SyncMode

+ func (mode *SyncMode) UnmarshalText(text []byte) error

+ func (mode SyncMode) IsValid() bool

+ func (mode SyncMode) MarshalText() ([]byte, error)

+ func (mode SyncMode) String() string

Nov 16, 2016

Changes in this version

+ var MaxSkeletonSize = 128

type PublicDownloaderAPI

+ func (api *PublicDownloaderAPI) SubscribeSyncStatus(status chan interface{}) *SyncStatusSubscription

+ type SyncStatusSubscription struct

+ func (s *SyncStatusSubscription) Unsubscribe()

May 24, 2016

Changes in this version

+ var MaxForkAncestry = 3 * params.EpochDuration.Uint64()

May 9, 2016

Changes in this version

+ type Progress struct

+ Current uint64

+ Height uint64

+ Known uint64

+ Origin uint64

+ Pulled uint64

+ type PublicDownloaderAPI struct

+ func NewPublicDownloaderAPI(d *Downloader, m *event.TypeMux) *PublicDownloaderAPI

+ func (api *PublicDownloaderAPI) Syncing(ctx context.Context) (rpc.Subscription, error)

+ type SyncingResult struct

+ Status Progress

+ Syncing bool

Jan 5, 2016

Changes in this version

+ var MaxReceiptFetch = 256

type Downloader

+ 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() (uint64, uint64, uint64)

+ type SyncMode int

+ const FastSync

+ const FullSync

+ const LightSync

Jul 9, 2015

Changes in this version

type Downloader

+ func (d *Downloader) Terminate()

May 27, 2015

Changes in this version

+ const MaxBlockFetch

+ const MaxHashFetch

+ const MinHashFetch

+ var ErrStallingPeer = errors.New("peer is stalling")

+ type Block struct

+ OriginPeer string

+ RawBlock *types.Block

May 15, 2015

Changes in this version

+ var ErrBadPeer = errors.New("action from bad peer ignored")

+ var ErrBusy = errors.New("busy")

+ var ErrCrossCheckFailed = errors.New("block cross-check failed")

+ var ErrInvalidChain = errors.New("retrieved hash chain is invalid")

+ var ErrPendingQueue = errors.New("pending items in queue")

+ var ErrTimeout = errors.New("timeout")

+ type DoneEvent struct

+ type Downloader struct

+ func New(mux *event.TypeMux, hasBlock hashCheckFn, getBlock getBlockFn) *Downloader

+ func (d *Downloader) Cancel() bool

+ func (d *Downloader) DeliverBlocks(id string, blocks []*types.Block) error

+ func (d *Downloader) DeliverHashes(id string, hashes []common.Hash) error

+ func (d *Downloader) Has(hash common.Hash) bool

+ func (d *Downloader) RegisterPeer(id string, head common.Hash, getHashes hashFetcherFn, getBlocks blockFetcherFn) error

+ func (d *Downloader) Stats() (current int, max int)

+ func (d *Downloader) Synchronise(id string, hash common.Hash) error

+ func (d *Downloader) Synchronising() bool

+ func (d *Downloader) TakeBlocks() types.Blocks

+ func (d *Downloader) UnregisterPeer(id string) error

+ type FailedEvent struct

+ Err error

+ type StartEvent struct