fx-durable-ga 0.3.0

Durable GA event driven optimization loop on PostgreSQL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use sqlx::{PgPool, postgres::PgAdvisoryLock};

pub(crate) struct Service {
    pool: PgPool,
}

impl Service {
    pub(crate) fn new(pool: PgPool) -> Self {
        Self { pool }
    }

    pub(crate) async fn lock_while<F, Fut, T>(&self, key: &str, f: F) -> Result<T, super::Error>
    where
        F: FnOnce() -> Fut,
        Fut: Future<Output = T>,
    {
        let lock = PgAdvisoryLock::new(&key);
        let conn = self.pool.acquire().await?;
        let acquired = lock.acquire(conn).await?;

        // Execute the passed function within the duration of the global lock
        let ret = f().await;

        acquired.release_now().await?;
        Ok(ret)
    }
}