monitor

Documentation

Index

• type Config
  • func NewConfig() (conf Config)
• type Monitor
  • func NewMonitor(cfg Config, latestHeightFunc func() (uint64, error)) *Monitor
  • func (m *Monitor) Start(ctx context.Context)
  • func (m *Monitor) Stop()
  • func (m *Monitor) Update(newHeight uint64)

Types

type Config

type Config struct {
	// Health check configuration
	Health health.CounterConfig

	// Maximum allowable duration for sync height to remain unchanged.
	MaxStalledDuration time.Duration `default:"5m"`
	// Maximum allowed lag in height between the latest chain height and the sync height.
	MaxAllowedLag uint64 `default:"200"`
}

Config holds the configuration parameters for the sync monitor.

func NewConfig

func NewConfig() (conf Config)

NewConfig returns a new Config with default values.

type Monitor

type Monitor struct {
	Config
	// contains filtered or unexported fields
}

Monitor periodically checks sync height growth.

func NewMonitor

func NewMonitor(cfg Config, latestHeightFunc func() (uint64, error)) *Monitor

func (*Monitor) Start

func (m *Monitor) Start(ctx context.Context)

Start begins the monitoring process by checking sync status periodically.

func (*Monitor) Stop

func (m *Monitor) Stop()

Stop halts the monitoring process.

func (*Monitor) Update

func (m *Monitor) Update(newHeight uint64)

Update updates the current sync height.