Skip to content

Commit

Permalink
add logging
Browse files Browse the repository at this point in the history
  • Loading branch information
malteish committed Sep 3, 2024
1 parent 73b5e47 commit ff16d9e
Showing 1 changed file with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,13 @@ export function countMessage(redis: Redis) {
return async (messageSizeBytes: number) => {
const timestamp = getKeyIntervalTimestamp();

console.log(
'countMessage at',
timestamp,
' with size ',
messageSizeBytes,
);

// Increment the message count, starting at 0 if the key doesn't exist
await redis.incrBy(`${RedisPrefix.MetricsMessageCount}${timestamp}`, 1);

Expand Down

0 comments on commit ff16d9e

Please sign in to comment.