4343]
4444EOL_ADVANCE_WARNING_TIME = timedelta (weeks = 26 ) # Give 6 months advance notice for EOL services
4545
46- REDIS_VALKEY_ACL_ARGS = [
47- "redis_acl_keys" ,
48- "redis_acl_commands" ,
49- "redis_acl_categories" ,
50- "redis_acl_channels" ,
46+ VALKEY_ACL_ARGS = [
5147 "valkey_acl_keys" ,
5248 "valkey_acl_commands" ,
5349 "valkey_acl_categories" ,
@@ -1838,7 +1834,7 @@ def service__migration_status(self) -> None:
18381834
18391835 def _parse_access_control (self ) -> Mapping [str , Any ]:
18401836 arg_vars = vars (self .args )
1841- result = {key : arg_vars [key ].split () for key in REDIS_VALKEY_ACL_ARGS if arg_vars [key ] is not None }
1837+ result = {key : arg_vars [key ].split () for key in VALKEY_ACL_ARGS if arg_vars [key ] is not None }
18421838 for key in ["m3_group" ]:
18431839 value = arg_vars [key ]
18441840 if value is not None :
@@ -1849,10 +1845,6 @@ def _parse_access_control(self) -> Mapping[str, Any]:
18491845 @arg .service_name
18501846 @arg ("--username" , help = "Service user username" , required = True )
18511847 @arg ("--m3-group" , help = "Service user group" )
1852- @arg ("--redis-acl-keys" , help = "ACL rules for keys (Redis only)" )
1853- @arg ("--redis-acl-commands" , help = "ACL rules for commands (Redis only)" )
1854- @arg ("--redis-acl-categories" , help = "ACL rules for command categories (Redis only)" )
1855- @arg ("--redis-acl-channels" , help = "ACL rules for channels (Redis only)" )
18561848 @arg ("--valkey-acl-keys" , help = "ACL rules for keys (Valkey only)" )
18571849 @arg ("--valkey-acl-commands" , help = "ACL rules for commands (Valkey only)" )
18581850 @arg ("--valkey-acl-categories" , help = "ACL rules for command categories (Valkey only)" )
@@ -1891,13 +1883,13 @@ def service__user_list(self) -> None:
18911883 """List service users"""
18921884 service = self .client .get_service (project = self .get_project (), service = self .args .service_name )
18931885 layout = [["username" , "type" ]]
1894- if service ["service_type" ] == "redis " :
1886+ if service ["service_type" ] == "valkey " :
18951887 layout [0 ].extend (
18961888 [
1897- "access_control.redis_acl_keys " ,
1898- "access_control.redis_acl_commands " ,
1899- "access_control.redis_acl_categories " ,
1900- "access_control.redis_acl_channels " ,
1889+ "access_control.valkey_acl_keys " ,
1890+ "access_control.valkey_acl_commands " ,
1891+ "access_control.valkey_acl_categories " ,
1892+ "access_control.valkey_acl_channels " ,
19011893 ]
19021894 )
19031895 self .print_response (
@@ -1918,12 +1910,7 @@ def service__user_get(self) -> None:
19181910 project = self .get_project (), service = self .args .service_name , username = self .args .username
19191911 )
19201912 layout = [["username" , "type" ]]
1921- for field in (
1922- "redis_acl_keys" ,
1923- "redis_acl_commands" ,
1924- "redis_acl_categories" ,
1925- "redis_acl_channels" ,
1926- ):
1913+ for field in VALKEY_ACL_ARGS :
19271914 if field in user .get ("access_control" , {}):
19281915 layout [0 ].append (f"access_control.{ field } " )
19291916 self .print_response (user , single_item = True , format = self .args .format , json = self .args .json , table_layout = layout )
@@ -2098,17 +2085,13 @@ def service__user_password_reset(self) -> None:
20982085 @arg .service_name
20992086 @arg ("--username" , help = "Service user username" , required = True )
21002087 @arg ("--m3-group" , help = "Service user group" )
2101- @arg ("--redis-acl-keys" , help = "ACL rules for keys (Redis only)" )
2102- @arg ("--redis-acl-commands" , help = "ACL rules for commands (Redis only)" )
2103- @arg ("--redis-acl-categories" , help = "ACL rules for command categories (Redis only)" )
2104- @arg ("--redis-acl-channels" , help = "ACL rules for channels (Redis only)" )
21052088 @arg ("--valkey-acl-keys" , help = "ACL rules for keys (Valkey only)" )
21062089 @arg ("--valkey-acl-commands" , help = "ACL rules for commands (Valkey only)" )
21072090 @arg ("--valkey-acl-categories" , help = "ACL rules for command categories (Valkey only)" )
21082091 @arg ("--valkey-acl-channels" , help = "ACL rules for channels (Valkey only)" )
21092092 @arg .json
21102093 def service__user_set_access_control (self ) -> None :
2111- """Set Redis/ Valkey service user access control"""
2094+ """Set Valkey service user access control"""
21122095 access_control = self ._parse_access_control ()
21132096 self .client .set_service_user_access_control (
21142097 project = self .get_project (),
0 commit comments