Version v0.14.0-dev

This commit is contained in:
github-actions[bot] 2025-07-27 16:03:58 +00:00
parent 3308c53f44
commit e4b5d5718d
143 changed files with 1857 additions and 149 deletions

View File

@ -1 +1 @@
v0.13.1
v0.14.0-dev

5
vendor/autoload.php vendored
View File

@ -14,10 +14,7 @@ if (PHP_VERSION_ID < 50600) {
echo $err;
}
}
trigger_error(
$err,
E_USER_ERROR
);
throw new RuntimeException($err);
}
require_once __DIR__ . '/composer/autoload_real.php';

View File

@ -26,12 +26,23 @@ use Composer\Semver\VersionParser;
*/
class InstalledVersions
{
/**
* @var string|null if set (by reflection by Composer), this should be set to the path where this class is being copied to
* @internal
*/
private static $selfDir = null;
/**
* @var mixed[]|null
* @psalm-var array{root: array{name: string, pretty_version: string, version: string, reference: string|null, type: string, install_path: string, aliases: string[], dev: bool}, versions: array<string, array{pretty_version?: string, version?: string, reference?: string|null, type?: string, install_path?: string, aliases?: string[], dev_requirement: bool, replaced?: string[], provided?: string[]}>}|array{}|null
*/
private static $installed;
/**
* @var bool
*/
private static $installedIsLocalDir;
/**
* @var bool|null
*/
@ -309,6 +320,24 @@ class InstalledVersions
{
self::$installed = $data;
self::$installedByVendor = array();
// when using reload, we disable the duplicate protection to ensure that self::$installed data is
// always returned, but we cannot know whether it comes from the installed.php in __DIR__ or not,
// so we have to assume it does not, and that may result in duplicate data being returned when listing
// all installed packages for example
self::$installedIsLocalDir = false;
}
/**
* @return string
*/
private static function getSelfDir()
{
if (self::$selfDir === null) {
self::$selfDir = strtr(__DIR__, '\\', '/');
}
return self::$selfDir;
}
/**
@ -322,19 +351,27 @@ class InstalledVersions
}
$installed = array();
$copiedLocalDir = false;
if (self::$canGetVendors) {
$selfDir = self::getSelfDir();
foreach (ClassLoader::getRegisteredLoaders() as $vendorDir => $loader) {
$vendorDir = strtr($vendorDir, '\\', '/');
if (isset(self::$installedByVendor[$vendorDir])) {
$installed[] = self::$installedByVendor[$vendorDir];
} elseif (is_file($vendorDir.'/composer/installed.php')) {
/** @var array{root: array{name: string, pretty_version: string, version: string, reference: string|null, type: string, install_path: string, aliases: string[], dev: bool}, versions: array<string, array{pretty_version?: string, version?: string, reference?: string|null, type?: string, install_path?: string, aliases?: string[], dev_requirement: bool, replaced?: string[], provided?: string[]}>} $required */
$required = require $vendorDir.'/composer/installed.php';
$installed[] = self::$installedByVendor[$vendorDir] = $required;
if (null === self::$installed && strtr($vendorDir.'/composer', '\\', '/') === strtr(__DIR__, '\\', '/')) {
self::$installed = $installed[count($installed) - 1];
self::$installedByVendor[$vendorDir] = $required;
$installed[] = $required;
if (self::$installed === null && $vendorDir.'/composer' === $selfDir) {
self::$installed = $required;
self::$installedIsLocalDir = true;
}
}
if (self::$installedIsLocalDir && $vendorDir.'/composer' === $selfDir) {
$copiedLocalDir = true;
}
}
}
@ -350,7 +387,7 @@ class InstalledVersions
}
}
if (self::$installed !== array()) {
if (self::$installed !== array() && !$copiedLocalDir) {
$installed[] = self::$installed;
}

View File

@ -32,12 +32,12 @@ return array(
'Ramsey\\Uuid\\' => array($vendorDir . '/ramsey/uuid/src'),
'Ramsey\\Collection\\' => array($vendorDir . '/ramsey/collection/src'),
'Psr\\Log\\' => array($vendorDir . '/psr/log/Psr/Log'),
'Psr\\Http\\Message\\' => array($vendorDir . '/psr/http-message/src', $vendorDir . '/psr/http-factory/src'),
'Psr\\Http\\Message\\' => array($vendorDir . '/psr/http-factory/src', $vendorDir . '/psr/http-message/src'),
'Psr\\Http\\Client\\' => array($vendorDir . '/psr/http-client/src'),
'Predis\\' => array($vendorDir . '/predis/predis/src'),
'Masterminds\\' => array($vendorDir . '/masterminds/html5/src'),
'Jfcherng\\Utility\\' => array($vendorDir . '/jfcherng/php-mb-string/src', $vendorDir . '/jfcherng/php-color-output/src'),
'Jfcherng\\Diff\\' => array($vendorDir . '/jfcherng/php-sequence-matcher/src', $vendorDir . '/jfcherng/php-diff/src'),
'Jfcherng\\Diff\\' => array($vendorDir . '/jfcherng/php-diff/src', $vendorDir . '/jfcherng/php-sequence-matcher/src'),
'GuzzleHttp\\Psr7\\' => array($vendorDir . '/guzzlehttp/psr7/src'),
'GuzzleHttp\\Promise\\' => array($vendorDir . '/guzzlehttp/promises/src'),
'GuzzleHttp\\' => array($vendorDir . '/guzzlehttp/guzzle/src'),

View File

@ -226,8 +226,8 @@ class ComposerStaticInit5d5db0943532ec3ad2d064ba31305947
),
'Psr\\Http\\Message\\' =>
array (
0 => __DIR__ . '/..' . '/psr/http-message/src',
1 => __DIR__ . '/..' . '/psr/http-factory/src',
0 => __DIR__ . '/..' . '/psr/http-factory/src',
1 => __DIR__ . '/..' . '/psr/http-message/src',
),
'Psr\\Http\\Client\\' =>
array (
@ -248,8 +248,8 @@ class ComposerStaticInit5d5db0943532ec3ad2d064ba31305947
),
'Jfcherng\\Diff\\' =>
array (
0 => __DIR__ . '/..' . '/jfcherng/php-sequence-matcher/src',
1 => __DIR__ . '/..' . '/jfcherng/php-diff/src',
0 => __DIR__ . '/..' . '/jfcherng/php-diff/src',
1 => __DIR__ . '/..' . '/jfcherng/php-sequence-matcher/src',
),
'GuzzleHttp\\Psr7\\' =>
array (

View File

@ -2271,17 +2271,17 @@
},
{
"name": "predis/predis",
"version": "v3.0.1",
"version_normalized": "3.0.1.0",
"version": "v3.1.0",
"version_normalized": "3.1.0.0",
"source": {
"type": "git",
"url": "https://github.com/predis/predis.git",
"reference": "34fb0a7da0330df1bab4280fcac4afdeeccc3edf"
"reference": "202e0c5322b906ec4c761c0cefebad6d0959a699"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/predis/predis/zipball/34fb0a7da0330df1bab4280fcac4afdeeccc3edf",
"reference": "34fb0a7da0330df1bab4280fcac4afdeeccc3edf",
"url": "https://api.github.com/repos/predis/predis/zipball/202e0c5322b906ec4c761c0cefebad6d0959a699",
"reference": "202e0c5322b906ec4c761c0cefebad6d0959a699",
"shasum": ""
},
"require": {
@ -2297,7 +2297,7 @@
"suggest": {
"ext-relay": "Faster connection with in-memory caching (>=0.6.2)"
},
"time": "2025-05-16T18:30:32+00:00",
"time": "2025-07-22T15:37:44+00:00",
"type": "library",
"installation-source": "dist",
"autoload": {
@ -2325,7 +2325,7 @@
],
"support": {
"issues": "https://github.com/predis/predis/issues",
"source": "https://github.com/predis/predis/tree/v3.0.1"
"source": "https://github.com/predis/predis/tree/v3.1.0"
},
"funding": [
{

View File

@ -3,7 +3,7 @@
'name' => 'icinga/icinga-php-thirdparty',
'pretty_version' => 'dev-main',
'version' => 'dev-main',
'reference' => 'a3a9a0f9a8449974ad52dcfbd5b1f1512e6e8bdb',
'reference' => '3308c53f448a7d71ae640f9464b45b7d286e946b',
'type' => 'project',
'install_path' => __DIR__ . '/../../',
'aliases' => array(),
@ -265,7 +265,7 @@
'icinga/icinga-php-thirdparty' => array(
'pretty_version' => 'dev-main',
'version' => 'dev-main',
'reference' => 'a3a9a0f9a8449974ad52dcfbd5b1f1512e6e8bdb',
'reference' => '3308c53f448a7d71ae640f9464b45b7d286e946b',
'type' => 'project',
'install_path' => __DIR__ . '/../../',
'aliases' => array(),
@ -323,9 +323,9 @@
),
),
'predis/predis' => array(
'pretty_version' => 'v3.0.1',
'version' => '3.0.1.0',
'reference' => '34fb0a7da0330df1bab4280fcac4afdeeccc3edf',
'pretty_version' => 'v3.1.0',
'version' => '3.1.0.0',
'reference' => '202e0c5322b906ec4c761c0cefebad6d0959a699',
'type' => 'library',
'install_path' => __DIR__ . '/../predis/predis',
'aliases' => array(),

View File

@ -19,8 +19,7 @@ if ($issues) {
echo 'Composer detected issues in your platform:' . PHP_EOL.PHP_EOL . str_replace('You are running '.PHP_VERSION.'.', '', implode(PHP_EOL, $issues)) . PHP_EOL.PHP_EOL;
}
}
trigger_error(
'Composer detected issues in your platform: ' . implode(' ', $issues),
E_USER_ERROR
throw new \RuntimeException(
'Composer detected issues in your platform: ' . implode(' ', $issues)
);
}

View File

@ -138,6 +138,50 @@ it is still desired to have control of when the connection is opened or closed:
achieved by invoking `$client->connect()` and `$client->disconnect()`. Please note that the effect
of these methods on aggregate connections may differ depending on each specific implementation.
#### Persistent connections ####
To increase a performance of your application you may set up a client to use persistent TCP connection, this way
client saves a time on socket creation and connection handshake. By default, connection is created on first-command
execution and will be automatically closed by GC before the process is being killed.
However, if your application is backed by PHP-FPM the processes are idle, and you may set up it to be persistent and
reusable across multiple script execution within the same process.
To enable the persistent connection mode you should provide following configuration:
```php
// Standalone
$client = new Predis\Client(['persistent' => true]);
// Cluster
$client = new Predis\Client(
['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
['cluster' => 'redis', 'parameters' => ['persistent' => true]]
);
```
**Important**
If you operate on multiple clients within the same application, and they communicate with the same resource, by default
they will share the same socket (that's the default behaviour of persistent sockets). So in this case you would need
to additionally provide a `conn_uid` identifier for each client, this way each client will create its own socket so
the connection context won't be shared across clients. This socket behaviour explained
[here](https://www.php.net/manual/en/function.stream-socket-client.php#105393)
```php
// Standalone
$client1 = new Predis\Client(['persistent' => true, 'conn_uid' => 'id_1']);
$client2 = new Predis\Client(['persistent' => true, 'conn_uid' => 'id_2']);
// Cluster
$client1 = new Predis\Client(
['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
['cluster' => 'redis', 'parameters' => ['persistent' => true, 'conn_uid' => 'id_1']]
);
$client2 = new Predis\Client(
['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
['cluster' => 'redis', 'parameters' => ['persistent' => true, 'conn_uid' => 'id_2']]
);
```
### Client configuration ###

View File

@ -54,7 +54,7 @@ use Traversable;
*/
class Client implements ClientInterface, IteratorAggregate
{
public const VERSION = '3.0.1';
public const VERSION = '3.1.0';
/** @var OptionsInterface */
private $options;

View File

@ -45,6 +45,7 @@ use Predis\Command\Container\Json\JSONDEBUG;
use Predis\Command\Container\Search\FTCONFIG;
use Predis\Command\Container\Search\FTCURSOR;
use Predis\Command\Container\XGROUP;
use Predis\Command\Redis\VADD;
/**
* Interface defining a client-side context such as a pipeline or transaction.
@ -283,6 +284,19 @@ use Predis\Command\Container\XGROUP;
* @method $this tsqueryindex(string ...$filterExpression)
* @method $this tsrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
* @method $this tsrevrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
* @method $this xack(string $key, string $group, string ...$id)
* @method $this xadd(string $key, array $dictionary, string $id = '*', array $options = null)
* @method $this xautoclaim(string $key, string $group, string $consumer, int $minIdleTime, string $start, ?int $count = null, bool $justId = false)
* @method $this xclaim(string $key, string $group, string $consumer, int $minIdleTime, string|array $ids, ?int $idle = null, ?int $time = null, ?int $retryCount = null, bool $force = false, bool $justId = false, ?string $lastId = null)
* @method $this xdel(string $key, string ...$id)
* @method $this xlen(string $key)
* @method $this xpending(string $key, string $group, ?int $minIdleTime = null, ?string $start = null, ?string $end = null, ?int $count = null, ?string $consumer = null)
* @method $this xrevrange(string $key, string $end, string $start, ?int $count = null)
* @method $this xrange(string $key, string $start, string $end, ?int $count = null)
* @method $this xread(int $count = null, int $block = null, array $streams = null, string ...$id)
* @method $this xreadgroup(string $group, string $consumer, ?int $count = null, ?int $blockMs = null, bool $noAck = false, string ...$keyOrId)
* @method $this xsetid(string $key, string $lastId, ?int $entriesAdded = null, ?string $maxDeleteId = null)
* @method $this xtrim(string $key, array|string $strategy, string $threshold, array $options = null)
* @method $this zadd($key, array $membersAndScoresDictionary)
* @method $this zcard($key)
* @method $this zcount($key, $min, $max)
@ -325,6 +339,17 @@ use Predis\Command\Container\XGROUP;
* @method $this unwatch()
* @method $this waitaof(int $numLocal, int $numReplicas, int $timeout)
* @method $this unsubscribe(string ...$channels)
* @method $this vadd(string $key, string|array $vector, string $elem, int $dim = null, bool $cas = false, string $quant = VADD::QUANT_DEFAULT, ?int $BEF = null, string|array $attributes = null, int $numlinks = null)
* @method $this vcard(string $key)
* @method $this vdim(int $key)
* @method $this vemb(string $key, string $elem, bool $raw = false)
* @method $this vgetattr(string $key, string $elem, bool $asJson = false)
* @method $this vinfo(string $key)
* @method $this vlinks(string $key, string $elem, bool $withScores = false)
* @method $this vrandmember(string $key, int $count = null)
* @method $this vrem(string $key, string $elem)
* @method $this vsetattr(string $key, string $elem, string|array $attributes)
* @method $this vsim(string $key, string|array $vectorOrElem, bool $isElem = false, bool $withScores = false, int $count = null, int $ef = null, string $filter = null, int $filterEf = null, bool $truth = false, bool $noThread = false)
* @method $this watch($key)
* @method $this eval($script, $numkeys, $keyOrArg1 = null, $keyOrArgN = null)
* @method $this eval_ro(string $script, array $keys, ...$argument)

View File

@ -47,6 +47,7 @@ use Predis\Command\Container\Search\FTCURSOR;
use Predis\Command\Container\XGROUP;
use Predis\Command\Container\XINFO;
use Predis\Command\FactoryInterface;
use Predis\Command\Redis\VADD;
use Predis\Configuration\OptionsInterface;
use Predis\Connection\ConnectionInterface;
use Predis\Response\Status;
@ -294,18 +295,22 @@ use Predis\Response\Status;
* @method array tsqueryindex(string ...$filterExpression)
* @method array tsrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
* @method array tsrevrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
* @method int xack(string $key, string $group, string ...$id)
* @method string xadd(string $key, array $dictionary, string $id = '*', array $options = null)
* @method array xautoclaim(string $key, string $group, string $consumer, int $minIdleTime, string $start, ?int $count = null, bool $justId = false)
* @method array xclaim(string $key, string $group, string $consumer, int $minIdleTime, string|array $ids, ?int $idle = null, ?int $time = null, ?int $retryCount = null, bool $force = false, bool $justId = false, ?string $lastId = null)
* @method int xdel(string $key, string ...$id)
* @method int xlen(string $key)
* @method array xpending(string $key, string $group, ?int $minIdleTime = null, ?string $start = null, ?string $end = null, ?int $count = null, ?string $consumer = null)
* @method array xrevrange(string $key, string $end, string $start, ?int $count = null)
* @method array xrange(string $key, string $start, string $end, ?int $count = null)
* @method array|null xread(int $count = null, int $block = null, array $streams = null, string ...$id)
* @method array xreadgroup(string $group, string $consumer, ?int $count = null, ?int $blockMs = null, bool $noAck = false, string ...$keyOrId)
* @method Status xsetid(string $key, string $lastId, ?int $entriesAdded = null, ?string $maxDeleteId = null)
* @method string xtrim(string $key, array|string $strategy, string $threshold, array $options = null)
* @method int zadd(string $key, array $membersAndScoresDictionary)
* @method int zcard(string $key)
* @method string zcount(string $key, int|string $min, int|string $max)
* @method int zcount(string $key, int|string $min, int|string $max)
* @method array zdiff(array $keys, bool $withScores = false)
* @method int zdiffstore(string $destination, array $keys)
* @method string zincrby(string $key, int $increment, string $member)
@ -346,6 +351,17 @@ use Predis\Response\Status;
* @method mixed multi()
* @method mixed unwatch()
* @method array unsubscribe(string ...$channels)
* @method bool vadd(string $key, string|array $vector, string $elem, int $dim = null, bool $cas = false, string $quant = VADD::QUANT_DEFAULT, int $bef = null, string|array $attributes = null, int $numlinks = null)
* @method int vcard(string $key)
* @method int vdim(string $key)
* @method array vemb(string $key, string $elem, bool $raw = false)
* @method string|array|null vgetattr(string $key, string $elem, bool $asJson = false)
* @method array|null vinfo(string $key)
* @method array|null vlinks(string $key, string $elem, bool $withScores = false)
* @method string|array|null vrandmember(string $key, int $count = null)
* @method bool vrem(string $key, string $elem)
* @method array vsim(string $key, string|array $vectorOrElem, bool $isElem = false, bool $withScores = false, int $count = null, int $ef = null, string $filter = null, int $filterEf = null, bool $truth = false, bool $noThread = false)
* @method bool vsetattr(string $key, string $elem, string|array $attributes)
* @method array waitaof(int $numLocal, int $numReplicas, int $timeout)
* @method mixed watch(string[]|string $keyOrKeys)
* @method mixed eval(string $script, int $numkeys, string ...$keyOrArg = null)

View File

@ -32,7 +32,7 @@ abstract class PrefixableCommand extends Command implements PrefixableCommandInt
*/
public function applyPrefixForAllArguments(string $prefix): void
{
$this->setArguments(
$this->setRawArguments(
array_map(static function ($key) use ($prefix) {
return $prefix . $key;
}, $this->getArguments())
@ -49,7 +49,7 @@ abstract class PrefixableCommand extends Command implements PrefixableCommandInt
{
$arguments = $this->getArguments();
$arguments[0] = $prefix . $arguments[0];
$this->setArguments($arguments);
$this->setRawArguments($arguments);
}
/**

View File

@ -12,6 +12,7 @@
namespace Predis\Command\Redis;
use InvalidArgumentException;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
@ -19,6 +20,8 @@ use Predis\Command\PrefixableCommand as RedisCommand;
*/
class BITOP extends RedisCommand
{
private const VALID_OPERATIONS = ['AND', 'OR', 'XOR', 'NOT', 'DIFF', 'DIFF1', 'ANDOR', 'ONE'];
/**
* {@inheritdoc}
*/
@ -38,6 +41,13 @@ class BITOP extends RedisCommand
array_unshift($arguments, $operation, $destination);
}
if (!empty($arguments)) {
$operation = strtoupper($arguments[0]);
if (!in_array($operation, self::VALID_OPERATIONS, false)) {
throw new InvalidArgumentException('BITOP operation must be one of: AND, OR, XOR, NOT, DIFF, DIFF1, ANDOR, ONE');
}
}
parent::setArguments($arguments);
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.add/
@ -26,4 +26,9 @@ class BFADD extends RedisCommand
{
return 'BF.ADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.exists/
@ -25,4 +25,9 @@ class BFEXISTS extends RedisCommand
{
return 'BF.EXISTS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use UnexpectedValueException;
/**
@ -76,4 +76,9 @@ class BFINFO extends RedisCommand
return $data;
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\BloomFilters\Capacity;
use Predis\Command\Traits\BloomFilters\Error;
use Predis\Command\Traits\BloomFilters\Expansion;
@ -48,6 +48,11 @@ class BFINSERT extends RedisCommand
return 'BF.INSERT';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
public function setArguments(array $arguments)
{
$this->setNoCreate($arguments);

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.loadchunk/
@ -25,4 +25,9 @@ class BFLOADCHUNK extends RedisCommand
{
return 'BF.LOADCHUNK';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.madd/
@ -26,4 +26,9 @@ class BFMADD extends RedisCommand
{
return 'BF.MADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.mexists/
@ -25,4 +25,9 @@ class BFMEXISTS extends RedisCommand
{
return 'BF.MEXISTS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\BloomFilters\Expansion;
/**
@ -46,4 +46,9 @@ class BFRESERVE extends RedisCommand
$this->setExpansion($arguments);
$this->filterArguments();
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\BloomFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/bf.scandump/
@ -26,4 +26,9 @@ class BFSCANDUMP extends RedisCommand
{
return 'BF.SCANDUMP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.incrby/
@ -26,4 +26,9 @@ class CMSINCRBY extends RedisCommand
{
return 'CMS.INCRBY';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.info/
@ -42,4 +42,9 @@ class CMSINFO extends RedisCommand
return $data;
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.initbydim/
@ -25,4 +25,9 @@ class CMSINITBYDIM extends RedisCommand
{
return 'CMS.INITBYDIM';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.initbyprob/
@ -25,4 +25,9 @@ class CMSINITBYPROB extends RedisCommand
{
return 'CMS.INITBYPROB';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.merge/
@ -39,4 +39,17 @@ class CMSMERGE extends RedisCommand
parent::setArguments($processedArguments);
}
public function prefixKeys($prefix)
{
if ($arguments = $this->getArguments()) {
$arguments[0] = $prefix . $arguments[0];
for ($i = 2, $iMax = (int) $arguments[1] + 2; $i < $iMax; $i++) {
$arguments[$i] = $prefix . $arguments[$i];
}
$this->setRawArguments($arguments);
}
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CountMinSketch;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cms.query/
@ -25,4 +25,9 @@ class CMSQUERY extends RedisCommand
{
return 'CMS.QUERY';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.add/
@ -25,4 +25,9 @@ class CFADD extends RedisCommand
{
return 'CF.ADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.addnx/
@ -25,4 +25,9 @@ class CFADDNX extends RedisCommand
{
return 'CF.ADDNX';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.count/
@ -26,4 +26,9 @@ class CFCOUNT extends RedisCommand
{
return 'CF.COUNT';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.del/
@ -27,4 +27,9 @@ class CFDEL extends RedisCommand
{
return 'CF.DEL';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.exists/
@ -25,4 +25,9 @@ class CFEXISTS extends RedisCommand
{
return 'CF.EXISTS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.info/
@ -42,4 +42,9 @@ class CFINFO extends RedisCommand
return $data;
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\BloomFilters\Capacity;
use Predis\Command\Traits\BloomFilters\Items;
use Predis\Command\Traits\BloomFilters\NoCreate;
@ -49,4 +49,9 @@ class CFINSERT extends RedisCommand
$this->setCapacity($arguments);
$this->filterArguments();
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.loadchunk/
@ -26,4 +26,9 @@ class CFLOADCHUNK extends RedisCommand
{
return 'CF.LOADCHUNK';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.mexists/
@ -25,4 +25,9 @@ class CFMEXISTS extends RedisCommand
{
return 'CF.MEXISTS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\BloomFilters\BucketSize;
use Predis\Command\Traits\BloomFilters\Expansion;
use Predis\Command\Traits\BloomFilters\MaxIterations;
@ -49,4 +49,9 @@ class CFRESERVE extends RedisCommand
$this->setBucketSize($arguments);
$this->filterArguments();
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\CuckooFilter;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/cf.scandump/
@ -26,4 +26,9 @@ class CFSCANDUMP extends RedisCommand
{
return 'CF.SCANDUMP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/expiretime/
@ -26,4 +26,9 @@ class EXPIRETIME extends RedisCommand
{
return 'EXPIRETIME';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\By\GeoBy;
use Predis\Command\Traits\Count;
use Predis\Command\Traits\From\GeoFrom;
@ -119,4 +119,9 @@ class GEOSEARCH extends RedisCommand
return $parsedData;
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class GETDEL extends RedisCommand
{
@ -20,4 +20,9 @@ class GETDEL extends RedisCommand
{
return 'GETDEL';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrappend/
@ -25,4 +25,9 @@ class JSONARRAPPEND extends RedisCommand
{
return 'JSON.ARRAPPEND';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrindex/
@ -25,4 +25,9 @@ class JSONARRINDEX extends RedisCommand
{
return 'JSON.ARRINDEX';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrinsert/
@ -25,4 +25,9 @@ class JSONARRINSERT extends RedisCommand
{
return 'JSON.ARRINSERT';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrlen/
@ -25,4 +25,9 @@ class JSONARRLEN extends RedisCommand
{
return 'JSON.ARRLEN';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrpop/
@ -25,4 +25,9 @@ class JSONARRPOP extends RedisCommand
{
return 'JSON.ARRPOP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.arrtrim/
@ -25,4 +25,9 @@ class JSONARRTRIM extends RedisCommand
{
return 'JSON.ARRTRIM';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.clear/
@ -25,4 +25,9 @@ class JSONCLEAR extends RedisCommand
{
return 'JSON.CLEAR';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.del/
@ -25,4 +25,9 @@ class JSONDEL extends RedisCommand
{
return 'JSON.DEL';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.forget/
@ -25,4 +25,9 @@ class JSONFORGET extends RedisCommand
{
return 'JSON.FORGET';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\Json\Indent;
use Predis\Command\Traits\Json\Newline;
use Predis\Command\Traits\Json\Space;
@ -54,4 +54,9 @@ class JSONGET extends RedisCommand
$this->setIndent($arguments);
$this->filterArguments();
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.merge/
@ -26,4 +26,9 @@ class JSONMERGE extends RedisCommand
{
return 'JSON.MERGE';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class JSONMGET extends RedisCommand
{
@ -33,4 +33,9 @@ class JSONMGET extends RedisCommand
parent::setArguments($unpackedArguments);
}
public function prefixKeys($prefix)
{
$this->applyPrefixSkippingLastArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.mset/
@ -25,4 +25,15 @@ class JSONMSET extends RedisCommand
{
return 'JSON.MSET';
}
public function prefixKeys($prefix)
{
if ($arguments = $this->getArguments()) {
for ($i = 0, $l = count($arguments); $i < $l; $i += 3) {
$arguments[$i] = $prefix . $arguments[$i];
}
$this->setArguments($arguments);
}
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.numincrby/
@ -25,4 +25,9 @@ class JSONNUMINCRBY extends RedisCommand
{
return 'JSON.NUMINCRBY';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.objkeys/
@ -25,4 +25,9 @@ class JSONOBJKEYS extends RedisCommand
{
return 'JSON.OBJKEYS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.objlen/
@ -25,4 +25,9 @@ class JSONOBJLEN extends RedisCommand
{
return 'JSON.OBJLEN';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.resp/
@ -25,4 +25,9 @@ class JSONRESP extends RedisCommand
{
return 'JSON.RESP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
use Predis\Command\Traits\Json\NxXxArgument;
/**
@ -38,4 +38,9 @@ class JSONSET extends RedisCommand
$this->setSubcommand($arguments);
$this->filterArguments();
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.strappend/
@ -25,4 +25,9 @@ class JSONSTRAPPEND extends RedisCommand
{
return 'JSON.STRAPPEND';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.strlen/
@ -25,4 +25,9 @@ class JSONSTRLEN extends RedisCommand
{
return 'JSON.STRLEN';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.toggle/
@ -25,4 +25,9 @@ class JSONTOGGLE extends RedisCommand
{
return 'JSON.TOGGLE';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Json;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/json.type/
@ -25,4 +25,9 @@ class JSONTYPE extends RedisCommand
{
return 'JSON.TYPE';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class LMOVE extends RedisCommand
{
@ -20,4 +20,14 @@ class LMOVE extends RedisCommand
{
return 'LMOVE';
}
public function prefixKeys($prefix)
{
if ($arguments = $this->getArguments()) {
$arguments[0] = $prefix . $arguments[0];
$arguments[1] = $prefix . $arguments[1];
$this->setRawArguments($arguments);
}
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/smismember/
@ -25,4 +25,9 @@ class SMISMEMBER extends RedisCommand
{
return 'SMISMEMBER';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.aggregate/
@ -50,4 +50,9 @@ class FTAGGREGATE extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.aliasadd/
@ -25,4 +25,9 @@ class FTALIASADD extends RedisCommand
{
return 'FT.ALIASADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForAllArguments($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.aliasdel/
@ -25,4 +25,9 @@ class FTALIASDEL extends RedisCommand
{
return 'FT.ALIASDEL';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.aliasupdate/
@ -26,4 +26,9 @@ class FTALIASUPDATE extends RedisCommand
{
return 'FT.ALIASUPDATE';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForAllArguments($prefix);
}
}

View File

@ -13,7 +13,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class FTALTER extends RedisCommand
{
@ -39,4 +39,9 @@ class FTALTER extends RedisCommand
$schema
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -13,7 +13,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.create/
@ -44,4 +44,9 @@ class FTCREATE extends RedisCommand
$schema
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class FTCURSOR extends RedisCommand
{
@ -31,4 +31,9 @@ class FTCURSOR extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.dictadd/
@ -25,4 +25,9 @@ class FTDICTADD extends RedisCommand
{
return 'FT.DICTADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.dictdel/
@ -25,4 +25,9 @@ class FTDICTDEL extends RedisCommand
{
return 'FT.DICTDEL';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.dictdump/
@ -25,4 +25,9 @@ class FTDICTDUMP extends RedisCommand
{
return 'FT.DICTDUMP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class FTDROPINDEX extends RedisCommand
{
@ -35,4 +35,9 @@ class FTDROPINDEX extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.explain/
@ -49,4 +49,9 @@ class FTEXPLAIN extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.info/
@ -25,4 +25,9 @@ class FTINFO extends RedisCommand
{
return 'FT.INFO';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.profile/
@ -35,4 +35,9 @@ class FTPROFILE extends RedisCommand
$arguments->toArray()
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.search/
@ -49,4 +49,9 @@ class FTSEARCH extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
class FTSPELLCHECK extends RedisCommand
{
@ -48,4 +48,9 @@ class FTSPELLCHECK extends RedisCommand
$commandArguments
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.syndump/
@ -25,4 +25,9 @@ class FTSYNDUMP extends RedisCommand
{
return 'FT.SYNDUMP';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.synupdate/
@ -43,4 +43,9 @@ class FTSYNUPDATE extends RedisCommand
$terms
));
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\Search;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/ft.tagvals/
@ -25,4 +25,9 @@ class FTTAGVALS extends RedisCommand
{
return 'FT.TAGVALS';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.add/
@ -25,4 +25,9 @@ class TDIGESTADD extends RedisCommand
{
return 'TDIGEST.ADD';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.byrank/
@ -52,4 +52,9 @@ class TDIGESTBYRANK extends RedisCommand
}
}, $data);
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.byrevrank/
@ -52,4 +52,9 @@ class TDIGESTBYREVRANK extends RedisCommand
}
}, $data);
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.cdf/
@ -54,4 +54,9 @@ class TDIGESTCDF extends RedisCommand
}
}, $data);
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.create/
@ -37,4 +37,9 @@ class TDIGESTCREATE extends RedisCommand
parent::setArguments($arguments);
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.info/
@ -38,4 +38,9 @@ class TDIGESTINFO extends RedisCommand
return $result;
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.max/
@ -46,4 +46,9 @@ class TDIGESTMAX extends RedisCommand
default: return $data;
}
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.merge/
@ -40,4 +40,17 @@ class TDIGESTMERGE extends RedisCommand
parent::setArguments($processedArguments);
}
public function prefixKeys($prefix)
{
if ($arguments = $this->getArguments()) {
$arguments[0] = $prefix . $arguments[0];
for ($i = 2, $iMax = (int) $arguments[1] + 2; $i < $iMax; $i++) {
$arguments[$i] = $prefix . $arguments[$i];
}
$this->setRawArguments($arguments);
}
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.min/
@ -46,4 +46,9 @@ class TDIGESTMIN extends RedisCommand
default: return $data;
}
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.quantile/
@ -52,4 +52,9 @@ class TDIGESTQUANTILE extends RedisCommand
}
}, $data);
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.rank/
@ -27,4 +27,9 @@ class TDIGESTRANK extends RedisCommand
{
return 'TDIGEST.RANK';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.reset/
@ -25,4 +25,9 @@ class TDIGESTRESET extends RedisCommand
{
return 'TDIGEST.RESET';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.revrank/
@ -27,4 +27,9 @@ class TDIGESTREVRANK extends RedisCommand
{
return 'TDIGEST.REVRANK';
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

View File

@ -12,7 +12,7 @@
namespace Predis\Command\Redis\TDigest;
use Predis\Command\Command as RedisCommand;
use Predis\Command\PrefixableCommand as RedisCommand;
/**
* @see https://redis.io/commands/tdigest.trimmed_mean/
@ -47,4 +47,9 @@ class TDIGESTTRIMMED_MEAN extends RedisCommand
default: return $data;
}
}
public function prefixKeys($prefix)
{
$this->applyPrefixForFirstArgument($prefix);
}
}

Some files were not shown because too many files have changed in this diff Show More