idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque synced 2025-07-03 22:52:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

2.1.1 (2023-03-20) - Update setex to set, add TTL to stats

Browse source
This commit is contained in:
Daniel Mason 2023-03-20 09:26:45 +13:00
parent 679394eb5f
commit 94cae8d271
5 changed files with 54 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

31
src/Resque/Stat.php
View file

@ -29,11 +29,24 @@ class Stat
*
* @param string $stat The name of the statistic to increment.
* @param int $by The amount to increment the statistic by.
* @return boolean True if successful, false if not.
*
* @return bool True if successful, false if not.
*/
public static function incr($stat, $by = 1): bool
public static function incr(string $stat, int $by = 1): bool
{
return (bool)Resque::redis()->incrby('stat:' . $stat, $by);
// Make sure we set a TTL by default
$set = Resque::redis()->set(
'stat:' . $stat,
$by,
['ex' => time() + 86400, 'nx'],
);
// If it already exists, return the incrby value
if (!$set) {
return (bool)Resque::redis()->incrby('stat:' . $stat, $by);
}
return true;
}
/**
@ -41,9 +54,10 @@ class Stat
*
* @param string $stat The name of the statistic to decrement.
* @param int $by The amount to decrement the statistic by.
* @return boolean True if successful, false if not.
*
* @return bool True if successful, false if not.
*/
public static function decr($stat, $by = 1): bool
public static function decr(string $stat, int $by = 1): bool
{
return (bool)Resque::redis()->decrby('stat:' . $stat, $by);
}
@ -52,10 +66,11 @@ class Stat
* Delete a statistic with the given name.
*
* @param string $stat The name of the statistic to delete.
* @return boolean True if successful, false if not.
*
* @return bool True if successful, false if not.
*/
public static function clear($stat): bool
public static function clear(string $stat): bool
{
return (bool)Resque::redis()->del('stat:' . $stat);
return (bool)Resque::redis()->unlink('stat:' . $stat);
}
}