opentelemetry

package

v1.4.0 Latest Latest Go to latest Published: Mar 22, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/alibaba/ilogtail

Links

Open Source Insights

Documentation ¶

Index ¶

func ConvertOtlpLogRequestToGroupEvents(otlpLogReq plogotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)
func ConvertOtlpLogsToGroupEvents(logs plog.Logs) (groupEventsSlice []*models.PipelineGroupEvents, err error)
func ConvertOtlpMetricRequestToGroupEvents(otlpMetricReq pmetricotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)
func ConvertOtlpMetricsToGroupEvents(metrics pmetric.Metrics) (groupEventsSlice []*models.PipelineGroupEvents, err error)
func ConvertOtlpTraceRequestToGroupEvents(otlpTraceReq ptraceotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)
func ConvertOtlpTracesToGroupEvents(traces ptrace.Traces) (groupEventsSlice []*models.PipelineGroupEvents, err error)
func DecodeOtlpRequest[P interface{ ... }](des P, data []byte, req *http.Request) (P, error)
type Decoder

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvertOtlpLogRequestToGroupEvents ¶ added in v1.4.0

func ConvertOtlpLogRequestToGroupEvents(otlpLogReq plogotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)

func ConvertOtlpLogsToGroupEvents ¶ added in v1.4.0

func ConvertOtlpLogsToGroupEvents(logs plog.Logs) (groupEventsSlice []*models.PipelineGroupEvents, err error)

func ConvertOtlpMetricRequestToGroupEvents ¶ added in v1.4.0

func ConvertOtlpMetricRequestToGroupEvents(otlpMetricReq pmetricotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)

func ConvertOtlpMetricsToGroupEvents ¶ added in v1.4.0

func ConvertOtlpMetricsToGroupEvents(metrics pmetric.Metrics) (groupEventsSlice []*models.PipelineGroupEvents, err error)

func ConvertOtlpTraceRequestToGroupEvents ¶ added in v1.4.0

func ConvertOtlpTraceRequestToGroupEvents(otlpTraceReq ptraceotlp.ExportRequest) ([]*models.PipelineGroupEvents, error)

func ConvertOtlpTracesToGroupEvents ¶ added in v1.4.0

func ConvertOtlpTracesToGroupEvents(traces ptrace.Traces) (groupEventsSlice []*models.PipelineGroupEvents, err error)

func DecodeOtlpRequest ¶ added in v1.4.0

func DecodeOtlpRequest[P interface {
	UnmarshalProto(data []byte) error
	UnmarshalJSON(data []byte) error
}](des P, data []byte, req *http.Request) (P, error)

DecodeOtlpRequest decodes the data and fills into the otlp logs/metrics/traces export request.

Types ¶

type Decoder ¶

type Decoder struct {
	Format string
}

Decoder impl

func (*Decoder) ConvertOtlpLogV1 ¶

func (d *Decoder) ConvertOtlpLogV1(otlpLogReq plogotlp.ExportRequest) (logs []*protocol.Log, err error)

func (*Decoder) ConvertOtlpMetricV1 ¶ added in v1.4.0

func (d *Decoder) ConvertOtlpMetricV1(otlpMetricReq pmetricotlp.ExportRequest) (logs []*protocol.Log, err error)

func (*Decoder) ConvertOtlpTraceV1 ¶ added in v1.4.0

func (d *Decoder) ConvertOtlpTraceV1(otlpTraceReq ptraceotlp.ExportRequest) (logs []*protocol.Log, err error)

func (*Decoder) Decode ¶

func (d *Decoder) Decode(data []byte, req *http.Request, tags map[string]string) (logs []*protocol.Log, err error)

Decode impl

func (*Decoder) DecodeV2 ¶ added in v1.4.0

func (d *Decoder) DecodeV2(data []byte, req *http.Request) (groups []*models.PipelineGroupEvents, err error)

DecodeV2 impl

func (*Decoder) ParseRequest ¶

func (d *Decoder) ParseRequest(res http.ResponseWriter, req *http.Request, maxBodySize int64) (data []byte, statusCode int, err error)

ParseRequest impl

Source Files ¶

View all Source files

decoder.go

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