controller

May 18, 2024

Changes in this version

+ const MetricSubsystem

+ var MetricEndpoints = metrics.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var MetricLastRunDurationSeconds = metrics.NewGauge(prometheus.GaugeOpts{ ... })

+ var MetricLastRunTimestamp = metrics.NewGauge(prometheus.GaugeOpts{ ... })

+ var MetricProviderUp = metrics.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var MetricRunDurationSeconds = metrics.NewHistogram(prometheus.HistogramOpts{ ... })

+ var MetricRuns = metrics.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var MetricSourceUp = metrics.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

Mar 4, 2023

Changes in this version

type Controller

+ Logger *zap.Logger

Mar 4, 2023

Changes in this version

+ type Controller struct

+ Interval time.Duration

+ Providers []provider.Provider

+ Sources []source.Source

+ func (c *Controller) Run(ctx context.Context)

+ func (c *Controller) RunOnce(ctx context.Context) error

+ func (c *Controller) ScheduleRunOnce(now time.Time)

+ func (c *Controller) ShouldRunOnce(now time.Time) bool