puller

Documentation

Index

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

Types

type Options

type Options struct {
	Bins            uint8
	ShallowBinPeers int
}

type Puller

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

func New

func New(stateStore storage.StateStorer, topology topology.Driver, pullSync pullsync.Interface, logger logging.Logger, o Options) *Puller

func (*Puller) Close

func (p *Puller) Close() error

func (*Puller) Metrics

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