Skip to content

Commit 46f1c8f

Browse files
committed
fix: address comments, impl interfaec
1 parent fc18466 commit 46f1c8f

2 files changed

Lines changed: 4 additions & 0 deletions

File tree

rueidiscompat/pipeline.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3184,6 +3184,10 @@ func (c *Pipeline) Watch(_ context.Context, _ func(Tx) error, _ ...string) error
31843184
panic("not implemented")
31853185
}
31863186

3187+
func (c *Pipeline) ForEachMaster(_ context.Context, _ func(ctx context.Context, client Cmdable) error) error {
3188+
panic("not implemented")
3189+
}
3190+
31873191
func (c *Pipeline) Client() rueidis.Client {
31883192
return c.comp.client.(*proxy).Client
31893193
}

rueidiscompat/rueidiscompat.test

-22.7 MB
Binary file not shown.

0 commit comments

Comments
 (0)