Documentation ¶
Index ¶
- type Collector
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector struct { // Run UpForSeconds *prometheus.Desc BundlesTakenFromDb *prometheus.Desc AllCheckedBundles *prometheus.Desc FinishedBundles *prometheus.Desc UnfinishedBundles *prometheus.Desc IrysUnfinishedBundles *prometheus.Desc TurboUnfinishedBundles *prometheus.Desc DbStateUpdated *prometheus.Desc IrysGetStatusError *prometheus.Desc TurboGetStatusError *prometheus.Desc DbStateUpdateError *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 ¶
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) GetPrometheusCollector ¶
func (self *Monitor) GetPrometheusCollector() (collector prometheus.Collector)
func (*Monitor) OnGetHealth ¶
func (*Monitor) OnGetState ¶
func (*Monitor) SetPermanentError ¶
Click to show internal directories.
Click to hide internal directories.