basepeerleecher

Documentation

Index

• type BasePeerLeecher
  • func New(wg *sync.WaitGroup, cfg EpochDownloaderConfig, ...) *BasePeerLeecher
  • func (d *BasePeerLeecher) NotifyChunkReceived(id interface{}) error
  • func (d *BasePeerLeecher) Start()
  • func (d *BasePeerLeecher) Stop()
  • func (d *BasePeerLeecher) Stopped() bool
  • func (d *BasePeerLeecher) Terminate()
• type EpochDownloaderCallbacks
• type EpochDownloaderConfig
• type IsProcessed

Types

type BasePeerLeecher

type BasePeerLeecher struct {
	// contains filtered or unexported fields
}

BasePeerLeecher is responsible for scheduling items for retrieval.

func New

func New(wg *sync.WaitGroup, cfg EpochDownloaderConfig, callback EpochDownloaderCallbacks) *BasePeerLeecher

New creates an items fetcher to retrieve items chunk-by-chunk. Works only with 1 peer.

func (*BasePeerLeecher) NotifyChunkReceived

func (d *BasePeerLeecher) NotifyChunkReceived(id interface{}) error

NotifyChunkReceived injects new pack infos from a peer

func (*BasePeerLeecher) Start

func (d *BasePeerLeecher) Start()

Start boots up the announcement based synchroniser, accepting and processing fetches until termination requested.

func (*BasePeerLeecher) Stop

func (d *BasePeerLeecher) Stop()

Stop terminates the announcement based synchroniser, canceling all pending operations.

func (*BasePeerLeecher) Stopped

func (d *BasePeerLeecher) Stopped() bool

func (*BasePeerLeecher) Terminate

func (d *BasePeerLeecher) Terminate()

type EpochDownloaderCallbacks

type EpochDownloaderCallbacks struct {
	IsProcessed IsProcessed

	RequestChunks func(maxNum uint32, maxSize uint64, maxChunks uint32) error

	Suspend func() bool

	Done func() bool
}

type EpochDownloaderConfig

type EpochDownloaderConfig struct {
	RecheckInterval        time.Duration
	DefaultChunkItemsNum   uint32
	DefaultChunkItemsSize  uint64
	ParallelChunksDownload int
}

type IsProcessed

type IsProcessed func(id interface{}) bool