influx2otel

README

InfluxDB Line Protocol to OpenTelemetry Converter

This package converts InfluxDB line protocol metrics to OpenTelemetry proto messages.

Documentation

Index

• type LineProtocolToOtelMetrics
  • func NewLineProtocolToOtelMetrics(logger common.Logger) (*LineProtocolToOtelMetrics, error)
  • func (c *LineProtocolToOtelMetrics) NewBatch() *MetricsBatch
• type MetricsBatch
  • func (b *MetricsBatch) AddPoint(measurement string, tags map[string]string, fields map[string]interface{}, ...) error
  • func (b *MetricsBatch) GetMetrics() pmetric.Metrics

Types

type LineProtocolToOtelMetrics

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

func NewLineProtocolToOtelMetrics

func NewLineProtocolToOtelMetrics(logger common.Logger) (*LineProtocolToOtelMetrics, error)

func (*LineProtocolToOtelMetrics) NewBatch

func (c *LineProtocolToOtelMetrics) NewBatch() *MetricsBatch

type MetricsBatch

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

func (*MetricsBatch) AddPoint

func (b *MetricsBatch) AddPoint(measurement string, tags map[string]string, fields map[string]interface{}, ts time.Time, vType common.InfluxMetricValueType) error

measurement - metric name

func (*MetricsBatch) GetMetrics

func (b *MetricsBatch) GetMetrics() pmetric.Metrics