Documentation
¶
Index ¶
- func NewEncodeOtlpLogs(_ *operational.Metrics, params config.StageParam) (encode.Encoder, error)
- func NewEncodeOtlpMetrics(opMetrics *operational.Metrics, params config.StageParam) (encode.Encoder, error)
- func NewEncodeOtlpTraces(_ *operational.Metrics, params config.StageParam) (encode.Encoder, error)
- func NewOtlpLoggerProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdklog2.LoggerProvider, error)
- func NewOtlpMetricsProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdkmetric.MeterProvider, error)
- func NewOtlpTracerProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdktrace.TracerProvider, error)
- type EncodeOtlpLogs
- type EncodeOtlpMetrics
- func (e *EncodeOtlpMetrics) Encode(metricRecord config.GenericMap)
- func (e *EncodeOtlpMetrics) GetChacheEntry(entryLabels map[string]string, _ interface{}) interface{}
- func (e *EncodeOtlpMetrics) MetricWrite(_ config.GenericMap)
- func (e *EncodeOtlpMetrics) ProcessAggHist(m interface{}, labels map[string]string, values []float64) error
- func (e *EncodeOtlpMetrics) ProcessCounter(m interface{}, labels map[string]string, value float64) error
- func (e *EncodeOtlpMetrics) ProcessGauge(m interface{}, labels map[string]string, value float64, key string) error
- func (e *EncodeOtlpMetrics) ProcessHist(m interface{}, labels map[string]string, value float64) error
- func (e *EncodeOtlpMetrics) Update(_ config.StageParam)
- type EncodeOtlpTrace
- type Float64Gauge
- type Float64GaugeEntry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEncodeOtlpLogs ¶
func NewEncodeOtlpLogs(_ *operational.Metrics, params config.StageParam) (encode.Encoder, error)
func NewEncodeOtlpMetrics ¶
func NewEncodeOtlpMetrics(opMetrics *operational.Metrics, params config.StageParam) (encode.Encoder, error)
func NewEncodeOtlpTraces ¶
func NewEncodeOtlpTraces(_ *operational.Metrics, params config.StageParam) (encode.Encoder, error)
func NewOtlpLoggerProvider ¶
func NewOtlpLoggerProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdklog2.LoggerProvider, error)
func NewOtlpMetricsProvider ¶
func NewOtlpMetricsProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdkmetric.MeterProvider, error)
func NewOtlpTracerProvider ¶
func NewOtlpTracerProvider(ctx context.Context, params config.StageParam, res *resource.Resource) (*sdktrace.TracerProvider, error)
Types ¶
type EncodeOtlpLogs ¶
type EncodeOtlpLogs struct {
// contains filtered or unexported fields
}
func (*EncodeOtlpLogs) Encode ¶
func (e *EncodeOtlpLogs) Encode(entry config.GenericMap)
Encode encodes a log entry to be exported
func (*EncodeOtlpLogs) LogWrite ¶
func (e *EncodeOtlpLogs) LogWrite(entry config.GenericMap)
func (*EncodeOtlpLogs) Update ¶
func (e *EncodeOtlpLogs) Update(_ config.StageParam)
type EncodeOtlpMetrics ¶
type EncodeOtlpMetrics struct {
// contains filtered or unexported fields
}
func (*EncodeOtlpMetrics) Encode ¶
func (e *EncodeOtlpMetrics) Encode(metricRecord config.GenericMap)
Encode encodes a metric to be exported
func (*EncodeOtlpMetrics) GetChacheEntry ¶
func (e *EncodeOtlpMetrics) GetChacheEntry(entryLabels map[string]string, _ interface{}) interface{}
func (*EncodeOtlpMetrics) MetricWrite ¶
func (e *EncodeOtlpMetrics) MetricWrite(_ config.GenericMap)
func (*EncodeOtlpMetrics) ProcessAggHist ¶
func (e *EncodeOtlpMetrics) ProcessAggHist(m interface{}, labels map[string]string, values []float64) error
func (*EncodeOtlpMetrics) ProcessCounter ¶
func (e *EncodeOtlpMetrics) ProcessCounter(m interface{}, labels map[string]string, value float64) error
func (*EncodeOtlpMetrics) ProcessGauge ¶
func (*EncodeOtlpMetrics) ProcessHist ¶
func (e *EncodeOtlpMetrics) ProcessHist(m interface{}, labels map[string]string, value float64) error
func (*EncodeOtlpMetrics) Update ¶
func (e *EncodeOtlpMetrics) Update(_ config.StageParam)
type EncodeOtlpTrace ¶
type EncodeOtlpTrace struct {
// contains filtered or unexported fields
}
func (*EncodeOtlpTrace) Encode ¶
func (e *EncodeOtlpTrace) Encode(entry config.GenericMap)
Encode encodes a metric to be exported
func (*EncodeOtlpTrace) Update ¶
func (e *EncodeOtlpTrace) Update(_ config.StageParam)
type Float64Gauge ¶
type Float64Gauge struct {
// contains filtered or unexported fields
}
func (*Float64Gauge) Callback ¶
func (f *Float64Gauge) Callback(_ context.Context, o metric.Float64Observer) error
Callback implements the callback function for the underlying asynchronous gauge it observes the current state of all previous Set() calls.
type Float64GaugeEntry ¶
type Float64GaugeEntry struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.