sources

Dec 1, 2022

Changes in this version

type SourceManager

+ SetClient func(kubernetes.Interface)

Apr 22, 2021

Changes in this version

+ type IntervalTimer struct

+ func NewIntervalTimer(interval time.Duration) *IntervalTimer

+ func (t *IntervalTimer) Reset() (intervalsMissed int64)

Oct 23, 2019

Changes in this version

+ type SourceManager interface

+ BuildProviders func(config configuration.SourceConfig) error

+ GetPendingMetrics func() []*metrics.DataBatch

+ SetDefaultCollectionInterval func(time.Duration)

+ StopProviders func()

+ func Manager() SourceManager

Jan 3, 2019

Changes in this version

+ const DefaultMetricsScrapeTimeout

+ const DelayPerSourceMs

+ const MaxDelayMs

+ func NewSourceManager(metricsSourceProviders []MetricsSourceProvider, ...) (MetricsSource, error)

+ type SourceFactory struct

+ func NewSourceFactory() *SourceFactory

+ func (sf *SourceFactory) Build(uri flags.Uri) (metrics.MetricsSourceProvider, error)

+ func (sf *SourceFactory) BuildAll(uris flags.Uris) []metrics.MetricsSourceProvider