diff --git a/src/cache.js b/src/cache.js index b996c405480505802da7ddf594c620f16102d9a1..eee57121645555056a5ec62b8da455bc3fdccddc 100644 --- a/src/cache.js +++ b/src/cache.js @@ -37,6 +37,16 @@ export const fileCacheSizeGauge = new Gauge({ help: 'Number of entries in file cache' }) +export const versionCountGauge = new Gauge({ + name: 'redis_version_count_gauge', + help: 'Number of cache versions stored in Redis', + async collect () { + const pattern = `${process.env.REDIS_PREFIX}:*:mergedMetadata` + const results = await redis.client.keys(pattern) + this.set(results.length) + } +}) + export function set (key, value, timeout) { logger.debug(`[Cache] Set ${key}`) if (cache[key] === value) return diff --git a/src/version.js b/src/version.js index 6651a902027d91ea1f062f81a637ab6b2b31ebb3..e1c9a72a10cb40c2f9ad63be82a83e67159f6888 100644 --- a/src/version.js +++ b/src/version.js @@ -189,7 +189,7 @@ export async function updateVersionProcessor (pubClient) { await warmCache({ version: fetchedVersionInfo.version, fetchFiles: true }) await redis.client.set(getRedisKey({ name: 'versionInfo' }), stringifiedVersionInfo) await cache.get(getRedisKey({ version: fetchedVersionInfo.version, name: 'mergedMetadata' }), async () => [await fetchMergedMetadata()]) - versionUpdateGauge.setToCurrentTime({ version: fetchVersionInfo.version }) + versionUpdateGauge.setToCurrentTime({ version: fetchedVersionInfo.version }) logger.info('[Version] publish update to other nodes.') pubClient.publish(getRedisKey({ name: 'updateVersionInfo' }), stringifiedVersionInfo) } else {