opentelemetry

Documentation

Index

• func NewEncodeOtlpLogs(opMetrics *operational.Metrics, params config.StageParam) (encode.Encoder, error)
• func NewEncodeOtlpMetrics(opMetrics *operational.Metrics, params config.StageParam) (encode.Encoder, error)
• func NewEncodeOtlpTraces(opMetrics *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
  • func (e *EncodeOtlpLogs) Encode(entry config.GenericMap)
  • func (e *EncodeOtlpLogs) LogWrite(entry config.GenericMap)
• type EncodeOtlpMetrics
  • func (e *EncodeOtlpMetrics) Cleanup(cleanupFunc interface{})
  • func (e *EncodeOtlpMetrics) Encode(metricRecord config.GenericMap)
  • func (e *EncodeOtlpMetrics) MetricWrite(entry config.GenericMap)
• type EncodeOtlpTrace
  • func (e *EncodeOtlpTrace) Encode(entry config.GenericMap)
• type Float64Gauge
  • func (f *Float64Gauge) Callback(ctx context.Context, o metric.Float64Observer) error
  • func (f *Float64Gauge) Set(key string, val float64, attrs []attribute.KeyValue)
• type Float64GaugeEntry

Functions

func NewEncodeOtlpLogs

func NewEncodeOtlpLogs(opMetrics *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(opMetrics *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)

type EncodeOtlpMetrics

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

func (*EncodeOtlpMetrics) Cleanup

func (e *EncodeOtlpMetrics) Cleanup(cleanupFunc interface{})

Cleanup - callback function from lru cleanup

func (*EncodeOtlpMetrics) Encode

func (e *EncodeOtlpMetrics) Encode(metricRecord config.GenericMap)

Encode encodes a metric to be exported

func (*EncodeOtlpMetrics) MetricWrite

func (e *EncodeOtlpMetrics) MetricWrite(entry config.GenericMap)

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

type Float64Gauge

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

func (*Float64Gauge) Callback

func (f *Float64Gauge) Callback(ctx 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.

func (*Float64Gauge) Set

func (f *Float64Gauge) Set(key string, val float64, attrs []attribute.KeyValue)

type Float64GaugeEntry

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