discoverUsers returns all users that are active and deleting. Deleted users are not included.
(ctx context.Context)
| 1145 | |
| 1146 | // discoverUsers returns all users that are active and deleting. Deleted users are not included. |
| 1147 | func (c *Compactor) discoverUsers(ctx context.Context) ([]string, error) { |
| 1148 | activeUsers, deletingUsers, _, err := c.usersScanner.ScanUsers(ctx) |
| 1149 | if err != nil { |
| 1150 | return nil, err |
| 1151 | } |
| 1152 | users := make([]string, 0, len(activeUsers)+len(deletingUsers)) |
| 1153 | users = append(users, activeUsers...) |
| 1154 | users = append(users, deletingUsers...) |
| 1155 | return users, nil |
| 1156 | } |
| 1157 | |
| 1158 | func (c *Compactor) ownUserForCompaction(userID string) (bool, error) { |
| 1159 | return c.ownUser(userID, false) |
no test coverage detected