monitor_warpy_syncer

Documentation

Index

• type Collector
  • func NewCollector() *Collector
  • func (self *Collector) Collect(ch chan<- prometheus.Metric)
  • func (self *Collector) Describe(ch chan<- *prometheus.Desc)
  • func (self *Collector) WithMonitor(m *Monitor) *Collector
• type Monitor
  • func NewMonitor() (self *Monitor)
  • func (self *Monitor) Clear()
  • func (self *Monitor) GetPrometheusCollector() (collector prometheus.Collector)
  • func (self *Monitor) GetReport() *report.Report
  • func (self *Monitor) IsOK() bool
  • func (self *Monitor) OnGetHealth(c *gin.Context)
  • func (self *Monitor) OnGetState(c *gin.Context)
  • func (self *Monitor) SetPermanentError(err error)

Types

type Collector

type Collector struct {

	// Run
	UpForSeconds *prometheus.Desc

	// Errors
	BlockDownloaderFailures              *prometheus.Desc
	SyncerDeltaCheckTxFailures           *prometheus.Desc
	SyncerDeltaProcessTxPermanentError   *prometheus.Desc
	SyncerDepositProcessTxPermanentError *prometheus.Desc
	SyncerDepositCheckTxFailures         *prometheus.Desc
	SyncerDeltaUpdateSyncStateFailures   *prometheus.Desc
	WriterFailures                       *prometheus.Desc
	StoreGetLastStateFailure             *prometheus.Desc
	StoreSaveLastStateFailure            *prometheus.Desc
	PollerDepositFetchError              *prometheus.Desc
	StoreDepositFailures                 *prometheus.Desc
	AssetsCalculatorFailures             *prometheus.Desc

	// State
	BlockDownloaderCurrentHeight   *prometheus.Desc
	SyncerDeltaTxsProcessed        *prometheus.Desc
	SyncerDeltaBlocksProcessed     *prometheus.Desc
	SyncerDepositTxsProcessed      *prometheus.Desc
	SyncerDepositBlocksProcessed   *prometheus.Desc
	WriterInteractionsToWarpy      *prometheus.Desc
	StoreLastSyncedBlockHeight     *prometheus.Desc
	PollerDepositAssetsFromSelects *prometheus.Desc
	StoreDepositRecordsSaved       *prometheus.Desc
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector() *Collector

func (*Collector) Collect

func (self *Collector) Collect(ch chan<- prometheus.Metric)

Collect implements required collect function for all promehteus collectors

func (*Collector) Describe

func (self *Collector) Describe(ch chan<- *prometheus.Desc)

func (*Collector) WithMonitor

func (self *Collector) WithMonitor(m *Monitor) *Collector

type Monitor

type Monitor struct {
	*task.Task

	Report report.Report

	// Params
	IsFatalError atomic.Bool
	// contains filtered or unexported fields
}

Stores and computes monitor counters

func NewMonitor

func NewMonitor() (self *Monitor)

func (*Monitor) Clear

func (self *Monitor) Clear()

func (*Monitor) GetPrometheusCollector

func (self *Monitor) GetPrometheusCollector() (collector prometheus.Collector)

func (*Monitor) GetReport

func (self *Monitor) GetReport() *report.Report

func (*Monitor) IsOK

func (self *Monitor) IsOK() bool

func (*Monitor) OnGetHealth

func (self *Monitor) OnGetHealth(c *gin.Context)

func (*Monitor) OnGetState

func (self *Monitor) OnGetState(c *gin.Context)

func (*Monitor) SetPermanentError

func (self *Monitor) SetPermanentError(err error)