pub(crate) async fn ingest_logs_inner(
handler: PipelineHandlerRef,
pipeline: PipelineDefinition,
log_ingest_requests: Vec<PipelineIngestRequest>,
query_ctx: QueryContextRef,
headers: HeaderMap,
) -> Result<HttpResponse>
pub(crate) async fn ingest_logs_inner(
handler: PipelineHandlerRef,
pipeline: PipelineDefinition,
log_ingest_requests: Vec<PipelineIngestRequest>,
query_ctx: QueryContextRef,
headers: HeaderMap,
) -> Result<HttpResponse>