geckon01/predis
1
0
Fork 0
mirror of https://github.com/predis/predis.git synced 2026-08-24 14:29:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added support for sharded pub/sub consumer (#1303)

Browse Source 
* Added support for sharded pub/sub consumer

* Removed query parameter

* Fix typo

* Codestyle fixes

* Added support for sharded pub/sub against DispatcherLoop

* Updated sharded consumer example to subscribe on differend shard channels

* Added test coverage

* Removed cluster condition for pub/sub

* Codestyle fixes

* Changed socket read interface, added parameters as dependency to cluster connection

* Added for interface consistency

* Updated method description

* Updated method description

* Removed redundant exception

* Codestyle fix

* Updated README

* Mark tests as relay-incompatible

* Mark tests as relay-incompatible

* Mark tests as relay-incompatible

* Moved sharded pub/sub functionality to new consumer

* Codestyle fixes

* Resolve context depends on connection type

* Codestyle fixes
This commit is contained in:
Vladyslav Vildanov
2023-07-19 16:28:14 +03:00
committed by GitHub
parent 6a1a2c4734
commit 021238f58b
29 changed files with 957 additions and 162 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ClientInterface.php
+3
View File
@@ -348,6 +348,9 @@ use Predis\Response\Status;
* @method mixed save()
* @method mixed slaveof(string $host, int $port)
* @method mixed slowlog($subcommand, $argument = null)
* @method int spublish(string $shardChannel, string $message)
* @method array ssubscribe(string ...$shardChannels)
* @method array sunsubscribe(string ...$shardChannels)
* @method array time()
* @method array command()
* @method int geoadd(string $key, $longitude, $latitude, $member)