prometheus_scraper

Documentation

Index

• Constants
• func GetScrapeTargetInfo(pmb PrometheusMetricBatch) (string, string, error)
• func NewMetricsTypeHandler() *metricsTypeHandler
• func Start(configFilePath string, receiver storage.Appendable, ...)
• type Calculator
  • func NewCalculator() *Calculator
  • func (c *Calculator) Calculate(pmb PrometheusMetricBatch) (result PrometheusMetricBatch)
• type DeltaCalculator
  • func NewDeltaCalculator() *DeltaCalculator
• type MetricsFilter
  • func NewMetricsFilter() *MetricsFilter
  • func (mf *MetricsFilter) Filter(pmb PrometheusMetricBatch) (result PrometheusMetricBatch)
• type PrometheusMetric
• type PrometheusMetricBatch
• type PrometheusScraper
  • func (p *PrometheusScraper) Description() string
  • func (p *PrometheusScraper) Gather(_ telegraf.Accumulator) error
  • func (p *PrometheusScraper) SampleConfig() string
  • func (p *PrometheusScraper) Start(accIn telegraf.Accumulator) error
  • func (p *PrometheusScraper) Stop()
• type ScrapeManager

Constants

const (
	CleanUpTimeThreshold = 60 * 1000       // 1 minute
	CacheTTL             = 5 * time.Minute // 5 minutes
)

const (
	MaxDropMetricsLogged = 1000
)

Functions

func GetScrapeTargetInfo

func GetScrapeTargetInfo(pmb PrometheusMetricBatch) (string, string, error)

Return JobName and Instance

func NewMetricsTypeHandler

func NewMetricsTypeHandler() *metricsTypeHandler

func Start

func Start(configFilePath string, receiver storage.Appendable, shutDownChan chan interface{}, wg *sync.WaitGroup, mth *metricsTypeHandler)

Types

type Calculator

type Calculator struct {
	// contains filtered or unexported fields
}

func NewCalculator

func NewCalculator() *Calculator

func (*Calculator) Calculate

func (c *Calculator) Calculate(pmb PrometheusMetricBatch) (result PrometheusMetricBatch)

Do calculation based on metric type

type DeltaCalculator

type DeltaCalculator struct {
	// contains filtered or unexported fields
}

func NewDeltaCalculator

func NewDeltaCalculator() *DeltaCalculator

type MetricsFilter

type MetricsFilter struct {
	// contains filtered or unexported fields
}

func NewMetricsFilter

func NewMetricsFilter() *MetricsFilter

func (*MetricsFilter) Filter

func (mf *MetricsFilter) Filter(pmb PrometheusMetricBatch) (result PrometheusMetricBatch)

Filter out and Log the unsupported metric types

type PrometheusMetric

type PrometheusMetric struct {
	// contains filtered or unexported fields
}

type PrometheusMetricBatch

type PrometheusMetricBatch []*PrometheusMetric

type PrometheusScraper

type PrometheusScraper struct {
	PrometheusConfigPath string                                      `toml:"prometheus_config_path"`
	ClusterName          string                                      `toml:"cluster_name"`
	ECSSDConfig          *ecsservicediscovery.ServiceDiscoveryConfig `toml:"ecs_service_discovery"`
	// contains filtered or unexported fields
}

func (*PrometheusScraper) Description

func (p *PrometheusScraper) Description() string

func (*PrometheusScraper) Gather

func (p *PrometheusScraper) Gather(_ telegraf.Accumulator) error

func (*PrometheusScraper) SampleConfig

func (p *PrometheusScraper) SampleConfig() string

func (*PrometheusScraper) Start

func (p *PrometheusScraper) Start(accIn telegraf.Accumulator) error

func (*PrometheusScraper) Stop

func (p *PrometheusScraper) Stop()

type ScrapeManager

type ScrapeManager interface {
	TargetsAll() map[string][]*scrape.Target
}