Method Get

pkg/storage/driver/sql.go:305–343

Get returns the release named by key.

(key string)

// Get returns the release named by key.
func (s *SQL) Get(key string) (release.Releaser, error) {
	var record SQLReleaseWrapper

	qb := s.statementBuilder.
		Select(sqlReleaseTableBodyColumn).
		From(sqlReleaseTableName).
		Where(sq.Eq{sqlReleaseTableKeyColumn: key}).
		Where(sq.Eq{sqlReleaseTableNamespaceColumn: s.namespace})

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

	// Get will return an error if the result is empty
	if err := s.db.Get(&record, query, args...); err != nil {
		s.Logger().Debug("got SQL error when getting release", slog.String("key", key), slog.Any("error", err))
		return nil, ErrReleaseNotFound
	}

	release, err := decodeRelease(record.Body)
	if err != nil {
		s.Logger().Debug("failed to decode data", slog.String("key", key), slog.Any("error", err))
		return nil, err
	}

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

	return release, nil
}

// List returns the list of all releases such that filter(release) == true
func (s *SQL) List(filter func(release.Releaser) bool) ([]release.Releaser, error) {