add ACLLogReset to rueidiscompat

Signed-off-by: hcc429 <[email protected]>
redis · Feb 9, 2025 · fcea155 · fcea155
1 parent 93e9af3
commit fcea155
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/rueidiscompat/adapter.go b/rueidiscompat/adapter.go
@@ -416,7 +416,8 @@ type CoreCmdable interface {
 
 	ACLDryRun(ctx context.Context, username string, command ...any) *StringCmd
 	// TODO ACLLog(ctx context.Context, count int64) *ACLLogCmd
-	// TODO ACLLogReset(ctx context.Context) *StatusCmd
+	ACLLogReset(ctx context.Context) *StatusCmd
+
 
 	ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd
 	GearsCmdable
@@ -3202,6 +3203,12 @@ func (c *Compat) ACLDryRun(ctx context.Context, username string, command ...any)
 	return newStringCmd(resp)
 }
 
+func (c *Compat) ACLLogReset(ctx context.Context) *StatusCmd {
+	cmd := c.client.B().AclLog().Reset().Build()
+	resp := c.client.Do(ctx, cmd)
+	return newStatusCmd(resp)
+}
+
 func (c *Compat) doPrimaries(ctx context.Context, fn func(c rueidis.Client) error) error {
 	if c.pOnly {
 		return fn(c.client)

diff --git a/rueidiscompat/pipeline.go b/rueidiscompat/pipeline.go
@@ -2089,6 +2089,12 @@ func (c *Pipeline) ACLDryRun(ctx context.Context, username string, command ...an
 	return ret
 }
 
+func (c *Pipeline) ACLLogReset(ctx context.Context) *StatusCmd {
+	ret := c.comp.ACLLogReset(ctx)
+	c.rets = append(c.rets, ret)
+	return ret
+}
+
 func (c *Pipeline) TFunctionLoad(ctx context.Context, lib string) *StatusCmd {
 	ret := c.comp.TFunctionLoad(ctx, lib)
 	c.rets = append(c.rets, ret)