()
| 101 | } |
| 102 | |
| 103 | func (c *KeyChecker) Stop() int { |
| 104 | close(c.ch) |
| 105 | c.wg.Wait() |
| 106 | return c.deleted |
| 107 | } |
| 108 | |
| 109 | func (c *KeyChecker) checkKeys(ctx context.Context, keys []string) error { |
| 110 | cmds, err := c.rdb.Pipelined(ctx, func(pipe redis.Pipeliner) error { |