servers::http::event

Function ingest_logs_inner

source 
async fn ingest_logs_inner(
    state: PipelineHandlerRef,
    pipeline_name: String,
    version: PipelineVersion,
    table_name: String,
    pipeline_data: Vec<Value>,
    query_ctx: QueryContextRef,
) -> Result<HttpResponse>