puller

Documentation

Overview

Package puller provides protocol-orchestrating functionality over the pullsync protocol. It pulls chunks from other nodes and reacts to changes in network configuration.

Index

• Constants
• type Options
• type Puller
  • func New(stateStore storage.StateStorer, topology topology.Driver, ...) *Puller
  • func (p *Puller) ActiveHistoricalSyncing() uint64
  • func (p *Puller) Close() error
  • func (p *Puller) Metrics() []prometheus.Collector

Constants

const (
	DefaultSyncErrorSleepDur    = time.Minute
	DefaultShallowBinsWarmupDur = time.Hour * 24
)

Types

type Options

type Options struct {
	Bins                 uint8
	SyncSleepDur         time.Duration
	ShallowBinsWarmupDur time.Duration
}

type Puller

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

func New

func New(stateStore storage.StateStorer, topology topology.Driver, reserveState postage.Radius, pullSync pullsync.Interface, blockLister p2p.Blocklister, logger log.Logger, o Options, warmupTime time.Duration) *Puller

func (*Puller) ActiveHistoricalSyncing

func (p *Puller) ActiveHistoricalSyncing() uint64

func (*Puller) Close

func (p *Puller) Close() error

func (*Puller) Metrics

func (p *Puller) Metrics() []prometheus.Collector