chainsyncer

Documentation

Overview

Package chainsyncer provides orchestration logic for the chainsync protocol.

Index

• type ChainSyncer
  • func New(backend transaction.Backend, p prover, peerIterator topology.EachPeerer, ...) (*ChainSyncer, error)
  • func (c *ChainSyncer) Close() error
  • func (c *ChainSyncer) Metrics() []prometheus.Collector
• type Options

Types

type ChainSyncer

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

func New

func New(backend transaction.Backend, p prover, peerIterator topology.EachPeerer, disconnecter p2p.Disconnecter, logger logging.Logger, o *Options) (*ChainSyncer, error)

func (*ChainSyncer) Close

func (c *ChainSyncer) Close() error

func (*ChainSyncer) Metrics

func (c *ChainSyncer) Metrics() []prometheus.Collector

Metrics returns the prometheus Collector for the accounting service.

type Options

type Options struct {
	FlagTimeout     time.Duration
	PollEvery       time.Duration
	BlockerPollTime time.Duration
}