metrics

Documentation

Index

• func GenerateEnhancedMetricsFromFunctionLog(logString string, time time.Time, tags []string, ...)
• func GenerateEnhancedMetricsFromReportLog(initDurationMs float64, durationMs float64, billedDurationMs int, ...)
• func GenerateRuntimeDurationMetric(start time.Time, end time.Time, status string, tags []string, ...)
• func SendTimeoutEnhancedMetric(tags []string, metricsChan chan []metrics.MetricSample)
• type DogStatsDFactory
• type MetricConfig
  • func (m *MetricConfig) GetMultipleEndpoints() (map[string][]string, error)
• type MetricDogStatsD
  • func (m *MetricDogStatsD) NewServer(aggregator *aggregator.BufferedAggregator, extraTags []string) (*dogstatsd.Server, error)
• type MultipleEndpointConfig
• type ServerlessMetricAgent
  • func (c *ServerlessMetricAgent) Flush()
  • func (c *ServerlessMetricAgent) GetMetricChannel() chan []metrics.MetricSample
  • func (c *ServerlessMetricAgent) IsReady() bool
  • func (c *ServerlessMetricAgent) SetExtraTags(tagArray []string)
  • func (c *ServerlessMetricAgent) Start(forwarderTimeout time.Duration, multipleEndpointConfig MultipleEndpointConfig, ...)
  • func (c *ServerlessMetricAgent) Stop()

Functions

func GenerateEnhancedMetricsFromFunctionLog

func GenerateEnhancedMetricsFromFunctionLog(logString string, time time.Time, tags []string, metricsChan chan []metrics.MetricSample)

GenerateEnhancedMetricsFromFunctionLog generates enhanced metrics from a LogTypeFunction message

func GenerateEnhancedMetricsFromReportLog

func GenerateEnhancedMetricsFromReportLog(initDurationMs float64, durationMs float64, billedDurationMs int, memorySizeMb int, maxMemoryUsedMb int, time time.Time, tags []string, metricsChan chan []metrics.MetricSample)

GenerateEnhancedMetricsFromReportLog generates enhanced metrics from a LogTypePlatformReport log message

func GenerateRuntimeDurationMetric

func GenerateRuntimeDurationMetric(start time.Time, end time.Time, status string, tags []string, metricsChan chan []metrics.MetricSample)

GenerateRuntimeDurationMetric generates the runtime duration metric

func SendTimeoutEnhancedMetric

func SendTimeoutEnhancedMetric(tags []string, metricsChan chan []metrics.MetricSample)

SendTimeoutEnhancedMetric sends an enhanced metric representing a timeout

Types

type DogStatsDFactory

type DogStatsDFactory interface {
	NewServer(aggregator *aggregator.BufferedAggregator, extraTags []string) (*dogstatsd.Server, error)
}

DogStatsDFactory allows create a new DogStatsD server

type MetricConfig

type MetricConfig struct {
}

MetricConfig abstacts the config package

func (*MetricConfig) GetMultipleEndpoints

func (m *MetricConfig) GetMultipleEndpoints() (map[string][]string, error)

GetMultipleEndpoints returns the api keys per domain specified in the main agent config

type MetricDogStatsD

type MetricDogStatsD struct {
}

MetricDogStatsD abstracts the DogStatsD package

func (*MetricDogStatsD) NewServer

func (m *MetricDogStatsD) NewServer(aggregator *aggregator.BufferedAggregator, extraTags []string) (*dogstatsd.Server, error)

NewServer returns a running DogStatsD server

type MultipleEndpointConfig

type MultipleEndpointConfig interface {
	GetMultipleEndpoints() (map[string][]string, error)
}

MultipleEndpointConfig abstracts the config package

type ServerlessMetricAgent

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

ServerlessMetricAgent represents the DogStatsD server and the aggregator

func (*ServerlessMetricAgent) Flush

func (c *ServerlessMetricAgent) Flush()

Flush triggers a DogStatsD flush

func (*ServerlessMetricAgent) GetMetricChannel

func (c *ServerlessMetricAgent) GetMetricChannel() chan []metrics.MetricSample

GetMetricChannel returns a channel where metrics can be sent to

func (*ServerlessMetricAgent) IsReady

func (c *ServerlessMetricAgent) IsReady() bool

IsReady indicates whether or not the DogStatsD server is ready

func (*ServerlessMetricAgent) SetExtraTags

func (c *ServerlessMetricAgent) SetExtraTags(tagArray []string)

SetExtraTags sets extra tags on the DogStatsD server

func (*ServerlessMetricAgent) Start

func (c *ServerlessMetricAgent) Start(forwarderTimeout time.Duration, multipleEndpointConfig MultipleEndpointConfig, dogstatFactory DogStatsDFactory)

Start starts the DogStatsD agent

func (*ServerlessMetricAgent) Stop

func (c *ServerlessMetricAgent) Stop()

Stop stops the DogStatsD server