Method UpsertCacheKey

core/services/distributed/gallery.go:152–170

UpsertCacheKey records the in-memory OpCache key + IsBackendOp flag on the gallery_operations row, creating the row if it does not exist yet. Why upsert: OpCache.Set is called by the HTTP admission handler before the galleryop service goroutine processes the operation and calls Create. If OpCache w

(id, cacheKey string, isBackend bool)

// in the window between the two, so peer replicas hydrating in that window
// would still rebuild an empty OpCache. Upsert closes that window.
func (s *GalleryStore) UpsertCacheKey(id, cacheKey string, isBackend bool) error {
	now := time.Now()
	rec := GalleryOperationRecord{
		ID:          id,
		CacheKey:    cacheKey,
		IsBackendOp: isBackend,
		Status:      "pending",
		CreatedAt:   now,
		UpdatedAt:   now,
	}
	return s.db.Clauses(clause.OnConflict{
		Columns: []clause.Column{{Name: "id"}},
		DoUpdates: clause.Assignments(map[string]any{
			"cache_key":     cacheKey,
			"is_backend_op": isBackend,
			"updated_at":    now,
		}),
	}).Create(&rec).Error
}

// FindDuplicate checks if another instance is already downloading the same element.
// Only considers records updated within the last 30 minutes as active — older