Struct InMemoryAutoRefresh

flytestdlib/cache/in_memory_auto_refresh.go:98–117

InMemoryAutoRefresh is an in-memory implementation of the AutoRefresh interface. It is a 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

//
// Sync is run as a fixed-interval-scheduled-task, and is skipped if sync from previous cycle is still running.
type InMemoryAutoRefresh struct {
	name            string
	metrics         metrics
	syncCb          SyncFunc
	createBatchesCb CreateBatchesFunc
	lruMap          *lru.Cache
	// Items that are currently being processed are in the processing set.
	// It will prevent the same item from being processed multiple times by different workers.
	processing         *sync.Map
	toDelete           *syncSet
	syncPeriod         time.Duration
	workqueue          workqueue.TypedRateLimitingInterface[*Batch]
	parallelizm        uint
	lock               sync.RWMutex
	clock              clock.Clock  // pluggable clock for unit testing
	syncCount          atomic.Int32 // internal sync counter for unit testing
	enqueueCount       atomic.Int32 // internal enqueue counter for unit testing
	enqueueLoopRunning atomic.Bool  // internal bool to ensure goroutines are running
	syncOnCreate       bool
}

// NewInMemoryAutoRefresh creates a new InMemoryAutoRefresh
func NewInMemoryAutoRefresh(