servers::otlp::logs

Function to_grpc_insert_requests

source 
pub fn to_grpc_insert_requests(
    request: ExportLogsServiceRequest,
    pipeline: PipelineWay,
    table_name: String,
) -> Result<(RowInsertRequests, usize)>
Expand description

Convert OpenTelemetry metrics to GreptimeDB insert requests

See https://github.com/open-telemetry/opentelemetry-proto/blob/main/opentelemetry/proto/metrics/v1/metrics.proto for data structure of OTLP metrics.

Returns InsertRequests and total number of rows to ingest