Versions in this module Expand all Collapse all v14 v14.2.0 May 9, 2022 Changes in this version + func Create(server *veneur.Server, name string, logger *logrus.Entry, ...) (sources.Source, error) + func ParseConfig(name string, config interface{}) (veneur.ParsedSourceConfig, error) + type OpenMetricsSource struct + Denylist *regexp.Regexp + HttpClient *http.Client + ScrapeTarget *url.URL + ScrapeTimeout time.Duration + func (source *OpenMetricsSource) Convert(prometheusResults <-chan QueryResults) <-chan *convertResults + func (source *OpenMetricsSource) Query(ctx context.Context) (<-chan QueryResults, error) + func (source OpenMetricsSource) Name() string + func (source OpenMetricsSource) Start(ingest sources.Ingest) error + func (source OpenMetricsSource) Stop() + type OpenMetricsSourceConfig struct + Allowlist util.Regexp + Denylist util.Regexp + HistogramBucketTag string + ScrapeInterval time.Duration + ScrapeTarget util.Url + ScrapeTimeout time.Duration + SummaryQuantileTag string + type QueryResults struct + Error error + MetricFamily dto.MetricFamily