Documentation
¶
Index ¶
- func Abs[T GaugeValue](value T) T
- func AggregateCounter[T CounterValue](aggregate *CounterAggregate[T], startTS pcommon.Timestamp, ...)
- func AggregateGauge[T GaugeValue](aggregate *GaugeAggregate[T], startTS pcommon.Timestamp, value T)
- func AggregateHistogram(aggregate *HistogramAggregate, value pmetric.HistogramDataPoint) int16
- func CompareFloat64SlicesEqual(a, b []float64) bool
- func CreateArgument(metricArg MetricArg) pmetric.Metrics
- func CreateCounterMetrics[T GaugeValue](scope pmetric.ScopeMetrics, aggregate *CounterAggregate[T], ...)
- func CreateGaugeMetrics[T GaugeValue](scope pmetric.ScopeMetrics, aggregate *GaugeAggregate[T], ...)
- func CreateHistogramMetrics(scope pmetric.ScopeMetrics, aggregate *HistogramAggregate, ...)
- func CreateMetricKey(metric pmetric.Metric, attributes pcommon.Map) string
- func CreateScopeKey(scopeMetric pmetric.ScopeMetrics) string
- func NewFactory() processor.Factory
- func ValidateCounter(t *testing.T, metric pmetric.Metric, wasChecked *bool, isCumulative bool, ...)
- func ValidateDoubleCounter(t *testing.T, metric pmetric.Metric, wasChecked *bool, isCumulative bool, ...)
- func ValidateDoubleGauge(t *testing.T, metric pmetric.Metric, wasChecked *bool, value float64, ...)
- func ValidateGauge(t *testing.T, metric pmetric.Metric, wasChecked *bool, ...)
- func ValidateHistogram(t *testing.T, metric pmetric.Metric, wasChecked *bool, isCumulative bool, ...)
- func ValidateIntCounter(t *testing.T, metric pmetric.Metric, wasChecked *bool, isCumulative bool, ...)
- func ValidateIntGauge(t *testing.T, metric pmetric.Metric, wasChecked *bool, value int64, ...)
- type Config
- type CounterAggregate
- type CounterArg
- type CounterValue
- type GaugeAggregate
- type GaugeArg
- type GaugeValue
- type HistogramAggregate
- type HistogramArg
- type HistogramValue
- type MetricArg
- type ProcessedConfig
- type ReduceResolution
- type ResourceMetricsArg
- type ScopeArg
- type ScopeContainer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Abs ¶ added in v0.3.0
func Abs[T GaugeValue](value T) T
func AggregateCounter ¶
func AggregateCounter[T CounterValue](aggregate *CounterAggregate[T], startTS pcommon.Timestamp, lastTS pcommon.Timestamp, value T)
func AggregateGauge ¶
func AggregateGauge[T GaugeValue](aggregate *GaugeAggregate[T], startTS pcommon.Timestamp, value T)
func AggregateHistogram ¶ added in v0.2.0
func AggregateHistogram(aggregate *HistogramAggregate, value pmetric.HistogramDataPoint) int16
func CompareFloat64SlicesEqual ¶ added in v0.2.1
func CreateArgument ¶
func CreateCounterMetrics ¶
func CreateCounterMetrics[T GaugeValue](scope pmetric.ScopeMetrics, aggregate *CounterAggregate[T], aggregationTS pcommon.Timestamp)
func CreateGaugeMetrics ¶
func CreateGaugeMetrics[T GaugeValue](scope pmetric.ScopeMetrics, aggregate *GaugeAggregate[T], aggregationTS pcommon.Timestamp, p *ReduceResolution)
func CreateHistogramMetrics ¶ added in v0.2.0
func CreateHistogramMetrics(scope pmetric.ScopeMetrics, aggregate *HistogramAggregate, aggregationTS pcommon.Timestamp)
func CreateMetricKey ¶
Creates a unique deterministic key based on a metric's name, and its attributes
func CreateScopeKey ¶
func CreateScopeKey(scopeMetric pmetric.ScopeMetrics) string
Creates a unique deterministic key based on a scope's name, version, and its attributes
func NewFactory ¶
NewFactory creates a factory for the metric logging processor
func ValidateCounter ¶
func ValidateDoubleCounter ¶
func ValidateDoubleGauge ¶
func ValidateGauge ¶
func ValidateHistogram ¶ added in v0.2.0
func ValidateIntCounter ¶
Types ¶
type CounterAggregate ¶
type CounterAggregate[T CounterValue] struct { // contains filtered or unexported fields }
func CreateCounterAggregate ¶
func CreateCounterAggregate[T CounterValue](metric pmetric.Metric, attributes pcommon.Map, startTS pcommon.Timestamp, lastTS pcommon.Timestamp, value T) *CounterAggregate[T]
type CounterArg ¶
type CounterArg[T CounterValue] struct { // contains filtered or unexported fields }
type CounterValue ¶
type GaugeAggregate ¶
type GaugeAggregate[T GaugeValue] struct { // contains filtered or unexported fields }
func CreateGaugeAggregate ¶
func CreateGaugeAggregate[T GaugeValue](metric pmetric.Metric, attributes pcommon.Map, startTS pcommon.Timestamp, value T) *GaugeAggregate[T]
type GaugeArg ¶
type GaugeArg[T GaugeValue] struct { // contains filtered or unexported fields }
type GaugeValue ¶
type HistogramAggregate ¶ added in v0.2.0
type HistogramAggregate struct {
// contains filtered or unexported fields
}
func CreateHistogramAggregate ¶ added in v0.2.0
func CreateHistogramAggregate(metric pmetric.Metric, value pmetric.HistogramDataPoint) *HistogramAggregate
type HistogramArg ¶ added in v0.2.0
type HistogramArg struct {
// contains filtered or unexported fields
}
type HistogramValue ¶ added in v0.2.0
type HistogramValue struct {
// contains filtered or unexported fields
}
type ProcessedConfig ¶ added in v0.3.0
type ReduceResolution ¶
type ReduceResolution struct {
Logger *zap.Logger
Config ProcessedConfig
}
func (*ReduceResolution) ProcessMetrics ¶
func (p *ReduceResolution) ProcessMetrics(_ context.Context, metrics pmetric.Metrics) (pmetric.Metrics, error)
ProcessMetrics logs information about incoming metrics
type ResourceMetricsArg ¶
type ResourceMetricsArg struct {
// contains filtered or unexported fields
}
type ScopeContainer ¶
type ScopeContainer struct {
// contains filtered or unexported fields
}
func CreateScopeContainer ¶
func CreateScopeContainer(scopeMetric pmetric.ScopeMetrics) *ScopeContainer
Source Files
Click to show internal directories.
Click to hide internal directories.