internal

Documentation

Index

• func LogsToOtlp(l LogsWrapper) *otlpcollectorlog.ExportLogsServiceRequest
• func MetricsCompatibilityChanges(req *otlpcollectormetrics.ExportMetricsServiceRequest)
• func MetricsToOtlp(mw MetricsWrapper) *otlpcollectormetrics.ExportMetricsServiceRequest
• func TracesCompatibilityChanges(req *otlpcollectortrace.ExportTraceServiceRequest)
• func TracesToOtlp(mw TracesWrapper) *otlpcollectortrace.ExportTraceServiceRequest
• type LogsWrapper
  • func LogsFromOtlp(req *otlpcollectorlog.ExportLogsServiceRequest) LogsWrapper
• type MetricsWrapper
  • func MetricsFromOtlp(req *otlpcollectormetrics.ExportMetricsServiceRequest) MetricsWrapper
• type TracesWrapper
  • func TracesFromOtlp(req *otlpcollectortrace.ExportTraceServiceRequest) TracesWrapper

Functions

func LogsToOtlp

func LogsToOtlp(l LogsWrapper) *otlpcollectorlog.ExportLogsServiceRequest

LogsToOtlp internal helper to convert LogsWrapper to protobuf representation.

func MetricsCompatibilityChanges

func MetricsCompatibilityChanges(req *otlpcollectormetrics.ExportMetricsServiceRequest)

MetricsCompatibilityChanges performs backward compatibility conversion on Metrics: - Convert IntHistogram to Histogram. See https://github.com/open-telemetry/opentelemetry-proto/blob/f3b0ee0861d304f8f3126686ba9b01c106069cb0/opentelemetry/proto/metrics/v1/metrics.proto#L170 - Convert IntGauge to Gauge. See https://github.com/open-telemetry/opentelemetry-proto/blob/f3b0ee0861d304f8f3126686ba9b01c106069cb0/opentelemetry/proto/metrics/v1/metrics.proto#L156 - Convert IntSum to Sum. See https://github.com/open-telemetry/opentelemetry-proto/blob/f3b0ee0861d304f8f3126686ba9b01c106069cb0/opentelemetry/proto/metrics/v1/metrics.proto#L156 - Converts Labels to Attributes. See https://github.com/open-telemetry/opentelemetry-proto/blob/8672494217bfc858e2a82a4e8c623d4a5530473a/opentelemetry/proto/metrics/v1/metrics.proto#L385

func MetricsToOtlp

func MetricsToOtlp(mw MetricsWrapper) *otlpcollectormetrics.ExportMetricsServiceRequest

MetricsToOtlp internal helper to convert MetricsWrapper to protobuf representation.

func TracesCompatibilityChanges

func TracesCompatibilityChanges(req *otlpcollectortrace.ExportTraceServiceRequest)

TracesCompatibilityChanges performs backward compatibility conversion of Span Status code according to OTLP specification as we are a new receiver and sender (we are pushing data to the pipelines): See https://github.com/open-telemetry/opentelemetry-proto/blob/59c488bfb8fb6d0458ad6425758b70259ff4a2bd/opentelemetry/proto/trace/v1/trace.proto#L239 See https://github.com/open-telemetry/opentelemetry-proto/blob/59c488bfb8fb6d0458ad6425758b70259ff4a2bd/opentelemetry/proto/trace/v1/trace.proto#L253

func TracesToOtlp

func TracesToOtlp(mw TracesWrapper) *otlpcollectortrace.ExportTraceServiceRequest

TracesToOtlp internal helper to convert TracesWrapper to protobuf representation.

Types

type LogsWrapper

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

LogsWrapper is an intermediary struct that is declared in an internal package as a way to prevent certain functions of pdata.Logs data type to be callable by any code outside of this module.

func LogsFromOtlp

func LogsFromOtlp(req *otlpcollectorlog.ExportLogsServiceRequest) LogsWrapper

LogsFromOtlp internal helper to convert protobuf representation to LogsWrapper.

type MetricsWrapper

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

MetricsWrapper is an intermediary struct that is declared in an internal package as a way to prevent certain functions of pdata.Metrics data type to be callable by any code outside of this module.

func MetricsFromOtlp

func MetricsFromOtlp(req *otlpcollectormetrics.ExportMetricsServiceRequest) MetricsWrapper

MetricsFromOtlp internal helper to convert protobuf representation to MetricsWrapper.

type TracesWrapper

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

TracesWrapper is an intermediary struct that is declared in an internal package as a way to prevent certain functions of pdata.Traces data type to be callable by any code outside of this module.

func TracesFromOtlp

func TracesFromOtlp(req *otlpcollectortrace.ExportTraceServiceRequest) TracesWrapper

TracesFromOtlp internal helper to convert protobuf representation to TracesWrapper.