Module pubsub 

Pub/Sub support for Redis

This module provides functionality for Redis publish/subscribe messaging. Redis Pub/Sub allows you to send messages between different parts of your application or between different applications.

Examples

Publisher

use redis_oxide::{Client, ConnectionConfig};

let config = ConnectionConfig::new("redis://localhost:6379");
let client = Client::connect(config).await?;

// Publish a message to a channel
let subscribers = client.publish("news", "Breaking news!").await?;
println!("Message sent to {} subscribers", subscribers);

Subscriber

use redis_oxide::{Client, ConnectionConfig};
use futures::StreamExt;

let config = ConnectionConfig::new("redis://localhost:6379");
let client = Client::connect(config).await?;

// Subscribe to channels
let mut subscriber = client.subscriber().await?;
subscriber.subscribe(vec!["news".to_string(), "updates".to_string()]).await?;

// Listen for messages
while let Some(message) = subscriber.next_message().await? {
    println!("Received: {} on channel {}", message.payload, message.channel);
}

Structs

PubSubMessage

A message received from a Redis channel

Publisher

Publisher for sending messages to Redis channels

Subscriber

Redis Pub/Sub subscriber

Traits

PubSubConnection

Trait for Pub/Sub connections

Functions

parse_pubsub_message

Parse a Pub/Sub message from Redis response