Documentation
¶
Index ¶
- func Format(writer io.Writer, metrics []Metric) error
- func IsRunning() bool
- func Run(port uint16, endpointName string) error
- func Send(metric *Metric)
- func SendHistogrammable(metric *Metric)
- func Stop()
- func TimerMS(metric *Metric) func()
- func TimerNS(metric *Metric) func()
- type FieldsType
- type Metric
- func (metric *Metric) AddTag(tagName string, value string)
- func (metric *Metric) MergeFields(other *Metric)
- func (metric *Metric) SetFieldFloat64(fieldName string, field float64)
- func (metric *Metric) SetFieldInt64(fieldName string, field int64)
- func (metric *Metric) SetFieldUInt64(fieldName string, field uint64)
- type MetricsAggregate
- type MetricsReservoirSampling
- type Tag
- type TagsType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Run ¶ added in v1.27.0
\param port port where the scraping endpoint will be created \param endpointName name of the endpoint, which must start with a slash eg. "/internalmetrics"
If we attempt send more messages than the size of the buffer, these overflowing messages will be ignored and warning will be logged.
func SendHistogrammable ¶ added in v1.35.0
func SendHistogrammable(metric *Metric)
Types ¶
type FieldsType ¶ added in v1.35.0
type Metric ¶
type Metric struct {
// contains filtered or unexported fields
}
func NewDefaultMetric ¶ added in v1.35.0
Return empty metric, it is used right now mostly in string to report metrics correctly to influxdb use NewECSMetric
func NewMetric ¶ added in v1.35.0
creates empty metric with tag subsystem=ECS, which is used by Telegraf to send metrics from ECS to correct bucket
func (*Metric) MergeFields ¶ added in v1.35.0
func (*Metric) SetFieldFloat64 ¶ added in v1.35.0
func (*Metric) SetFieldInt64 ¶ added in v1.35.0
func (*Metric) SetFieldUInt64 ¶ added in v1.35.0
type MetricsAggregate ¶ added in v1.35.0
type MetricsAggregate struct {
// contains filtered or unexported fields
}
func NewMetricsAggregate ¶ added in v1.35.0
func NewMetricsAggregate() *MetricsAggregate
func (*MetricsAggregate) AddMetric ¶ added in v1.35.0
func (this *MetricsAggregate) AddMetric(metric *Metric)
func (*MetricsAggregate) Clear ¶ added in v1.35.0
func (this *MetricsAggregate) Clear()
func (*MetricsAggregate) GetMetrics ¶ added in v1.35.0
func (this *MetricsAggregate) GetMetrics() []Metric
type MetricsReservoirSampling ¶ added in v1.35.0
type MetricsReservoirSampling struct {
// contains filtered or unexported fields
}
func NewMetricsReservoirSampling ¶ added in v1.35.0
func NewMetricsReservoirSampling() *MetricsReservoirSampling
func (*MetricsReservoirSampling) AddMetric ¶ added in v1.35.0
func (this *MetricsReservoirSampling) AddMetric(metric *Metric)
func (*MetricsReservoirSampling) Clear ¶ added in v1.35.0
func (this *MetricsReservoirSampling) Clear()
func (*MetricsReservoirSampling) GetMetrics ¶ added in v1.35.0
func (this *MetricsReservoirSampling) GetMetrics() []Metric
Source Files
Click to show internal directories.
Click to hide internal directories.