prometheus

Documentation

Index

• Constants
• Variables
• 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 Prometheus
  • func (p *Prometheus) Description() string
  • func (p *Prometheus) Gather(_ telegraf.Accumulator) error
  • func (p *Prometheus) SampleConfig() string
  • func (p *Prometheus) Start(accIn telegraf.Accumulator) error
  • func (p *Prometheus) Stop()
• type PrometheusMetric
• type PrometheusMetricBatch
• type ScrapeManager
• type TargetAllocatorManager
  • func (tam *TargetAllocatorManager) AttachReloadConfigHandler(handler func(config *promconfig.Config))
  • func (tam *TargetAllocatorManager) Run() error
  • func (tam *TargetAllocatorManager) Shutdown()

Constants

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

const DEFAULT_TLS_RELOAD_INTERVAL_SECONDS = 10 * time.Second

const (
	MaxDropMetricsLogged = 1000
)

Variables

var DEFAULT_TLS_CA_FILE_PATH = filepath.Join("/etc", "amazon-cloudwatch-observability-agent-cert", "tls-ca.crt")

Functions

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 Prometheus

type Prometheus 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 (*Prometheus) Description

func (p *Prometheus) Description() string

func (*Prometheus) Gather

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

func (*Prometheus) SampleConfig

func (p *Prometheus) SampleConfig() string

func (*Prometheus) Start

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

func (*Prometheus) Stop

func (p *Prometheus) Stop()

type PrometheusMetric

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

type PrometheusMetricBatch

type PrometheusMetricBatch []*PrometheusMetric

type ScrapeManager

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

type TargetAllocatorManager

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

func (*TargetAllocatorManager) AttachReloadConfigHandler

func (tam *TargetAllocatorManager) AttachReloadConfigHandler(handler func(config *promconfig.Config))

func (*TargetAllocatorManager) Run

func (tam *TargetAllocatorManager) Run() error

func (*TargetAllocatorManager) Shutdown

func (tam *TargetAllocatorManager) Shutdown()