geckon01/predis
1
0
Fork 0
mirror of https://github.com/predis/predis.git synced 2026-08-31 12:43:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added vector sets commands to ClusterStrategy (#1710)

Browse Source
This commit is contained in:
Róbert Kelčák
2026-07-23 08:47:49 +02:00
committed by GitHub
parent c9494ab124
commit bb5ca97854
4 changed files with 81 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
CHANGELOG.md
+1
View File
@@ -13,6 +13,7 @@
- Added support for `LMOVEM` and `BLMOVEM` commands
- Added support for `FT.ALIASLIST` command
- Added stream commands to ClusterStrategy
- Added vector sets commands to ClusterStrategy
### Fixed
- Fixed Sentinel does not wipe servers on exception caused (#1694)
src/Cluster/ClusterStrategy.php
+14
View File
@@ -201,6 +201,20 @@ abstract class ClusterStrategy implements StrategyInterface
'XSETID' => $getKeyFromFirstArgument,
'XTRIM' => $getKeyFromFirstArgument,
/* commands operating on vector sets */
'VADD' => $getKeyFromFirstArgument,
'VCARD' => $getKeyFromFirstArgument,
'VDIM' => $getKeyFromFirstArgument,
'VEMB' => $getKeyFromFirstArgument,
'VGETATTR' => $getKeyFromFirstArgument,
'VINFO' => $getKeyFromFirstArgument,
'VLINKS' => $getKeyFromFirstArgument,
'VRANDMEMBER' => $getKeyFromFirstArgument,
'VRANGE' => $getKeyFromFirstArgument,
'VREM' => $getKeyFromFirstArgument,
'VSETATTR' => $getKeyFromFirstArgument,
'VSIM' => $getKeyFromFirstArgument,
/* commands operating on time series */
'TS.READ' => $getKeyFromFirstArgument,
tests/Predis/Cluster/PredisStrategyTest.php
+33
View File
@@ -331,6 +331,25 @@ class PredisStrategyTest extends PredisTestCase
}
}
/**
* @group disconnected
*/
public function testKeysForVectorSetCommands(): void
{
$strategy = $this->getClusterStrategy();
$commands = $this->getCommandFactory();
$arguments = [
'VADD' => ['key', [1.0, 2.0], 'element'],
'VSIM' => ['key', [1.0, 2.0]],
];
foreach ($this->getExpectedCommands('keys-vector') as $commandID) {
$command = $commands->create($commandID, $arguments[$commandID]);
$this->assertSame($strategy->getSlotByKey('key'), $strategy->getSlot($command), $commandID);
}
}
/**
* @group disconnected
*/
@@ -667,6 +686,20 @@ class PredisStrategyTest extends PredisTestCase
'XSETID' => 'keys-first',
'XTRIM' => 'keys-first',
/* commands operating on vector sets */
'VADD' => 'keys-vector',
'VCARD' => 'keys-first',
'VDIM' => 'keys-first',
'VEMB' => 'keys-first',
'VGETATTR' => 'keys-first',
'VINFO' => 'keys-first',
'VLINKS' => 'keys-first',
'VRANDMEMBER' => 'keys-first',
'VRANGE' => 'keys-first',
'VREM' => 'keys-first',
'VSETATTR' => 'keys-first',
'VSIM' => 'keys-vector',
/* commands operating on time series */
'TS.READ' => 'keys-first',
tests/Predis/Cluster/RedisStrategyTest.php
+33
View File
@@ -341,6 +341,25 @@ class RedisStrategyTest extends PredisTestCase
}
}
/**
* @group disconnected
*/
public function testKeysForVectorSetCommands(): void
{
$strategy = $this->getClusterStrategy();
$commands = $this->getCommandFactory();
$arguments = [
'VADD' => ['key', [1.0, 2.0], 'element'],
'VSIM' => ['key', [1.0, 2.0]],
];
foreach ($this->getExpectedCommands('keys-vector') as $commandID) {
$command = $commands->create($commandID, $arguments[$commandID]);
$this->assertSame($strategy->getSlotByKey('key'), $strategy->getSlot($command), $commandID);
}
}
/**
* @group disconnected
*/
@@ -687,6 +706,20 @@ class RedisStrategyTest extends PredisTestCase
'XSETID' => 'keys-first',
'XTRIM' => 'keys-first',
/* commands operating on vector sets */
'VADD' => 'keys-vector',
'VCARD' => 'keys-first',
'VDIM' => 'keys-first',
'VEMB' => 'keys-first',
'VGETATTR' => 'keys-first',
'VINFO' => 'keys-first',
'VLINKS' => 'keys-first',
'VRANDMEMBER' => 'keys-first',
'VRANGE' => 'keys-first',
'VREM' => 'keys-first',
'VSETATTR' => 'keys-first',
'VSIM' => 'keys-vector',
/* commands operating on time series */
'TS.READ' => 'keys-first',