servers::otlp::trace::v0

Function v0_to_grpc_insert_requests

Source 
pub fn v0_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