otel2influx

package
v0.73.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

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

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 (*OtelTracesToLineProtocol) WriteTraces

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL