depthmonitor

Documentation

Index

• Constants
• type ReserveReporter
• type Service
  • func New(t Topology, syncer SyncReporter, reserve ReserveReporter, bs postage.Storer, ...) *Service
  • func (s *Service) Close() error
  • func (s *Service) IsFullySynced() bool
• type SyncReporter
• type Topology

Constants

const DefaultWakeupInterval = 5 * time.Minute

DefaultWakeupInterval is the default value for the depth monitor wake-up interval.

Types

type ReserveReporter

type ReserveReporter interface {
	// Current size of the reserve.
	ComputeReserveSize(uint8) (uint64, error)
	// Capacity of the reserve that is configured.
	ReserveCapacity() uint64
}

ReserveReporter interface defines the functionality required from the local storage of the node to report information about the reserve. The reserve storage is the storage pledged by the node to the network.

type Service

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

Service implements the depthmonitor service

func New

func New(
	t Topology,
	syncer SyncReporter,
	reserve ReserveReporter,
	bs postage.Storer,
	logger log.Logger,
	warmupTime time.Duration,
	wakeupInterval time.Duration,
) *Service

New constructs a new depthmonitor service

func (*Service) Close

func (s *Service) Close() error

func (*Service) IsFullySynced

func (s *Service) IsFullySynced() bool

type SyncReporter

type SyncReporter interface {
	// Number of active historical syncing jobs.
	ActiveHistoricalSyncing() uint64
}

SyncReporter interface needs to be implemented by the syncing component of the node (puller).

type Topology

type Topology interface {
	topologyDriver.NeighborhoodDepther
	topologyDriver.SetStorageRadiuser
	topologyDriver.PeersCounter
}

Topology interface encapsulates the functionality required by the topology component of the node.