Struct PgNotifier 

pub struct PgNotifier { /* private fields */ }

PostgreSQL NOTIFY publisher for sending notifications

Publishes notifications to channels that listeners can receive.

Implementations

impl PgNotifier

pub fn new(pool: PgPool) -> Self

Create a new notifier using the provided connection pool

Example

let notifier = PgNotifier::new(pool);

pub async fn notify<T: Serialize>( &self, channel: &str, payload: &T, ) -> Result<(), PgError>

Send a notification to a channel

Arguments

• channel - Channel name to notify
• payload - Serializable payload (will be converted to JSON)

Errors

Returns error if:

• Payload cannot be serialized to JSON
• NOTIFY command fails

Example

notifier.notify("warpdrive:cache:invalidate", &serde_json::json!({
    "key": "user:123",
    "event_type": "delete"
})).await?;

pub async fn broadcast<T: Serialize>( &self, channels: &[String], payload: &T, ) -> Result<(), PgError>

Broadcast to multiple channels with the same payload

Errors

Returns error if any notification fails. Uses a transaction so all succeed or all fail.

Trait Implementations

impl Clone for PgNotifier

fn clone(&self) -> PgNotifier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.