logger log.Logger,
handler metrics.Handler,
maxSize := config.ReplicationProgressCacheMaxSize()
opts := &cache.Options{
TTL: config.ReplicationProgressCacheTTL(),
}
return &progressCacheImpl{
cache: cache.NewWithMetrics(maxSize, opts, handler.WithTags(metrics.CacheTypeTag(metrics.ReplicationProgressCacheTypeTagValue))),
}
}
func (c *progressCacheImpl) Get(