puller

package
v1.13.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 2, 2023 License: BSD-3-Clause Imports: 17 Imported by: 1

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

View Source
const (
	DefaultSyncErrorSleepDur = time.Second * 30
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Options

type Options struct {
	Bins         uint8
	SyncSleepDur time.Duration
}

type Puller

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

func New

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

func (*Puller) ActiveHistoricalSyncing added in v1.11.0

func (p *Puller) ActiveHistoricalSyncing() uint64

func (*Puller) Close

func (p *Puller) Close() error

func (*Puller) Metrics added in v0.2.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL