NewAutoRefreshBatchedCache

Instantiates a new AutoRefresh Cache that syncs items in batches.

def NewAutoRefreshBatchedCache(
    name: string,
    createBatches: CreateBatchesFunc,
    syncCb: SyncFunc,
    syncRateLimiter: workqueue.TypedRateLimiter[*Batch],
    resyncPeriod: time.Duration,
    parallelizm: uint,
    size: uint,
    scope: promutils.Scope
) - > AutoRefresh, error

Instantiates a new AutoRefresh Cache that syncs items in batches.

Parameters

Name	Type	Description
name	string	The name of the cache, used for identification and metrics.
createBatches	CreateBatchesFunc	A function that defines how items are grouped into batches for synchronization.
syncCb	SyncFunc	The callback function executed to synchronize a batch of items.
syncRateLimiter	workqueue.TypedRateLimiter[*Batch]	A rate limiter to control the frequency of synchronization operations for batches.
resyncPeriod	time.Duration	The duration after which the cache will perform a full resynchronization of all items.
parallelizm	uint	The number of concurrent synchronization operations that can run in parallel.
size	uint	The maximum number of items the cache can hold.
scope	promutils.Scope	The Prometheus metrics scope for reporting cache-related metrics.

Returns

Type	Description
AutoRefresh, error	A new AutoRefresh instance and an error if the instantiation fails.