Method Query

pkg/storage/driver/secrets.go:124–159

Query fetches all releases that match the provided map of labels. An error is returned if the secret fails to retrieve the releases.

(labels map[string]string)

// Query fetches all releases that match the provided map of labels.
// An error is returned if the secret fails to retrieve the releases.
func (secrets *Secrets) Query(labels map[string]string) ([]release.Releaser, error) {
	ls := kblabels.Set{}
	for k, v := range labels {
		if errs := validation.IsValidLabelValue(v); len(errs) != 0 {
			return nil, fmt.Errorf("invalid label value: %q: %s", v, strings.Join(errs, "; "))
		}
		ls[k] = v
	}

	opts := metav1.ListOptions{LabelSelector: ls.AsSelector().String()}

	list, err := secrets.impl.List(context.Background(), opts)
	if err != nil {
		return nil, fmt.Errorf("query: failed to query with labels: %w", err)
	}

	if len(list.Items) == 0 {
		return nil, ErrReleaseNotFound
	}

	var results []release.Releaser
	for _, item := range list.Items {
		rls, err := decodeRelease(string(item.Data["release"]))
		if err != nil {
			secrets.Logger().Debug(
				"failed to decode release",
				slog.String("key", item.Name),
				slog.Any("error", err),
			)
			continue
		}
		rls.Labels = item.Labels
		results = append(results, rls)
	}
	return results, nil
}

// Create creates a new Secret holding the release. If the
// Secret already exists, ErrReleaseExists is returned.