By default, keyspace events notifications are disabled. We can enable them in redis.conf or redis-cli as below:
$ redis-cli config set notify-keyspace-events KEA
$ OK
Last active
April 21, 2022 07:50
-
-
Save tyler46/128f9dece7a23bb964d485a1d8408fe9 to your computer and use it in GitHub Desktop.
Redis keyspace notification in Rust
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| extern crate redis; | |
| fn listen_redis_notifications() -> redis::RedisResult<()> { | |
| let client = try!(redis::Client::open("redis://127.0.0.1/0")); | |
| let mut pubsub = try!(client.get_pubsub()); | |
| try!(pubsub.psubscribe("__keyspace@0__:*")); | |
| try!(pubsub.psubscribe("__keyevent@0__:*")); | |
| loop { | |
| let msg = try!(pubsub.get_message()); | |
| let payload : String = try!(msg.get_payload()); | |
| println!("Channel '{}': {}", msg.get_channel_name(), payload); | |
| } | |
| } | |
| fn main() { | |
| match listen_redis_notifications() { | |
| Err(why) => panic!("{:?}", why), | |
| Ok(t) => println!("ok: {:?}", t), | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment