Added ACL SETUSER, DELUSER to AllNodes & AllSucceed response and requ…

…est policies
amazon-contributing · Sep 2, 2023 · f16ae47 · f16ae47
1 parent dcbbc21
commit f16ae47
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/redis/src/cluster_routing.rs b/redis/src/cluster_routing.rs
@@ -243,10 +243,11 @@ impl RoutingInfo {
 
             b"WAIT" => Some(Aggregate(AggregateOp::Min)),
 
-            b"CONFIG SET" | b"CONFIG RESETSTAT" | b"CONFIG REWRITE" | b"FLUSHALL" | b"FLUSHDB"
-            | b"FUNCTION DELETE" | b"FUNCTION FLUSH" | b"FUNCTION LOAD" | b"FUNCTION RESTORE"
-            | b"LATENCY RESET" | b"MEMORY PURGE" | b"MSET" | b"PING" | b"SCRIPT FLUSH"
-            | b"SCRIPT LOAD" | b"SLOWLOG RESET" => Some(AllSucceeded),
+            b"ACL SETUSER" | b"ACL DELUSER" | b"CONFIG SET" | b"CONFIG RESETSTAT"
+            | b"CONFIG REWRITE" | b"FLUSHALL" | b"FLUSHDB" | b"FUNCTION DELETE"
+            | b"FUNCTION FLUSH" | b"FUNCTION LOAD" | b"FUNCTION RESTORE" | b"LATENCY RESET"
+            | b"MEMORY PURGE" | b"MSET" | b"PING" | b"SCRIPT FLUSH" | b"SCRIPT LOAD"
+            | b"SLOWLOG RESET" => Some(AllSucceeded),
 
             b"KEYS" | b"MGET" | b"SLOWLOG GET" => Some(CombineArrays),
 
@@ -296,10 +297,10 @@ impl RoutingInfo {
             | b"MEMORY STATS"
             | b"INFO" => Some(RoutingInfo::MultiNode(MultipleNodeRoutingInfo::AllMasters)),
 
-            b"SLOWLOG GET" | b"SLOWLOG LEN" | b"SLOWLOG RESET" | b"CONFIG SET"
-            | b"CONFIG RESETSTAT" | b"CONFIG REWRITE" | b"SCRIPT FLUSH" | b"SCRIPT LOAD"
-            | b"LATENCY RESET" | b"LATENCY GRAPH" | b"LATENCY HISTOGRAM" | b"LATENCY HISTORY"
-            | b"LATENCY DOCTOR" | b"LATENCY LATEST" => {
+            b"ACL SETUSER" | b"ACL DELUSER" | b"SLOWLOG GET" | b"SLOWLOG LEN"
+            | b"SLOWLOG RESET" | b"CONFIG SET" | b"CONFIG RESETSTAT" | b"CONFIG REWRITE"
+            | b"SCRIPT FLUSH" | b"SCRIPT LOAD" | b"LATENCY RESET" | b"LATENCY GRAPH"
+            | b"LATENCY HISTOGRAM" | b"LATENCY HISTORY" | b"LATENCY DOCTOR" | b"LATENCY LATEST" => {
                 Some(RoutingInfo::MultiNode(MultipleNodeRoutingInfo::AllNodes))
             }