Method List

pkg/storage/driver/sql.go:346–394

List returns the list of all releases such that filter(release) == true

(filter func(release.Releaser) bool)

// List returns the list of all releases such that filter(release) == true
func (s *SQL) List(filter func(release.Releaser) bool) ([]release.Releaser, error) {
	sb := s.statementBuilder.
		Select(sqlReleaseTableKeyColumn, sqlReleaseTableNamespaceColumn, sqlReleaseTableBodyColumn).
		From(sqlReleaseTableName).
		Where(sq.Eq{sqlReleaseTableOwnerColumn: sqlReleaseDefaultOwner})

	// If a namespace was specified, we only list releases from that namespace
	if s.namespace != "" {
		sb = sb.Where(sq.Eq{sqlReleaseTableNamespaceColumn: s.namespace})
	}

	query, args, err := sb.ToSql()
	if err != nil {
		s.Logger().Debug("failed to build query", slog.Any("error", err))
		return nil, err
	}

	var records = []SQLReleaseWrapper{}
	if err := s.db.Select(&records, query, args...); err != nil {
		s.Logger().Debug("failed to list", slog.Any("error", err))
		return nil, err
	}

	var releases []release.Releaser
	for _, record := range records {
		release, err := decodeRelease(record.Body)
		if err != nil {
			s.Logger().Debug("failed to decode release", slog.Any("record", record), slog.Any("error", err))
			continue
		}

		if release.Labels, err = s.getReleaseCustomLabels(record.Key, record.Namespace); err != nil {
			s.Logger().Debug(
				"failed to get release custom labels",
				slog.String("namespace", record.Namespace),
				slog.String("key", record.Key),
				slog.Any("error", err),
			)
			return nil, err
		}
		maps.Copy(release.Labels, getReleaseSystemLabels(release))

		if filter(release) {
			releases = append(releases, release)
		}
	}

	return releases, nil
}

// Query returns the set of releases that match the provided set of labels.
func (s *SQL) Query(labels map[string]string) ([]release.Releaser, error) {