mirror of
https://github.com/idanoo/php-resque.git
synced 2024-11-22 16:25:14 +00:00
102 lines
1.9 KiB
PHP
102 lines
1.9 KiB
PHP
|
<?php
|
||
|
|
// Third- party apps may have already loaded Resident from elsewhere
|
||
|
|
// so lets be careful.
|
||
|
|
if(!class_exists('RedisentCluster')) {
|
||
|
|
require_once dirname(__FILE__) . '/../Redisent/RedisentCluster.php';
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Extended Redisent class used by Resque for all communication with
|
||
|
|
* redis. Essentially adds namespace support to Redisent.
|
||
|
|
*
|
||
|
|
* @package Resque/Redis
|
||
|
|
* @author Chris Boulton <chris.boulton@interspire.com>
|
||
|
|
* @copyright (c) 2010 Chris Boulton
|
||
|
|
* @license http://www.opensource.org/licenses/mit-license.php
|
||
|
|
*/
|
||
|
|
class Resque_RedisCluster extends RedisentCluster
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* @var array List of all commands in Redis that supply a key as their
|
||
|
|
* first argument. Used to prefix keys with the Resque namespace.
|
||
|
|
*/
|
||
|
|
private $keyCommands = array(
|
||
|
|
'exists',
|
||
|
|
'del',
|
||
|
|
'type',
|
||
|
|
'keys',
|
||
|
|
'expire',
|
||
|
|
'ttl',
|
||
|
|
'move',
|
||
|
|
'set',
|
||
|
|
'get',
|
||
|
|
'getset',
|
||
|
|
'setnx',
|
||
|
|
'incr',
|
||
|
|
'incrby',
|
||
|
|
'decrby',
|
||
|
|
'decrby',
|
||
|
|
'rpush',
|
||
|
|
'lpush',
|
||
|
|
'llen',
|
||
|
|
'lrange',
|
||
|
|
'ltrim',
|
||
|
|
'lindex',
|
||
|
|
'lset',
|
||
|
|
'lrem',
|
||
|
|
'lpop',
|
||
|
|
'rpop',
|
||
|
|
'sadd',
|
||
|
|
'srem',
|
||
|
|
'spop',
|
||
|
|
'scard',
|
||
|
|
'sismember',
|
||
|
|
'smembers',
|
||
|
|
'srandmember',
|
||
|
|
'zadd',
|
||
|
|
'zrem',
|
||
|
|
'zrange',
|
||
|
|
'zrevrange',
|
||
|
|
'zrangebyscore',
|
||
|
|
'zcard',
|
||
|
|
'zscore',
|
||
|
|
'zremrangebyscore',
|
||
|
|
'sort'
|
||
|
|
);
|
||
|
|
// sinterstore
|
||
|
|
// sunion
|
||
|
|
// sunionstore
|
||
|
|
// sdiff
|
||
|
|
// sdiffstore
|
||
|
|
// sinter
|
||
|
|
// smove
|
||
|
|
// rename
|
||
|
|
// rpoplpush
|
||
|
|
// mget
|
||
|
|
// msetnx
|
||
|
|
// mset
|
||
|
|
// renamenx
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Magic method to handle all function requests and prefix key based
|
||
|
|
* operations with the 'resque:' key prefix.
|
||
|
|
*
|
||
|
|
* @param string $name The name of the method called.
|
||
|
|
* @param array $args Array of supplied arguments to the method.
|
||
|
|
* @return mixed Return value from Resident::call() based on the command.
|
||
|
|
*/
|
||
|
|
public function __call($name, $args) {
|
||
|
|
$args = func_get_args();
|
||
|
|
if(in_array($name, $this->keyCommands)) {
|
||
|
|
$args[1][0] = 'resque:' . $args[1][0];
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
return parent::__call($name, $args[1]);
|
||
|
|
}
|
||
|
|
catch(RedisException $e) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
?>
|