Function NewAutoRefreshCache

flytestdlib/cache/in_memory_auto_refresh.go:413–416

Instantiates a new AutoRefresh Cache that syncs items periodically.

(name string, syncCb SyncFunc, syncRateLimiter workqueue.TypedRateLimiter[*Batch], resyncPeriod time.Duration,
	parallelizm, size uint, scope promutils.Scope)

// Instantiates a new AutoRefresh Cache that syncs items periodically.
func NewAutoRefreshCache(name string, syncCb SyncFunc, syncRateLimiter workqueue.TypedRateLimiter[*Batch], resyncPeriod time.Duration,
	parallelizm, size uint, scope promutils.Scope) (AutoRefresh, error) {
	return NewAutoRefreshBatchedCache(name, SingleItemBatches, syncCb, syncRateLimiter, resyncPeriod, parallelizm, size, scope)
}

// SingleItemBatches is a function that creates n batches of items, each with size 1
func SingleItemBatches(_ context.Context, snapshot []ItemWrapper) (batches []Batch, err error) {