Sharded pubsub implementation (#8621)

This commit implements a sharded pubsub implementation based off of shard channels.

Co-authored-by: Harkrishn Patro <harkrisp@amazon.com>
Co-authored-by: Madelyn Olson <madelyneolson@gmail.com>

1 files changed, 5 insertions, 1 deletions

diff --git a/tests/support/cluster.tcl b/tests/support/cluster.tcl
index df4b7f3d0..081ef6a95 100644
--- a/tests/support/cluster.tcl
+++ b/tests/support/cluster.tcl
@@ -13,6 +13,7 @@ package require Tcl 8.5
 package provide redis_cluster 0.1
 
 namespace eval redis_cluster {}
+set ::redis_cluster::internal_id 0
 set ::redis_cluster::id 0
 array set ::redis_cluster::startup_nodes {}
 array set ::redis_cluster::nodes {}
@@ -32,7 +33,8 @@ set ::redis_cluster::plain_commands {
     hget hmset hmget hincrby hincrbyfloat hdel hlen hkeys hvals
     hgetall hexists hscan incrby decrby incrbyfloat getset move
     expire expireat pexpire pexpireat type ttl pttl persist restore
-    dump bitcount bitpos pfadd pfcount
+    dump bitcount bitpos pfadd pfcount cluster ssubscribe spublish
+    sunsubscribe
 }
 
 # Create a cluster client. The nodes are given as a list of host:port. The TLS
@@ -118,6 +120,7 @@ proc ::redis_cluster::__method__refresh_nodes_map {id} {
         # Build this node description as an hash.
         set node [dict create \
             id $nodeid \
+            internal_id $id \
             addr $addr \
             host $host \
             port $port \
@@ -265,6 +268,7 @@ proc ::redis_cluster::get_keys_from_command {cmd argv} {
         mget {return $argv}
         eval {return [lrange $argv 2 1+[lindex $argv 1]]}
         evalsha {return [lrange $argv 2 1+[lindex $argv 1]]}
+        spublish {return [list [lindex $argv 1]]}
     }
 
     # All the remaining commands are not handled.