Method discoverUsersWithRetries

pkg/compactor/compactor.go:1123–1144

(ctx context.Context)

}

func (c *Compactor) discoverUsersWithRetries(ctx context.Context) ([]string, error) {
	var lastErr error

	retries := backoff.New(ctx, backoff.Config{
		MinBackoff: c.compactorCfg.retryMinBackoff,
		MaxBackoff: c.compactorCfg.retryMaxBackoff,
		MaxRetries: c.compactorCfg.CompactionRetries,
	})

	for retries.Ongoing() {
		var users []string

		users, lastErr = c.discoverUsers(ctx)
		if lastErr == nil {
			return users, nil
		}

		retries.Wait()
	}

	return nil, lastErr
}

// discoverUsers returns all users that are active and deleting. Deleted users are not included.
func (c *Compactor) discoverUsers(ctx context.Context) ([]string, error) {