Skip to main content

insert_many_copy

awa_model::insert

Function insert_many_copy 

Source 
pub async fn insert_many_copy(
    conn: &mut PgConnection,
    jobs: &[InsertParams],
) -> Result<Vec<JobRow>, AwaError>
Expand description

Insert many jobs through the compatibility COPY surface.

Uses a temp staging table with no constraints for fast COPY ingestion, then routes staged rows through awa.insert_job_compat. Accepts &mut PgConnection so callers can use pool connections or transactions (Transaction derefs to PgConnection). For high-volume queue-storage producers, prefer QueueStorage::enqueue_params_copy on a QueueStorage built with the same config as the worker fleet.