Method SetIndex

pkg/cache/postgres/index.go:19–35

SetIndex serializes and stores the index in Postgres.

(idx *index.Index)

// SetIndex serializes and stores the index in Postgres.
func (s *IndexStorage) SetIndex(idx *index.Index) error {
	data, err := json.Marshal(idx)
	if err != nil {
		return err
	}

	index := &database.Index{
		URL:  s.namespacePrefix,
		Blob: data,
	}

	// Upsert operation: Update if exists, else create
	return s.db.Clauses(clause.OnConflict{
		Columns:   []clause.Column{{Name: "url"}},                           // conflict target
		DoUpdates: clause.Assignments(map[string]interface{}{"blob": data}), // update just the blob
	}).Create(index).Error
}

// Index retrieves and deserializes the index from Postgres.
func (s *IndexStorage) Index() (*index.Index, error) {