Struct coil::Runner

pub struct Runner<Env> { /* fields omitted */ }

Runner for background tasks. Synchronous tasks are run in a threadpool. Asynchronous tasks are spawned on the executor.

Implementations

impl<Env: 'static> Runner<Env>

pub fn builder(
    env: Env,
    executor: impl Spawn + 'static,
    conn: &PgPool
) -> Builder<Env>

Build the builder for Runner

pub async fn connection<'_>(&'_ self) -> Result<PoolConnection<Postgres>, Error>

Get a Pool Connection from the pool that the runner is using.

pub fn connection_pool(&self) -> PgPool

Get the connection pool that the runner is using

impl<Env: Send + Sync + RefUnwindSafe + 'static> Runner<Env>

pub async fn run_all_sync_tasks<'_>(&'_ self) -> Result<usize, FetchError>

Run all synchronous tasks Spawns synchronous tasks onto a rayon threadpool Returns how many tasks were actually queued

pub async fn run_all_async_tasks<'_>(&'_ self) -> Result<usize, FetchError>

Run all asynchronous tasks Spawns asynchronous tasks onto the specified executor Returns how many tasks were actually queued