Skip to main content

v1_to_grpc_main_insert_requests

servers::otlp::trace::v1

Function v1_to_grpc_main_insert_requests 

Source 
pub fn v1_to_grpc_main_insert_requests(
    spans: &[TraceSpan],
    _pipeline: &PipelineWay,
    _pipeline_params: &GreptimePipelineParams,
    table_name: &str,
    _query_ctx: &QueryContextRef,
    _pipeline_handler: PipelineHandlerRef,
) -> Result<(RowInsertRequests, usize)>
Expand description

Converts trace spans into row insert requests for the main v1 trace table.

Auxiliary service and operation table writes are built separately so the caller can update them only after the main span write succeeds.