Struct autoRefreshCache

flytestdlib/utils/auto_refresh_cache.go:94–100

Thread-safe general purpose auto-refresh cache that watches for updates asynchronously for the keys after they are added to the cache. An item can be inserted only once. Get reads from sync.map while refresh is invoked on a snapshot of keys. Cache eventually catches up on deleted items. Sync is ru

//
// Sync is run as a fixed-interval-scheduled-task, and is skipped if sync from previous cycle is still running.
type autoRefreshCache struct {
	syncCb          CacheSyncItem
	lruMap          *lru.Cache
	syncRateLimiter RateLimiter
	resyncPeriod    time.Duration
	scope           promutils.Scope
}

func (w *autoRefreshCache) Start(ctx context.Context) {
	go wait.Until(func() { w.sync(ctx) }, w.resyncPeriod, ctx.Done())