Merge pull request #34 from DamImpr/difference_redis_predis

DamImpr · web-flow · commit 16667cfa5a0a · 2026-01-12T14:02:50.000+01:00
redis cache with phpredis or predis
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -18,3 +18,5 @@
 - [2026-01-09] DamImpr: Redis and memcache cache, instance passed in construction [#32](https://github.com/DamImpr/cache-multi-layer/pull/32) 
 
 - [2026-01-09] DamImpr: Instance configuration [#33](https://github.com/DamImpr/cache-multi-layer/pull/33) 
+
+- [2026-01-12] DamImpr: redis cache with phpredis or predis [#34](https://github.com/DamImpr/cache-multi-layer/pull/34) 
diff --git a/src/Enum/CacheEnum.php b/src/Enum/CacheEnum.php
@@ -11,4 +11,5 @@ enum CacheEnum: int
     case APCU = 1;
     case REDIS = 2;
     case MEMCACHE = 3;
+    case PREDIS = 4;
 }
diff --git a/src/Exception/CacheMissingConfigurationException.php b/src/Exception/CacheMissingConfigurationException.php
@@ -12,8 +12,4 @@
  */
 class CacheMissingConfigurationException extends Exception
 {
-    public function __construct(string $message = "", int $code = 0, ?Throwable $previous = null)
-    {
-        parent::__construct($message, $code, $previous);
-    }
 }
diff --git a/src/Service/Cache.php b/src/Service/Cache.php
@@ -117,6 +117,7 @@ public static function factory(CacheEnum $cacheEnum, int $ttl, array $configurat
         return match ($cacheEnum) {
             CacheEnum::APCU => new ApcuCache($ttl, $configuration),
             CacheEnum::REDIS => new RedisCache($ttl, $configuration),
+            CacheEnum::PREDIS => new PRedisCache($ttl, $configuration),
             CacheEnum::MEMCACHE => new MemcacheCache($ttl, $configuration)
         };
     }
diff --git a/src/Service/CacheManagerImplDryMode.php b/src/Service/CacheManagerImplDryMode.php
@@ -12,11 +12,6 @@
  */
 class CacheManagerImplDryMode extends CacheManagerImpl
 {
-    protected function __construct(?CacheConfiguration $cacheConfiguration = null)
-    {
-        parent::__construct($cacheConfiguration);
-    }
-
     #[\Override]
     public function appendCache(Cache $cache): bool
     {
diff --git a/src/Service/MemcacheCache.php b/src/Service/MemcacheCache.php
@@ -172,7 +172,7 @@ protected function __construct(int $ttl, array $configuration = [])
         } else {
             $this->memcache = new Memcache();
             $port = $configuration['port'] ?? 11211;
-            if (array_key_exists('persistent', $configuration)) {
+            if (array_key_exists('persistent', $configuration) && $configuration['persistent']) {
                 $resultConnection = $this->memcache->pconnect($configuration['server_address'], $port);
             } else {
                 $resultConnection = $this->memcache->connect($configuration['server_address'], $port);
@@ -182,6 +182,7 @@ protected function __construct(int $ttl, array $configuration = [])
                 throw new Exception("Connection not found");
             }
         }
+
         $this->compress = array_key_exists('compress', $configuration) && $configuration['compress'];
     }
 
@@ -194,8 +195,11 @@ protected function assertConfig(array $configuration): void
             throw new CacheMissingConfigurationException("instance must be " . Memcache::class . " class");
         }
     }
+
     private readonly Memcache $memcache;
+
     private readonly bool $compress;
+
     private array $mandatoryKeys = [
         'server_address'
     ];
diff --git a/src/Service/PRedisCache.php b/src/Service/PRedisCache.php
@@ -0,0 +1,173 @@
+<?php
+
+namespace CacheMultiLayer\Service;
+
+use CacheMultiLayer\Enum\CacheEnum;
+use CacheMultiLayer\Exception\CacheMissingConfigurationException;
+use CacheMultiLayer\Interface\Cacheable;
+use Override;
+use Predis\Client as PredisClient;
+
+/**
+ *
+ * PREDIS cache implementation
+ * @author Damiano Improta <code@damianoimprota.dev>
+ */
+class PRedisCache extends Cache
+{
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    public function decrement(string $key, ?int $ttl = null): int|false
+    {
+        $value = $this->predisClient->decr($key);
+        if (empty($this->getRemainingTTL($key))) {
+            $this->predisClient->expire($key, $this->getTtlToUse($ttl));
+        }
+
+        return $value;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    public function get(string $key): int|float|string|Cacheable|array|null
+    {
+        $val = $this->predisClient->get($key);
+        if ($val === null) {
+            return null;
+        }
+
+        $valDecoded = json_decode($val, true);
+        return is_array($valDecoded) ? $this->unserializeVal($valDecoded) : $valDecoded;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    public function set(string $key, int|float|string|Cacheable|array $val, ?int $ttl = null): bool
+    {
+        $data = is_array($val) ? $this->serializeValArray($val) : $this->serializeVal($val);
+        return $this->predisClient->setex($key, $this->getTtlToUse($ttl), json_encode($data)) !== null;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[Override]
+    public function increment(string $key, ?int $ttl = null): int|false
+    {
+        $value = $this->predisClient->incr($key);
+        if (empty($this->getRemainingTTL($key))) {
+            $this->predisClient->expire($key, $this->getTtlToUse($ttl));
+        }
+
+        return $value;
+    }
+
+    /**
+     *
+     * {@inheritDoc}
+     */
+    #[Override]
+    public function clear(string $key): bool
+    {
+        return (bool) $this->predisClient->del($key);
+    }
+
+    /**
+     *
+     * {@inheritDoc}
+     */
+    #[Override]
+    public function clearAllCache(): bool
+    {
+        return $this->predisClient->flushall() !== null;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[Override]
+    public function getRemainingTTL(string $key): ?int
+    {
+        $ttl = $this->predisClient->ttl($key);
+        return $ttl !== false ? $ttl : null;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    protected function __construct(int $ttl, array $configuration = [])
+    {
+        parent::__construct($ttl, $configuration);
+        if (array_key_exists('instance', $configuration)) {
+            $this->predisClient = $configuration['instance'];
+        } else {
+            $this->predisClient = new PredisClient([
+                'scheme' => $configuration['tcp'] ?? 'tcp',
+                'host' => $configuration['server_address'],
+                'port' => $configuration['port'] ?? 6379,
+                'password' => $configuration['password'] ?? '',
+                'database' => $configuration['database'] ?? 0,
+                'persistent' => $configuration['persistent'] ?? false,
+                'conn_uid' => $configuration['connection_id'] ?? ''
+            ]);
+        }
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    public function isConnected(): bool
+    {
+        return $this->predisClient->ping() !== null;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    public function getEnum(): CacheEnum
+    {
+        return CacheEnum::PREDIS;
+    }
+
+    /**
+     *
+     * {@InheritDoc}
+     */
+    #[\Override]
+    protected function getMandatoryConfig(): array
+    {
+        return $this->mandatoryKeys;
+    }
+
+    #[\Override]
+    protected function assertConfig(array $configuration): void
+    {
+        if (!array_key_exists('instance', $configuration) || $configuration['instance'] instanceof PredisClient) {
+            parent::assertConfig($configuration);
+        } elseif (array_key_exists('instance', $configuration)) {
+            throw new CacheMissingConfigurationException("instance must be " . PredisClient::class . " class");
+        }
+    }
+
+    private readonly PredisClient $predisClient;
+
+    private array $mandatoryKeys = [
+        'server_address'
+    ];
+}
diff --git a/src/Service/RedisCache.php b/src/Service/RedisCache.php
@@ -6,7 +6,6 @@
 use CacheMultiLayer\Exception\CacheMissingConfigurationException;
 use CacheMultiLayer\Interface\Cacheable;
 use Override;
-use Predis\Client as PredisClient;
 
 /**
  *
@@ -22,9 +21,9 @@ class RedisCache extends Cache
     #[\Override]
     public function decrement(string $key, ?int $ttl = null): int|false
     {
-        $value = $this->predisClient->decr($key);
+        $value = $this->redis->decr($key);
         if (empty($this->getRemainingTTL($key))) {
-            $this->predisClient->expire($key, $this->getTtlToUse($ttl));
+            $this->redis->expire($key, $this->getTtlToUse($ttl));
         }
 
         return $value;
@@ -37,12 +36,12 @@ public function decrement(string $key, ?int $ttl = null): int|false
     #[\Override]
     public function get(string $key): int|float|string|Cacheable|array|null
     {
-        $val = $this->predisClient->get($key);
+        $val = $this->redis->get($key);
         if ($val === null) {
             return null;
         }
 
-        $valDecoded = json_decode($val, true);
+        $valDecoded = json_decode((string) $val, true);
         return is_array($valDecoded) ? $this->unserializeVal($valDecoded) : $valDecoded;
     }
 
@@ -54,7 +53,7 @@ public function get(string $key): int|float|string|Cacheable|array|null
     public function set(string $key, int|float|string|Cacheable|array $val, ?int $ttl = null): bool
     {
         $data = is_array($val) ? $this->serializeValArray($val) : $this->serializeVal($val);
-        return $this->predisClient->setex($key, $this->getTtlToUse($ttl), json_encode($data)) !== null;
+        return $this->redis->setex($key, $this->getTtlToUse($ttl), json_encode($data)) !== null;
     }
 
     /**
@@ -64,9 +63,9 @@ public function set(string $key, int|float|string|Cacheable|array $val, ?int $tt
     #[Override]
     public function increment(string $key, ?int $ttl = null): int|false
     {
-        $value = $this->predisClient->incr($key);
+        $value = $this->redis->incr($key);
         if (empty($this->getRemainingTTL($key))) {
-            $this->predisClient->expire($key, $this->getTtlToUse($ttl));
+            $this->redis->expire($key, $this->getTtlToUse($ttl));
         }
 
         return $value;
@@ -79,7 +78,7 @@ public function increment(string $key, ?int $ttl = null): int|false
     #[Override]
     public function clear(string $key): bool
     {
-        return (bool) $this->predisClient->del($key);
+        return (bool) $this->redis->del($key);
     }
 
     /**
@@ -89,7 +88,7 @@ public function clear(string $key): bool
     #[Override]
     public function clearAllCache(): bool
     {
-        return $this->predisClient->flushall() !== null;
+        return $this->redis->flushall() !== null;
     }
 
     /**
@@ -99,7 +98,7 @@ public function clearAllCache(): bool
     #[Override]
     public function getRemainingTTL(string $key): ?int
     {
-        $ttl = $this->predisClient->ttl($key);
+        $ttl = $this->redis->ttl($key);
         return $ttl !== false ? $ttl : null;
     }
 
@@ -111,16 +110,14 @@ protected function __construct(int $ttl, array $configuration = [])
     {
         parent::__construct($ttl, $configuration);
         if (array_key_exists('instance', $configuration)) {
-            $this->predisClient = $configuration['instance'];
+            $this->redis = $configuration['instance'];
         } else {
-            $this->predisClient = new PredisClient([
-                'scheme' => $configuration['tcp'] ?? 'tcp',
-                'host' => $configuration['server_address'],
-                'port' => $configuration['port'] ?? 6379,
-                'password' => $configuration['password'] ?? '',
-                'database' => $configuration['database'] ?? 0,
-                'persistent' => $configuration['persistent'] ?? false
-            ]);
+            $this->redis = new \Redis();
+            if (array_key_exists('persistent', $configuration) && $configuration['persistent']) {
+                $this->redis->connect($configuration['server_address'], $configuration['port'] ?? 6379, $configuration['timeout'] ?? 3, $configuration['connection_id'] ?? 'app_redis_connection');
+            } else {
+                $this->redis->connect($configuration['server_address'], $configuration['port'] ?? 6379, $configuration['timeout'] ?? 3);
+            }
         }
     }
 
@@ -131,7 +128,7 @@ protected function __construct(int $ttl, array $configuration = [])
     #[\Override]
     public function isConnected(): bool
     {
-        return $this->predisClient->ping() !== null;
+        return $this->redis->ping() !== null;
     }
 
     /**
@@ -157,13 +154,15 @@ protected function getMandatoryConfig(): array
     #[\Override]
     protected function assertConfig(array $configuration): void
     {
-        if (!array_key_exists('instance', $configuration) || $configuration['instance'] instanceof PredisClient) {
+        if (!array_key_exists('instance', $configuration) || $configuration['instance'] instanceof \Redis) {
             parent::assertConfig($configuration);
         } elseif (array_key_exists('instance', $configuration)) {
-            throw new CacheMissingConfigurationException("instance must be " . PredisClient::class . " class");
+            throw new CacheMissingConfigurationException("instance must be " . \Redis::class . " class");
         }
     }
-    private readonly PredisClient $predisClient;
+
+    private readonly \Redis $redis;
+
     private array $mandatoryKeys = [
         'server_address'
     ];
diff --git a/tests/PRedisCacheTest.php b/tests/PRedisCacheTest.php
diff --git a/tests/RedisCacheTest.php b/tests/RedisCacheTest.php

Original file line number	Diff line number	Diff line change
`@@ -11,4 +11,5 @@ enum CacheEnum: int`
`11`	`11`	`case APCU = 1;`
`12`	`12`	`case REDIS = 2;`
`13`	`13`	`case MEMCACHE = 3;`
	`14`	`+ case PREDIS = 4;`
`14`	`15`	`}`
Original file line number	Diff line number	Diff line change
`@@ -12,8 +12,4 @@`
`12`	`12`	`*/`
`13`	`13`	`class CacheMissingConfigurationException extends Exception`
`14`	`14`	`{`
`15`		`- public function __construct(string $message = "", int $code = 0, ?Throwable $previous = null)`
`16`		`- {`
`17`		`- parent::__construct($message, $code, $previous);`
`18`		`- }`
`19`	`15`	`}`
Original file line number	Diff line number	Diff line change
`@@ -117,6 +117,7 @@ public static function factory(CacheEnum $cacheEnum, int $ttl, array $configurat`
`117`	`117`	`return match ($cacheEnum) {`
`118`	`118`	`CacheEnum::APCU => new ApcuCache($ttl, $configuration),`
`119`	`119`	`CacheEnum::REDIS => new RedisCache($ttl, $configuration),`
	`120`	`+ CacheEnum::PREDIS => new PRedisCache($ttl, $configuration),`
`120`	`121`	`CacheEnum::MEMCACHE => new MemcacheCache($ttl, $configuration)`
`121`	`122`	`};`
`122`	`123`	`}`
Original file line number	Diff line number	Diff line change
`@@ -12,11 +12,6 @@`
`12`	`12`	`*/`
`13`	`13`	`class CacheManagerImplDryMode extends CacheManagerImpl`
`14`	`14`	`{`
`15`		`- protected function __construct(?CacheConfiguration $cacheConfiguration = null)`
`16`		`- {`
`17`		`- parent::__construct($cacheConfiguration);`
`18`		`- }`
`19`		`-`
`20`	`15`	`#[\Override]`
`21`	`16`	`public function appendCache(Cache $cache): bool`
`22`	`17`	`{`
Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,7 @@ protected function __construct(int $ttl, array $configuration = [])`
`172`	`172`	`} else {`
`173`	`173`	`$this->memcache = new Memcache();`
`174`	`174`	`$port = $configuration['port'] ?? 11211;`
`175`		`- if (array_key_exists('persistent', $configuration)) {`
	`175`	`+ if (array_key_exists('persistent', $configuration) && $configuration['persistent']) {`
`176`	`176`	`$resultConnection = $this->memcache->pconnect($configuration['server_address'], $port);`
`177`	`177`	`} else {`
`178`	`178`	`$resultConnection = $this->memcache->connect($configuration['server_address'], $port);`
`@@ -182,6 +182,7 @@ protected function __construct(int $ttl, array $configuration = [])`
`182`	`182`	`throw new Exception("Connection not found");`
`183`	`183`	`}`
`184`	`184`	`}`
	`185`	`+`
`185`	`186`	`$this->compress = array_key_exists('compress', $configuration) && $configuration['compress'];`
`186`	`187`	`}`
`187`	`188`
`@@ -194,8 +195,11 @@ protected function assertConfig(array $configuration): void`
`194`	`195`	`throw new CacheMissingConfigurationException("instance must be " . Memcache::class . " class");`
`195`	`196`	`}`
`196`	`197`	`}`
	`198`	`+`
`197`	`199`	`private readonly Memcache $memcache;`
	`200`	`+`
`198`	`201`	`private readonly bool $compress;`
	`202`	`+`
`199`	`203`	`private array $mandatoryKeys = [`
`200`	`204`	`'server_address'`
`201`	`205`	`];`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,6 @@`
`6`	`6`	`use CacheMultiLayer\Exception\CacheMissingConfigurationException;`
`7`	`7`	`use CacheMultiLayer\Interface\Cacheable;`
`8`	`8`	`use Override;`
`9`		`-use Predis\Client as PredisClient;`
`10`	`9`
`11`	`10`	`/**`
`12`	`11`	`*`
`@@ -22,9 +21,9 @@ class RedisCache extends Cache`
`22`	`21`	`#[\Override]`
`23`	`22`	`public function decrement(string $key, ?int $ttl = null): int\|false`
`24`	`23`	`{`
`25`		`- $value = $this->predisClient->decr($key);`
	`24`	`+ $value = $this->redis->decr($key);`
`26`	`25`	`if (empty($this->getRemainingTTL($key))) {`
`27`		`- $this->predisClient->expire($key, $this->getTtlToUse($ttl));`
	`26`	`+ $this->redis->expire($key, $this->getTtlToUse($ttl));`
`28`	`27`	`}`
`29`	`28`
`30`	`29`	`return $value;`
`@@ -37,12 +36,12 @@ public function decrement(string $key, ?int $ttl = null): int\|false`
`37`	`36`	`#[\Override]`
`38`	`37`	`public function get(string $key): int\|float\|string\|Cacheable\|array\|null`
`39`	`38`	`{`
`40`		`- $val = $this->predisClient->get($key);`
	`39`	`+ $val = $this->redis->get($key);`
`41`	`40`	`if ($val === null) {`
`42`	`41`	`return null;`
`43`	`42`	`}`
`44`	`43`
`45`		`- $valDecoded = json_decode($val, true);`
	`44`	`+ $valDecoded = json_decode((string) $val, true);`
`46`	`45`	`return is_array($valDecoded) ? $this->unserializeVal($valDecoded) : $valDecoded;`
`47`	`46`	`}`
`48`	`47`
`@@ -54,7 +53,7 @@ public function get(string $key): int\|float\|string\|Cacheable\|array\|null`
`54`	`53`	`public function set(string $key, int\|float\|string\|Cacheable\|array $val, ?int $ttl = null): bool`
`55`	`54`	`{`
`56`	`55`	`$data = is_array($val) ? $this->serializeValArray($val) : $this->serializeVal($val);`
`57`		`- return $this->predisClient->setex($key, $this->getTtlToUse($ttl), json_encode($data)) !== null;`
	`56`	`+ return $this->redis->setex($key, $this->getTtlToUse($ttl), json_encode($data)) !== null;`
`58`	`57`	`}`
`59`	`58`
`60`	`59`	`/**`
`@@ -64,9 +63,9 @@ public function set(string $key, int\|float\|string\|Cacheable\|array $val, ?int $tt`
`64`	`63`	`#[Override]`
`65`	`64`	`public function increment(string $key, ?int $ttl = null): int\|false`
`66`	`65`	`{`
`67`		`- $value = $this->predisClient->incr($key);`
	`66`	`+ $value = $this->redis->incr($key);`
`68`	`67`	`if (empty($this->getRemainingTTL($key))) {`
`69`		`- $this->predisClient->expire($key, $this->getTtlToUse($ttl));`
	`68`	`+ $this->redis->expire($key, $this->getTtlToUse($ttl));`
`70`	`69`	`}`
`71`	`70`
`72`	`71`	`return $value;`
`@@ -79,7 +78,7 @@ public function increment(string $key, ?int $ttl = null): int\|false`
`79`	`78`	`#[Override]`
`80`	`79`	`public function clear(string $key): bool`
`81`	`80`	`{`
`82`		`- return (bool) $this->predisClient->del($key);`
	`81`	`+ return (bool) $this->redis->del($key);`
`83`	`82`	`}`
`84`	`83`
`85`	`84`	`/**`
`@@ -89,7 +88,7 @@ public function clear(string $key): bool`
`89`	`88`	`#[Override]`
`90`	`89`	`public function clearAllCache(): bool`
`91`	`90`	`{`
`92`		`- return $this->predisClient->flushall() !== null;`
	`91`	`+ return $this->redis->flushall() !== null;`
`93`	`92`	`}`
`94`	`93`
`95`	`94`	`/**`
`@@ -99,7 +98,7 @@ public function clearAllCache(): bool`
`99`	`98`	`#[Override]`
`100`	`99`	`public function getRemainingTTL(string $key): ?int`
`101`	`100`	`{`
`102`		`- $ttl = $this->predisClient->ttl($key);`
	`101`	`+ $ttl = $this->redis->ttl($key);`
`103`	`102`	`return $ttl !== false ? $ttl : null;`
`104`	`103`	`}`
`105`	`104`
`@@ -111,16 +110,14 @@ protected function __construct(int $ttl, array $configuration = [])`
`111`	`110`	`{`
`112`	`111`	`parent::__construct($ttl, $configuration);`
`113`	`112`	`if (array_key_exists('instance', $configuration)) {`
`114`		`- $this->predisClient = $configuration['instance'];`
	`113`	`+ $this->redis = $configuration['instance'];`
`115`	`114`	`} else {`
`116`		`- $this->predisClient = new PredisClient([`
`117`		`- 'scheme' => $configuration['tcp'] ?? 'tcp',`
`118`		`- 'host' => $configuration['server_address'],`
`119`		`- 'port' => $configuration['port'] ?? 6379,`
`120`		`- 'password' => $configuration['password'] ?? '',`
`121`		`- 'database' => $configuration['database'] ?? 0,`
`122`		`- 'persistent' => $configuration['persistent'] ?? false`
`123`		`- ]);`
	`115`	`+ $this->redis = new \Redis();`
	`116`	`+ if (array_key_exists('persistent', $configuration) && $configuration['persistent']) {`
	`117`	`+ $this->redis->connect($configuration['server_address'], $configuration['port'] ?? 6379, $configuration['timeout'] ?? 3, $configuration['connection_id'] ?? 'app_redis_connection');`
	`118`	`+ } else {`
	`119`	`+ $this->redis->connect($configuration['server_address'], $configuration['port'] ?? 6379, $configuration['timeout'] ?? 3);`
	`120`	`+ }`
`124`	`121`	`}`
`125`	`122`	`}`
`126`	`123`
`@@ -131,7 +128,7 @@ protected function __construct(int $ttl, array $configuration = [])`
`131`	`128`	`#[\Override]`
`132`	`129`	`public function isConnected(): bool`
`133`	`130`	`{`
`134`		`- return $this->predisClient->ping() !== null;`
	`131`	`+ return $this->redis->ping() !== null;`
`135`	`132`	`}`
`136`	`133`
`137`	`134`	`/**`
`@@ -157,13 +154,15 @@ protected function getMandatoryConfig(): array`
`157`	`154`	`#[\Override]`
`158`	`155`	`protected function assertConfig(array $configuration): void`
`159`	`156`	`{`
`160`		`- if (!array_key_exists('instance', $configuration) \|\| $configuration['instance'] instanceof PredisClient) {`
	`157`	`+ if (!array_key_exists('instance', $configuration) \|\| $configuration['instance'] instanceof \Redis) {`
`161`	`158`	`parent::assertConfig($configuration);`
`162`	`159`	`} elseif (array_key_exists('instance', $configuration)) {`
`163`		`- throw new CacheMissingConfigurationException("instance must be " . PredisClient::class . " class");`
	`160`	`+ throw new CacheMissingConfigurationException("instance must be " . \Redis::class . " class");`
`164`	`161`	`}`
`165`	`162`	`}`
`166`		`- private readonly PredisClient $predisClient;`
	`163`	`+`
	`164`	`+ private readonly \Redis $redis;`
	`165`	`+`
`167`	`166`	`private array $mandatoryKeys = [`
`168`	`167`	`'server_address'`
`169`	`168`	`];`