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(addr swarm.Address, stateStore storage.StateStorer, topology topology.Driver, ...) *Puller
  • func (p *Puller) Close() error
  • func (p *Puller) Metrics() []prometheus.Collector
  • func (p *Puller) Start(ctx context.Context)
  • func (p *Puller) SyncRate() float64

Constants

const (
	DefaultHistRateWindow = time.Minute * 15

	IntervalPrefix = "sync_interval"
)

Types

type Options

type Options struct {
	Bins uint8
}

type Puller

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

func New

func New(
	addr swarm.Address,
	stateStore storage.StateStorer,
	topology topology.Driver,
	reserveState storer.RadiusChecker,
	pullSync pullsync.Interface,
	blockLister p2p.Blocklister,
	logger log.Logger,
	o Options,
) *Puller

func (*Puller) Close

func (p *Puller) Close() error

func (*Puller) Metrics

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

func (*Puller) Start

func (p *Puller) Start(ctx context.Context)

func (*Puller) SyncRate

func (p *Puller) SyncRate() float64