diff --git a/lib/Predis/Client.php b/lib/Predis/Client.php index 2ee20dd2..afa6c81f 100644 --- a/lib/Predis/Client.php +++ b/lib/Predis/Client.php @@ -17,9 +17,9 @@ use Predis\Command\CommandInterface; use Predis\Command\RawCommand; use Predis\Command\ScriptCommand; use Predis\Configuration; +use Predis\Connection; use Predis\Connection\AggregatedConnectionInterface; use Predis\Connection\ConnectionInterface; -use Predis\Connection\ConnectionParametersInterface; use Predis\Monitor; use Predis\Pipeline; use Predis\PubSub; @@ -83,7 +83,7 @@ class Client implements ClientInterface * Accepted types for connection parameters are: * * - Instance of Predis\Connection\ConnectionInterface. - * - Instance of Predis\Connection\ConnectionParametersInterface. + * - Instance of Predis\Connection\ParametersInterface. * - Array * - String * - Callable @@ -97,7 +97,7 @@ class Client implements ClientInterface return $parameters; } - if ($parameters instanceof ConnectionParametersInterface || is_string($parameters)) { + if ($parameters instanceof Connection\ParametersInterface || is_string($parameters)) { return $this->options->connections->create($parameters); } diff --git a/lib/Predis/Connection/AbstractConnection.php b/lib/Predis/Connection/AbstractConnection.php index 808533e8..e47e9cdf 100644 --- a/lib/Predis/Connection/AbstractConnection.php +++ b/lib/Predis/Connection/AbstractConnection.php @@ -33,9 +33,9 @@ abstract class AbstractConnection implements SingleConnectionInterface protected $initCmds = array(); /** - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. */ - public function __construct(ConnectionParametersInterface $parameters) + public function __construct(ParametersInterface $parameters) { $this->parameters = $this->assertParameters($parameters); } @@ -52,9 +52,9 @@ abstract class AbstractConnection implements SingleConnectionInterface /** * Checks some of the parameters used to initialize the connection. * - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. */ - protected function assertParameters(ConnectionParametersInterface $parameters) + protected function assertParameters(ParametersInterface $parameters) { $scheme = $parameters->scheme; diff --git a/lib/Predis/Connection/ComposableStreamConnection.php b/lib/Predis/Connection/ComposableStreamConnection.php index 6b1f9484..9ef32e79 100644 --- a/lib/Predis/Connection/ComposableStreamConnection.php +++ b/lib/Predis/Connection/ComposableStreamConnection.php @@ -26,11 +26,11 @@ class ComposableStreamConnection extends StreamConnection implements ComposableC protected $protocol; /** - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. * @param ProtocolProcessorInterface $protocol Protocol processor. */ public function __construct( - ConnectionParametersInterface $parameters, + ParametersInterface $parameters, ProtocolProcessorInterface $protocol = null ) { $this->parameters = $this->assertParameters($parameters); diff --git a/lib/Predis/Connection/Factory.php b/lib/Predis/Connection/Factory.php index 92309369..6728155b 100644 --- a/lib/Predis/Connection/Factory.php +++ b/lib/Predis/Connection/Factory.php @@ -74,8 +74,8 @@ class Factory implements FactoryInterface */ public function create($parameters) { - if (!$parameters instanceof ConnectionParametersInterface) { - $parameters = ConnectionParameters::create($parameters); + if (!$parameters instanceof ParametersInterface) { + $parameters = Parameters::create($parameters); } $scheme = $parameters->scheme; diff --git a/lib/Predis/Connection/ConnectionParameters.php b/lib/Predis/Connection/Parameters.php similarity index 97% rename from lib/Predis/Connection/ConnectionParameters.php rename to lib/Predis/Connection/Parameters.php index 34fda0ae..c066d40d 100644 --- a/lib/Predis/Connection/ConnectionParameters.php +++ b/lib/Predis/Connection/Parameters.php @@ -18,7 +18,7 @@ use InvalidArgumentException; * * @author Daniele Alessandri */ -class ConnectionParameters implements ConnectionParametersInterface +class Parameters implements ParametersInterface { private $parameters; @@ -70,7 +70,7 @@ class ConnectionParameters implements ConnectionParametersInterface * form of an URI string or a named array. * * @param array|string $parameters Set of connection parameters. - * @return ConnectionParameters + * @return Parameters */ public static function create($parameters) { diff --git a/lib/Predis/Connection/ConnectionParametersInterface.php b/lib/Predis/Connection/ParametersInterface.php similarity index 83% rename from lib/Predis/Connection/ConnectionParametersInterface.php rename to lib/Predis/Connection/ParametersInterface.php index 3e3cb380..1a901074 100644 --- a/lib/Predis/Connection/ConnectionParametersInterface.php +++ b/lib/Predis/Connection/ParametersInterface.php @@ -12,12 +12,11 @@ namespace Predis\Connection; /** - * Interface that must be implemented by classes that provide their own mechanism - * to parse and handle connection parameters. + * Interface for classes providing their own logic for connection parameters. * * @author Daniele Alessandri */ -interface ConnectionParametersInterface +interface ParametersInterface { /** * Checks if the specified parameters is set. diff --git a/lib/Predis/Connection/PhpiredisSocketConnection.php b/lib/Predis/Connection/PhpiredisSocketConnection.php index e9ef2a5e..3acc2e71 100644 --- a/lib/Predis/Connection/PhpiredisSocketConnection.php +++ b/lib/Predis/Connection/PhpiredisSocketConnection.php @@ -48,7 +48,7 @@ class PhpiredisSocketConnection extends AbstractConnection /** * {@inheritdoc} */ - public function __construct(ConnectionParametersInterface $parameters) + public function __construct(ParametersInterface $parameters) { $this->assertExtensions(); @@ -89,7 +89,7 @@ class PhpiredisSocketConnection extends AbstractConnection /** * {@inheritdoc} */ - protected function assertParameters(ConnectionParametersInterface $parameters) + protected function assertParameters(ParametersInterface $parameters) { if (isset($parameters->persistent)) { throw new NotSupportedException( @@ -186,9 +186,9 @@ class PhpiredisSocketConnection extends AbstractConnection * Sets options on the socket resource from the connection parameters. * * @param resource $socket Socket resource. - * @param ConnectionParametersInterface $parameters Parameters used to initialize the connection. + * @param ParametersInterface $parameters Parameters used to initialize the connection. */ - private function setSocketOptions($socket, ConnectionParametersInterface $parameters) + private function setSocketOptions($socket, ParametersInterface $parameters) { if ($parameters->scheme !== 'tcp') { return; @@ -225,10 +225,10 @@ class PhpiredisSocketConnection extends AbstractConnection /** * Gets the address from the connection parameters. * - * @param ConnectionParametersInterface $parameters Parameters used to initialize the connection. + * @param ParametersInterface $parameters Parameters used to initialize the connection. * @return string */ - private static function getAddress(ConnectionParametersInterface $parameters) + private static function getAddress(ParametersInterface $parameters) { if ($parameters->scheme === 'unix') { return $parameters->path; @@ -250,10 +250,10 @@ class PhpiredisSocketConnection extends AbstractConnection /** * Opens the actual connection to the server with a timeout. * - * @param ConnectionParametersInterface $parameters Parameters used to initialize the connection. + * @param ParametersInterface $parameters Parameters used to initialize the connection. * @return string */ - private function connectWithTimeout(ConnectionParametersInterface $parameters) + private function connectWithTimeout(ParametersInterface $parameters) { $host = self::getAddress($parameters); $socket = $this->getResource(); diff --git a/lib/Predis/Connection/PhpiredisStreamConnection.php b/lib/Predis/Connection/PhpiredisStreamConnection.php index 95c63014..0be0c057 100644 --- a/lib/Predis/Connection/PhpiredisStreamConnection.php +++ b/lib/Predis/Connection/PhpiredisStreamConnection.php @@ -51,7 +51,7 @@ class PhpiredisStreamConnection extends StreamConnection /** * {@inheritdoc} */ - public function __construct(ConnectionParametersInterface $parameters) + public function __construct(ParametersInterface $parameters) { $this->assertExtensions(); diff --git a/lib/Predis/Connection/SingleConnectionInterface.php b/lib/Predis/Connection/SingleConnectionInterface.php index 0b68c012..7deb83f0 100644 --- a/lib/Predis/Connection/SingleConnectionInterface.php +++ b/lib/Predis/Connection/SingleConnectionInterface.php @@ -37,7 +37,7 @@ interface SingleConnectionInterface extends ConnectionInterface /** * Returns the parameters used to initialize the connection. * - * @return ConnectionParametersInterface + * @return ParametersInterface */ public function getParameters(); diff --git a/lib/Predis/Connection/StreamConnection.php b/lib/Predis/Connection/StreamConnection.php index 2987dd39..a09dd691 100644 --- a/lib/Predis/Connection/StreamConnection.php +++ b/lib/Predis/Connection/StreamConnection.php @@ -60,10 +60,10 @@ class StreamConnection extends AbstractConnection /** * Initializes a TCP stream resource. * - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function tcpStreamInitializer(ConnectionParametersInterface $parameters) + private function tcpStreamInitializer(ParametersInterface $parameters) { $uri = "tcp://{$parameters->host}:{$parameters->port}"; $flags = STREAM_CLIENT_CONNECT; @@ -102,10 +102,10 @@ class StreamConnection extends AbstractConnection /** * Initializes a UNIX stream resource. * - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function unixStreamInitializer(ConnectionParametersInterface $parameters) + private function unixStreamInitializer(ParametersInterface $parameters) { $uri = "unix://{$parameters->path}"; $flags = STREAM_CLIENT_CONNECT; diff --git a/lib/Predis/Connection/WebdisConnection.php b/lib/Predis/Connection/WebdisConnection.php index 8f32a28d..143cdd8a 100644 --- a/lib/Predis/Connection/WebdisConnection.php +++ b/lib/Predis/Connection/WebdisConnection.php @@ -50,9 +50,9 @@ class WebdisConnection implements SingleConnectionInterface private $reader; /** - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. */ - public function __construct(ConnectionParametersInterface $parameters) + public function __construct(ParametersInterface $parameters) { $this->assertExtensions(); @@ -105,10 +105,10 @@ class WebdisConnection implements SingleConnectionInterface /** * Initializes cURL. * - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function createCurl(ConnectionParametersInterface $parameters) + private function createCurl(ParametersInterface $parameters) { $options = array( CURLOPT_FAILONERROR => true, @@ -131,10 +131,10 @@ class WebdisConnection implements SingleConnectionInterface /** * Initializes the phpiredis protocol reader. * - * @param ConnectionParametersInterface $parameters Initialization parameters for the connection. + * @param ParametersInterface $parameters Initialization parameters for the connection. * @return resource */ - private function createReader(ConnectionParametersInterface $parameters) + private function createReader(ParametersInterface $parameters) { $reader = phpiredis_reader_create(); diff --git a/tests/PHPUnit/PredisTestCase.php b/tests/PHPUnit/PredisTestCase.php index 45c04e20..bd4ed5e8 100644 --- a/tests/PHPUnit/PredisTestCase.php +++ b/tests/PHPUnit/PredisTestCase.php @@ -106,12 +106,12 @@ abstract class PredisTestCase extends PHPUnit_Framework_TestCase * Returns a new instance of connection parameters. * * @param array $additional Additional connection parameters. - * @return Connection\ConnectionParameters Default connection parameters. + * @return Connection\Parameters Default connection parameters. */ protected function getParameters($additional = array()) { $parameters = array_merge($this->getDefaultParametersArray(), $additional); - $parameters = new Connection\ConnectionParameters($parameters); + $parameters = new Connection\Parameters($parameters); return $parameters; } diff --git a/tests/Predis/CommunicationExceptionTest.php b/tests/Predis/CommunicationExceptionTest.php index 76f4d02e..6e65bcc7 100644 --- a/tests/Predis/CommunicationExceptionTest.php +++ b/tests/Predis/CommunicationExceptionTest.php @@ -12,7 +12,7 @@ namespace Predis; use PredisTestCase; -use Predis\Connection\SingleConnectionInterface; +use Predis\Connection; /** * @@ -79,7 +79,7 @@ class CommunicationExceptionTest extends PredisTestCase * Returns a mocked connection instance. * * @param mixed $parameters Connection parameters. - * @return SingleConnectionInterface + * @return Connection\SingleConnectionInterface */ protected function getMockedConnectionBase($parameters = null) { @@ -87,8 +87,8 @@ class CommunicationExceptionTest extends PredisTestCase if ($parameters === null) { $builder->disableOriginalConstructor(); - } else if (!$parameters instanceof ConnectionParametersInterface) { - $parameters = new ConnectionParameters($parameters); + } else if (!$parameters instanceof Connection\ParametersInterface) { + $parameters = new Connection\Parameters($parameters); } return $builder->getMockForAbstractClass(array($parameters)); @@ -97,14 +97,18 @@ class CommunicationExceptionTest extends PredisTestCase /** * Returns a connection exception instance. * - * @param SingleConnectionInterface $message Connection instance. + * @param Connection\SingleConnectionInterface $message Connection instance. * @param string $message Exception message. * @param int $code Exception code. * @param \Exception $inner Inner exception. * @return \Exception */ - protected function getException(SingleConnectionInterface $connection, $message, $code = 0, \Exception $inner = null) - { + protected function getException( + Connection\SingleConnectionInterface $connection, + $message, + $code = 0, + \Exception $inner = null + ) { $arguments = array($connection, $message, $code, $inner); $mock = $this->getMockForAbstractClass('Predis\CommunicationException', $arguments); diff --git a/tests/Predis/Connection/FactoryTest.php b/tests/Predis/Connection/FactoryTest.php index 957afdcf..51761649 100644 --- a/tests/Predis/Connection/FactoryTest.php +++ b/tests/Predis/Connection/FactoryTest.php @@ -35,7 +35,7 @@ class FactoryTest extends PredisTestCase { $factory = new Factory(); - $tcp = new ConnectionParameters(array( + $tcp = new Parameters(array( 'scheme' => 'tcp', 'host' => 'locahost', )); @@ -48,7 +48,7 @@ class FactoryTest extends PredisTestCase $this->assertEquals($tcp->database, $parameters->database); - $unix = new ConnectionParameters(array( + $unix = new Parameters(array( 'scheme' => 'unix', 'path' => '/tmp/redis.sock', )); @@ -117,7 +117,7 @@ class FactoryTest extends PredisTestCase $profile->expects($this->never())->method('create'); $factory = new Factory($profile); - $parameters = new ConnectionParameters(); + $parameters = new Parameters(); $connection = $factory->create($parameters); $this->assertInstanceOf('Predis\Connection\SingleConnectionInterface', $connection); @@ -129,7 +129,7 @@ class FactoryTest extends PredisTestCase */ public function testCreateConnectionWithInitializationCommands() { - $parameters = new ConnectionParameters(array( + $parameters = new Parameters(array( 'database' => '0', 'password' => 'foobar' )); @@ -162,7 +162,7 @@ class FactoryTest extends PredisTestCase $this->setExpectedException('InvalidArgumentException', "Unknown connection scheme: $scheme"); $factory = new Factory(); - $factory->create(new ConnectionParameters(array('scheme' => $scheme))); + $factory->create(new Parameters(array('scheme' => $scheme))); } /** @@ -172,7 +172,7 @@ class FactoryTest extends PredisTestCase { list(, $connectionClass) = $this->getMockConnectionClass(); - $parameters = new ConnectionParameters(array('scheme' => 'foobar')); + $parameters = new Parameters(array('scheme' => 'foobar')); $factory = new Factory(); $factory->define($parameters->scheme, $connectionClass); @@ -188,7 +188,7 @@ class FactoryTest extends PredisTestCase { list(, $connectionClass) = $this->getMockConnectionClass(); - $parameters = new ConnectionParameters(array('scheme' => 'foobar')); + $parameters = new Parameters(array('scheme' => 'foobar')); $initializer = function ($parameters) use ($connectionClass) { return new $connectionClass($parameters); diff --git a/tests/Predis/Connection/MasterSlaveReplicationTest.php b/tests/Predis/Connection/MasterSlaveReplicationTest.php index 9a559ad5..774d0ecc 100644 --- a/tests/Predis/Connection/MasterSlaveReplicationTest.php +++ b/tests/Predis/Connection/MasterSlaveReplicationTest.php @@ -576,7 +576,7 @@ class MasterSlaveReplicationTest extends PredisTestCase $connection = $this->getMock('Predis\Connection\SingleConnectionInterface'); if ($parameters) { - $parameters = ConnectionParameters::create($parameters); + $parameters = Parameters::create($parameters); $hash = "{$parameters->host}:{$parameters->port}"; $connection->expects($this->any()) diff --git a/tests/Predis/Connection/ConnectionParametersTest.php b/tests/Predis/Connection/ParametersTest.php similarity index 86% rename from tests/Predis/Connection/ConnectionParametersTest.php rename to tests/Predis/Connection/ParametersTest.php index 7bb9d3cc..1bd6e181 100644 --- a/tests/Predis/Connection/ConnectionParametersTest.php +++ b/tests/Predis/Connection/ParametersTest.php @@ -14,10 +14,10 @@ namespace Predis\Connection; use PredisTestCase; /** - * @todo ConnectionParameters::define(); - * @todo ConnectionParameters::undefine(); + * @todo Parameters::define(); + * @todo Parameters::undefine(); */ -class ConnectionParametersTest extends PredisTestCase +class ParametersTest extends PredisTestCase { /** * @group disconnected @@ -25,7 +25,7 @@ class ConnectionParametersTest extends PredisTestCase public function testDefaultValues() { $defaults = $this->getDefaultParametersArray(); - $parameters = new ConnectionParameters(); + $parameters = new Parameters(); $this->assertEquals($defaults['scheme'], $parameters->scheme); $this->assertEquals($defaults['host'], $parameters->host); @@ -38,13 +38,13 @@ class ConnectionParametersTest extends PredisTestCase */ public function testIsSet() { - $parameters = new ConnectionParameters(); + $parameters = new Parameters(); $this->assertTrue(isset($parameters->scheme)); $this->assertFalse(isset($parameters->unknown)); } - public function sharedTestsWithArrayParameters(ConnectionParameters $parameters) + public function sharedTestsWithArrayParameters(Parameters $parameters) { $this->assertTrue(isset($parameters->scheme)); $this->assertSame('tcp', $parameters->scheme); @@ -64,7 +64,7 @@ class ConnectionParametersTest extends PredisTestCase */ public function testConstructWithArrayParameters() { - $parameters = new ConnectionParameters(array( + $parameters = new Parameters(array( 'port' => 7000, 'custom' => 'foobar' )); @@ -77,7 +77,7 @@ class ConnectionParametersTest extends PredisTestCase */ public function testCreateWithArrayParameters() { - $parameters = new ConnectionParameters(array( + $parameters = new Parameters(array( 'port' => 7000, 'custom' => 'foobar' )); @@ -99,7 +99,7 @@ class ConnectionParametersTest extends PredisTestCase ); $uriString = $this->getParametersString($overrides); - $parameters = ConnectionParameters::create($uriString); + $parameters = Parameters::create($uriString); $this->sharedTestsWithArrayParameters($parameters); $this->assertEquals($overrides['database'], $parameters->database); @@ -111,7 +111,7 @@ class ConnectionParametersTest extends PredisTestCase public function testToArray() { $additional = array('port' => 7000, 'custom' => 'foobar'); - $parameters = new ConnectionParameters($additional); + $parameters = new Parameters($additional); $this->assertEquals($this->getParametersArray($additional), $parameters->toArray()); } @@ -121,7 +121,7 @@ class ConnectionParametersTest extends PredisTestCase */ public function testSerialization() { - $parameters = new ConnectionParameters(array('port' => 7000, 'custom' => 'foobar')); + $parameters = new Parameters(array('port' => 7000, 'custom' => 'foobar')); $unserialized = unserialize(serialize($parameters)); $this->assertEquals($parameters->scheme, $unserialized->scheme); @@ -149,7 +149,7 @@ class ConnectionParametersTest extends PredisTestCase 'persistent' => '1', ); - $this->assertSame($expected, ConnectionParameters::parse($uri)); + $this->assertSame($expected, Parameters::parse($uri)); } /** @@ -167,7 +167,7 @@ class ConnectionParametersTest extends PredisTestCase 'persistent' => '1', ); - $this->assertSame($expected, ConnectionParameters::parse($uri)); + $this->assertSame($expected, Parameters::parse($uri)); } /** @@ -185,7 +185,7 @@ class ConnectionParametersTest extends PredisTestCase 'bar' => '', ); - $this->assertSame($expected, ConnectionParameters::parse($uri)); + $this->assertSame($expected, Parameters::parse($uri)); } /** @@ -202,7 +202,7 @@ class ConnectionParametersTest extends PredisTestCase 'persistent' => '1', ); - $this->assertSame($expected, ConnectionParameters::parse($uri)); + $this->assertSame($expected, Parameters::parse($uri)); } /** @@ -219,7 +219,7 @@ class ConnectionParametersTest extends PredisTestCase 'metavars' => array('foo', 'hoge'), ); - $this->assertSame($expected, ConnectionParameters::parse($uri)); + $this->assertSame($expected, Parameters::parse($uri)); } /** @@ -229,7 +229,7 @@ class ConnectionParametersTest extends PredisTestCase */ public function testParsingURIThrowOnInvalidURI() { - ConnectionParameters::parse('tcp://invalid:uri'); + Parameters::parse('tcp://invalid:uri'); } // ******************************************************************** // diff --git a/tests/Predis/Connection/PredisClusterTest.php b/tests/Predis/Connection/PredisClusterTest.php index 9d45e9ac..f6673263 100644 --- a/tests/Predis/Connection/PredisClusterTest.php +++ b/tests/Predis/Connection/PredisClusterTest.php @@ -388,7 +388,7 @@ class PredisClusterTest extends PredisTestCase $connection = $this->getMock('Predis\Connection\SingleConnectionInterface'); if ($parameters) { - $parameters = ConnectionParameters::create($parameters); + $parameters = Parameters::create($parameters); $hash = "{$parameters->host}:{$parameters->port}"; $connection->expects($this->any()) diff --git a/tests/Predis/Connection/RedisClusterTest.php b/tests/Predis/Connection/RedisClusterTest.php index c6892e72..655e512c 100644 --- a/tests/Predis/Connection/RedisClusterTest.php +++ b/tests/Predis/Connection/RedisClusterTest.php @@ -652,7 +652,7 @@ class RedisClusterTest extends PredisTestCase $connection = $this->getMock('Predis\Connection\SingleConnectionInterface'); if ($parameters) { - $parameters = ConnectionParameters::create($parameters); + $parameters = Parameters::create($parameters); $hash = "{$parameters->host}:{$parameters->port}"; $connection->expects($this->any()) diff --git a/tests/Predis/Response/Iterator/MultiBulkTest.php b/tests/Predis/Response/Iterator/MultiBulkTest.php index c8a68639..2f5ce5c5 100644 --- a/tests/Predis/Response/Iterator/MultiBulkTest.php +++ b/tests/Predis/Response/Iterator/MultiBulkTest.php @@ -14,7 +14,6 @@ namespace Predis\Response\Iterator; use PredisTestCase; use Predis\Client; use Predis\Connection\ComposableStreamConnection; -use Predis\Connection\ConnectionParameters; use Predis\Protocol\Text\ProtocolProcessor as TextProtocolProcessor; /** diff --git a/tests/Predis/Response/Iterator/MultiBulkTupleTest.php b/tests/Predis/Response/Iterator/MultiBulkTupleTest.php index e3fbe51c..0d34690a 100644 --- a/tests/Predis/Response/Iterator/MultiBulkTupleTest.php +++ b/tests/Predis/Response/Iterator/MultiBulkTupleTest.php @@ -14,7 +14,6 @@ namespace Predis\Response\Iterator; use PredisTestCase; use Predis\Client; use Predis\Connection\ComposableStreamConnection; -use Predis\Connection\ConnectionParameters; use Predis\Protocol\Text\ProtocolProcessor as TextProtocolProcessor; /**