otel2influx

Documentation

Overview

Package otel2influx is temporarily copied from github.com/influxdata/influxdb-observability/otel2influx to unblock the collector release. Once https://github.com/influxdata/influxdb-observability/pull/182 is merged, this package can be removed.

Index

• func AttributeValueToInfluxFieldValue(value pcommon.Value) (interface{}, error)
• func AttributeValueToInfluxTagValue(value pcommon.Value) (string, error)
• func InstrumentationScopeToTags(instrumentationLibrary pcommon.InstrumentationScope, tags map[string]string) (tagsAgain map[string]string)
• func ResourceToTags(logger common.Logger, resource pcommon.Resource, tags map[string]string) (tagsAgain map[string]string)
• type DependencyGraph
• type InfluxWriter
• type InfluxWriterBatch
• type JaegerDependencyGraph
  • func NewJaegerDependencyGraph(logger common.Logger, cacheMaxTrace, queueLength int, w InfluxWriter) (*JaegerDependencyGraph, error)
  • func (g *JaegerDependencyGraph) ReportSpan(ctx context.Context, span ptrace.Span, resource pcommon.Resource)
  • func (g *JaegerDependencyGraph) Shutdown(ctx context.Context) error
  • func (g *JaegerDependencyGraph) Start(_ context.Context, _ component.Host) error
• type OtelLogsToLineProtocol
  • func NewOtelLogsToLineProtocol(logger common.Logger, writer InfluxWriter) *OtelLogsToLineProtocol
  • func (c *OtelLogsToLineProtocol) WriteLogs(ctx context.Context, ld plog.Logs) error
• type OtelMetricsToLineProtocol
  • func NewOtelMetricsToLineProtocol(logger common.Logger, iw InfluxWriter, schema common.MetricsSchema) (*OtelMetricsToLineProtocol, error)
  • func (c *OtelMetricsToLineProtocol) WriteMetrics(ctx context.Context, md pmetric.Metrics) error
• type OtelTracesToLineProtocol
  • func NewOtelTracesToLineProtocol(logger common.Logger, w InfluxWriter) (*OtelTracesToLineProtocol, error)
  • func (c *OtelTracesToLineProtocol) Shutdown(ctx context.Context) error
  • func (c *OtelTracesToLineProtocol) Start(ctx context.Context, host component.Host) error
  • func (c *OtelTracesToLineProtocol) WriteTraces(ctx context.Context, td ptrace.Traces) error

Functions

func AttributeValueToInfluxFieldValue

func AttributeValueToInfluxFieldValue(value pcommon.Value) (interface{}, error)

func AttributeValueToInfluxTagValue

func AttributeValueToInfluxTagValue(value pcommon.Value) (string, error)

func InstrumentationScopeToTags

func InstrumentationScopeToTags(instrumentationLibrary pcommon.InstrumentationScope, tags map[string]string) (tagsAgain map[string]string)

func ResourceToTags

func ResourceToTags(logger common.Logger, resource pcommon.Resource, tags map[string]string) (tagsAgain map[string]string)

Types

type DependencyGraph

type DependencyGraph interface {
	Start(ctx context.Context, host component.Host) error
	ReportSpan(ctx context.Context, span ptrace.Span, resource pcommon.Resource)
	Shutdown(ctx context.Context) error
}

type InfluxWriter

type InfluxWriter interface {
	NewBatch() InfluxWriterBatch
}

type InfluxWriterBatch

type InfluxWriterBatch interface {
	WritePoint(ctx context.Context, measurement string, tags map[string]string, fields map[string]interface{}, ts time.Time, vType common.InfluxMetricValueType) error
	FlushBatch(ctx context.Context) error
}

type JaegerDependencyGraph

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

func NewJaegerDependencyGraph

func NewJaegerDependencyGraph(logger common.Logger, cacheMaxTrace, queueLength int, w InfluxWriter) (*JaegerDependencyGraph, error)

func (*JaegerDependencyGraph) ReportSpan

func (g *JaegerDependencyGraph) ReportSpan(ctx context.Context, span ptrace.Span, resource pcommon.Resource)

func (*JaegerDependencyGraph) Shutdown

func (g *JaegerDependencyGraph) Shutdown(ctx context.Context) error

func (*JaegerDependencyGraph) Start

func (g *JaegerDependencyGraph) Start(_ context.Context, _ component.Host) error

type OtelLogsToLineProtocol

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

func NewOtelLogsToLineProtocol

func NewOtelLogsToLineProtocol(logger common.Logger, writer InfluxWriter) *OtelLogsToLineProtocol

func (*OtelLogsToLineProtocol) WriteLogs

func (c *OtelLogsToLineProtocol) WriteLogs(ctx context.Context, ld plog.Logs) error

type OtelMetricsToLineProtocol

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

func NewOtelMetricsToLineProtocol

func NewOtelMetricsToLineProtocol(logger common.Logger, iw InfluxWriter, schema common.MetricsSchema) (*OtelMetricsToLineProtocol, error)

func (*OtelMetricsToLineProtocol) WriteMetrics

func (c *OtelMetricsToLineProtocol) WriteMetrics(ctx context.Context, md pmetric.Metrics) error

type OtelTracesToLineProtocol

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

func NewOtelTracesToLineProtocol

func NewOtelTracesToLineProtocol(logger common.Logger, w InfluxWriter) (*OtelTracesToLineProtocol, error)

func (*OtelTracesToLineProtocol) Shutdown

func (c *OtelTracesToLineProtocol) Shutdown(ctx context.Context) error

func (*OtelTracesToLineProtocol) Start

func (c *OtelTracesToLineProtocol) Start(ctx context.Context, host component.Host) error

func (*OtelTracesToLineProtocol) WriteTraces

func (c *OtelTracesToLineProtocol) WriteTraces(ctx context.Context, td ptrace.Traces) error