servers::otlp::trace

Function to_grpc_insert_requests

Source 
pub fn to_grpc_insert_requests(
    request: ExportTraceServiceRequest,
    pipeline: PipelineWay,
    pipeline_params: GreptimePipelineParams,
    table_name: String,
    query_ctx: &QueryContextRef,
    pipeline_handler: PipelineHandlerRef,
) -> Result<(RowInsertRequests, usize)>
Expand description

Convert SpanTraces to GreptimeDB row insert requests. Returns InsertRequests and total number of rows to ingest