opentelemetry

func NewPushSpansCallbackFunc ¶ added in v0.6.0

func NewPushSpansCallbackFunc(lmp insertutil.LogMessageProcessor) func(timestamp int64, fields []logstorage.Field)

func OTLPGRPCRequestHandler ¶ added in v0.5.0

func OTLPGRPCRequestHandler(r *http.Request, w http.ResponseWriter) bool

OTLPGRPCRequestHandler is the router of gRPC requests.

func PersistServiceGraph ¶ added in v0.4.0

func PersistServiceGraph(ctx context.Context, tenantID logstorage.TenantID, commonFields []logstorage.Field, fields [][]logstorage.Field, timestamp time.Time) ([]logstorage.Field, error)

func RequestHandler ¶

func RequestHandler(path string, w http.ResponseWriter, r *http.Request) bool

RequestHandler processes Opentelemetry insert requests