Method GetOrCreate

flytestdlib/cache/in_memory_auto_refresh.go:233–251

Return the item if exists else create it. Create should be invoked only once. recreating the object is not supported.

(id ItemID, item Item)

// Return the item if exists else create it.
// Create should be invoked only once. recreating the object is not supported.
func (w *InMemoryAutoRefresh) GetOrCreate(id ItemID, item Item) (Item, error) {
	if val, ok := w.lruMap.Get(id); ok {
		w.metrics.CacheHit.Inc()
		return val.(Item), nil
	}

	w.lruMap.Add(id, item)
	w.metrics.CacheMiss.Inc()

	// It fixes cold start issue in the AutoRefreshCache by adding the item to the workqueue when it is created.
	// This way, the item will be processed without waiting for the next sync cycle (30s by default).
	if w.syncOnCreate {
		batch := make([]ItemWrapper, 0, 1)
		batch = append(batch, itemWrapper{id: id, item: item})
		w.workqueue.AddRateLimited(&batch)
		w.processing.Store(id, w.clock.Now())
	}
	return item, nil
}

// DeleteDelayed queues an item for deletion. It Will get deleted as part of the next Sync cycle. Until the next sync
// cycle runs, Get and GetOrCreate will continue to return the Item in its previous state.