pg-queue 0.1.0

PostgreSQL job queue, pub/sub, and cache using SKIP LOCKED and LISTEN/NOTIFY
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
28
29
30
31
32
33
34
35
36

use crate::errors::Result;
use sqlx::PgPool;

/// Service for sending PostgreSQL NOTIFY messages.
///
/// Note: PostgreSQL NOTIFY has an 8KB payload limit.
#[derive(Clone)]
pub struct NotifyService {
    pool: PgPool,
}

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

    /// Send a notification to a channel
    pub async fn notify(&self, channel: &str, payload: &str) -> Result<()> {
        sqlx::query("SELECT pg_notify($1, $2)")
            .bind(channel)
            .bind(payload)
            .execute(&self.pool)
            .await?;

        Ok(())
    }
}

#[cfg(test)]
mod tests {
    #[test]
    fn test_channel_formatting() {
        let channel = format!("events.{}", "user_123");
        assert_eq!(channel, "events.user_123");
    }
}