Skip to main content

to_grpc_insert_requests_from_spans

Function to_grpc_insert_requests_from_spans 

Source
pub fn to_grpc_insert_requests_from_spans(
    spans: &[TraceSpan],
    pipeline: &PipelineWay,
    pipeline_params: &GreptimePipelineParams,
    table_name: &str,
    query_ctx: &QueryContextRef,
    pipeline_handler: PipelineHandlerRef,
) -> Result<(RowInsertRequests, usize)>
Expand description

Convert a subset of trace spans to GreptimeDB row insert requests.