Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + type AddSampleTelemetry struct + Stateful telemetry.SimpleCounter + Stateless telemetry.SimpleCounter + Total telemetry.SimpleCounter + func (a *AddSampleTelemetry) Inc(isStateful bool) + type CheckMetrics struct + func NewCheckMetrics(expireMetrics bool, statefulTimeout time.Duration) CheckMetrics + func (cm *CheckMetrics) AddSample(contextKey ckey.ContextKey, sample *MetricSample, timestamp float64, ...) error + func (cm *CheckMetrics) Expire(contextKeys []ckey.ContextKey, timestamp float64) + func (cm *CheckMetrics) Flush(timestamp float64) ([]*Serie, map[ckey.ContextKey]error) + func (cm *CheckMetrics) RemoveExpired(timestamp float64) + type CheckMetricsTelemetryAccumulator struct + func (c *CheckMetricsTelemetryAccumulator) Flush() + func (c *CheckMetricsTelemetryAccumulator) VisitCheckMetrics(cm *CheckMetrics) type Event + Cardinality string + K8sOriginID string + OriginID string type Events + func (events Events) MarshalSplitCompress(bufferContext *marshaler.BufferContext) ([]*[]byte, error) type HistogramBucket + FlushFirstValue bool type MetricSample + Cardinality string + FlushFirstValue bool + K8sOriginID string + OriginID string type Series + func (series Series) MarshalSplitCompress(bufferContext *marshaler.BufferContext) ([]*[]byte, error) + func (series Series) MarshalStrings() ([]string, [][]string) type ServiceCheck + Cardinality string + K8sOriginID string + OriginID string type ServiceChecks + func (sc ServiceChecks) MarshalSplitCompress(bufferContext *marshaler.BufferContext) ([]*[]byte, error) + func (sc ServiceChecks) MarshalStrings() ([]string, [][]string) type SketchSeriesList + func (sl SketchSeriesList) MarshalSplitCompress(bufferContext *marshaler.BufferContext) ([]*[]byte, error) v0.8.0 Jul 23, 2020retracted Changes in this version + var DistributionMetricTypes = map[MetricType]struct + func AssertPointsEqual(t *testing.T, expected, actual []Point) + func AssertSerieEqual(t *testing.T, expected, actual *Serie) + func AssertSeriesEqual(t *testing.T, expected Series, series Series) + func AssertSketchSeriesApproxEqual(t assert.TestingT, exp, act SketchSeries, e float64) + func AssertSketchSeriesEqual(t assert.TestingT, exp, act SketchSeries) + func AssertTagsEqual(t assert.TestingT, expected, actual []string) + type APIMetricType int + const APICountType + const APIGaugeType + const APIRateType + func (a *APIMetricType) UnmarshalText(buf []byte) error + func (a APIMetricType) MarshalText() ([]byte, error) + func (a APIMetricType) String() string + type ContextMetrics map[ckey.ContextKey]Metric + func MakeContextMetrics() ContextMetrics + func (m ContextMetrics) AddSample(contextKey ckey.ContextKey, sample *MetricSample, timestamp float64, ...) error + func (m ContextMetrics) Flush(timestamp float64) ([]*Serie, map[ckey.ContextKey]error) + type Count struct + type Counter struct + func NewCounter(interval int64) *Counter + type Event struct + AggregationKey string + AlertType EventAlertType + EventType string + Host string + Priority EventPriority + SourceTypeName string + Tags []string + Text string + Title string + Ts int64 + func (e *Event) String() string + type EventAlertType string + const EventAlertTypeError + const EventAlertTypeInfo + const EventAlertTypeSuccess + const EventAlertTypeWarning + func GetAlertTypeFromString(val string) (EventAlertType, error) + type EventPriority string + const EventPriorityLow + const EventPriorityNormal + func GetEventPriorityFromString(val string) (EventPriority, error) + type Events []*Event + func (events Events) CreateMarshalersBySourceType() []marshaler.StreamJSONMarshaler + func (events Events) CreateSingleMarshaler() marshaler.StreamJSONMarshaler + func (events Events) Marshal() ([]byte, error) + func (events Events) MarshalJSON() ([]byte, error) + func (events Events) SplitPayload(times int) ([]marshaler.Marshaler, error) + type Gauge struct + type Histogram struct + func NewHistogram(interval int64) *Histogram + type HistogramBucket struct + Host string + LowerBound float64 + Monotonic bool + Name string + Tags []string + Timestamp float64 + UpperBound float64 + Value int64 + func (m *HistogramBucket) GetHost() string + func (m *HistogramBucket) GetName() string + func (m *HistogramBucket) GetTags() []string + type Historate struct + func NewHistorate(interval int64) *Historate + type Metric interface + type MetricSample struct + Host string + Mtype MetricType + Name string + RawValue string + SampleRate float64 + Tags []string + Timestamp float64 + Value float64 + func (m *MetricSample) Copy() *MetricSample + func (m *MetricSample) GetHost() string + func (m *MetricSample) GetName() string + func (m *MetricSample) GetTags() []string + type MetricSampleContext interface + GetHost func() string + GetName func() string + GetTags func() []string + type MetricSamplePool struct + func NewMetricSamplePool(batchSize int) *MetricSamplePool + func (m *MetricSamplePool) GetBatch() []MetricSample + func (m *MetricSamplePool) PutBatch(batch []MetricSample) + type MetricType int + const CountType + const CounterType + const DistributionType + const GaugeType + const HistogramType + const HistorateType + const MonotonicCountType + const RateType + const SetType + func (m MetricType) String() string + type MonotonicCount struct + type NoSerieError struct + func (e NoSerieError) Error() string + type Point struct + Ts float64 + Value float64 + func (p *Point) MarshalJSON() ([]byte, error) + func (p *Point) UnmarshalJSON(buf []byte) error + type Rate struct + type Serie struct + ContextKey ckey.ContextKey + Device string + Host string + Interval int64 + MType APIMetricType + Name string + NameSuffix string + Points []Point + SourceTypeName string + Tags []string + func (e Serie) String() string + type Series []*Serie + func (series Series) DescribeItem(i int) string + func (series Series) Len() int + func (series Series) Marshal() ([]byte, error) + func (series Series) MarshalJSON() ([]byte, error) + func (series Series) SplitPayload(times int) ([]marshaler.Marshaler, error) + func (series Series) WriteFooter(stream *jsoniter.Stream) error + func (series Series) WriteHeader(stream *jsoniter.Stream) error + func (series Series) WriteItem(stream *jsoniter.Stream, i int) error + type ServiceCheck struct + CheckName string + Host string + Message string + Status ServiceCheckStatus + Tags []string + Ts int64 + func (sc ServiceCheck) String() string + type ServiceCheckStatus int + const ServiceCheckCritical + const ServiceCheckOK + const ServiceCheckUnknown + const ServiceCheckWarning + func GetServiceCheckStatus(val int) (ServiceCheckStatus, error) + func (s ServiceCheckStatus) String() string + type ServiceChecks []*ServiceCheck + func (sc ServiceChecks) DescribeItem(i int) string + func (sc ServiceChecks) Len() int + func (sc ServiceChecks) Marshal() ([]byte, error) + func (sc ServiceChecks) MarshalJSON() ([]byte, error) + func (sc ServiceChecks) SplitPayload(times int) ([]marshaler.Marshaler, error) + func (sc ServiceChecks) WriteFooter(stream *jsoniter.Stream) error + func (sc ServiceChecks) WriteHeader(stream *jsoniter.Stream) error + func (sc ServiceChecks) WriteItem(stream *jsoniter.Stream, i int) error + type Set struct + func NewSet() *Set + type SketchPoint struct + Sketch *quantile.Sketch + Ts int64 + type SketchSeries struct + ContextKey ckey.ContextKey + Host string + Interval int64 + Name string + Points []SketchPoint + Tags []string + type SketchSeriesList []SketchSeries + func (sl SketchSeriesList) Marshal() ([]byte, error) + func (sl SketchSeriesList) MarshalJSON() ([]byte, error) + func (sl SketchSeriesList) SplitPayload(times int) ([]marshaler.Marshaler, error) Other modules containing this package github.com/DataDog/datadog-agent/pkg/metrics
Go to main page