Skip to main content

v0_to_grpc_main_insert_requests

servers::otlp::trace::v0

Function v0_to_grpc_main_insert_requests 

Source 
pub fn v0_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 v0 trace table.

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