@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | */ |
| 125 | 125 | protected function driverConnect() |
| 126 | 126 | { |
| 127 | - $config = isset($this->config[ 'predis' ]) ? $this->config[ 'predis' ] : []; |
|
| 127 | + $config = isset($this->config['predis']) ? $this->config['predis'] : []; |
|
| 128 | 128 | |
| 129 | 129 | $this->instance = new PredisClient(array_merge([ |
| 130 | 130 | 'host' => '127.0.0.1', |
@@ -150,7 +150,7 @@ discard block |
||
| 150 | 150 | $info = $this->instance->info(); |
| 151 | 151 | $size = (isset($info['Memory']['used_memory']) ? $info['Memory']['used_memory'] : 0); |
| 152 | 152 | $version = (isset($info['Server']['redis_version']) ? $info['Server']['redis_version'] : 0); |
| 153 | - $date = (isset($info['Server'][ 'uptime_in_seconds' ]) ? (new \DateTime())->setTimestamp(time() - $info['Server'][ 'uptime_in_seconds' ]) : 'unknown date'); |
|
| 153 | + $date = (isset($info['Server']['uptime_in_seconds']) ? (new \DateTime())->setTimestamp(time() - $info['Server']['uptime_in_seconds']) : 'unknown date'); |
|
| 154 | 154 | |
| 155 | 155 | return (new driverStatistic()) |
| 156 | 156 | ->setData(implode(', ', array_keys($this->itemInstances))) |
@@ -125,10 +125,10 @@ discard block |
||
| 125 | 125 | $config = isset($this->config[ 'predis' ]) ? $this->config[ 'predis' ] : []; |
| 126 | 126 | |
| 127 | 127 | $this->instance = new PredisClient(array_merge([ |
| 128 | - 'host' => '127.0.0.1', |
|
| 129 | - 'port' => 6379, |
|
| 130 | - 'password' => null, |
|
| 131 | - 'database' => null, |
|
| 128 | + 'host' => '127.0.0.1', |
|
| 129 | + 'port' => 6379, |
|
| 130 | + 'password' => null, |
|
| 131 | + 'database' => null, |
|
| 132 | 132 | ], $config)); |
| 133 | 133 | |
| 134 | 134 | return true; |
@@ -151,9 +151,9 @@ discard block |
||
| 151 | 151 | $date = (isset($info['Server'][ 'uptime_in_seconds' ]) ? (new \DateTime())->setTimestamp(time() - $info['Server'][ 'uptime_in_seconds' ]) : 'unknown date'); |
| 152 | 152 | |
| 153 | 153 | return (new driverStatistic()) |
| 154 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 155 | - ->setRawData($info) |
|
| 156 | - ->setSize($size) |
|
| 157 | - ->setInfo(sprintf("The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.", $version, $date->format(DATE_RFC2822))); |
|
| 154 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 155 | + ->setRawData($info) |
|
| 156 | + ->setSize($size) |
|
| 157 | + ->setInfo(sprintf("The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.", $version, $date->format(DATE_RFC2822))); |
|
| 158 | 158 | } |
| 159 | 159 | } |
| 160 | 160 | \ No newline at end of file |
@@ -63,8 +63,8 @@ |
||
| 63 | 63 | { |
| 64 | 64 | try { |
| 65 | 65 | $cacheItem = $this->internalCacheInstance |
| 66 | - ->getItem($key) |
|
| 67 | - ->set($value); |
|
| 66 | + ->getItem($key) |
|
| 67 | + ->set($value); |
|
| 68 | 68 | if (is_int($ttl) || $ttl instanceof \DateInterval) { |
| 69 | 69 | $cacheItem->expiresAfter($ttl); |
| 70 | 70 | } |
@@ -110,7 +110,7 @@ |
||
| 110 | 110 | public function getMultiple($keys, $default = null) |
| 111 | 111 | { |
| 112 | 112 | try { |
| 113 | - return array_map(function (ExtendedCacheItemInterface $item) { |
|
| 113 | + return array_map(function(ExtendedCacheItemInterface $item) { |
|
| 114 | 114 | return $item->get(); |
| 115 | 115 | }, $this->internalCacheInstance->getItems($keys)); |
| 116 | 116 | } catch (phpFastCacheInvalidArgumentException $e) { |
@@ -237,7 +237,7 @@ discard block |
||
| 237 | 237 | |
| 238 | 238 | /** |
| 239 | 239 | * @param \Psr\Cache\CacheItemInterface $item |
| 240 | - * @return mixed |
|
| 240 | + * @return boolean |
|
| 241 | 241 | * @throws phpFastCacheInvalidArgumentException |
| 242 | 242 | * @throws \RuntimeException |
| 243 | 243 | */ |
@@ -294,7 +294,7 @@ discard block |
||
| 294 | 294 | } |
| 295 | 295 | |
| 296 | 296 | /** |
| 297 | - * @return mixed|null |
|
| 297 | + * @return boolean |
|
| 298 | 298 | * @throws phpFastCacheInvalidArgumentException |
| 299 | 299 | */ |
| 300 | 300 | public function commit() |
@@ -148,9 +148,9 @@ |
||
| 148 | 148 | * Reset the Item |
| 149 | 149 | */ |
| 150 | 150 | $item->set(null) |
| 151 | - ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
| 152 | - ->setHit(false) |
|
| 153 | - ->setTags([]); |
|
| 151 | + ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
| 152 | + ->setHit(false) |
|
| 153 | + ->setTags([]); |
|
| 154 | 154 | if($this->config['itemDetailedDate']){ |
| 155 | 155 | |
| 156 | 156 | /** |
@@ -62,7 +62,7 @@ discard block |
||
| 62 | 62 | public function getItem($key) |
| 63 | 63 | { |
| 64 | 64 | if (is_string($key)) { |
| 65 | - if (preg_match('~([' . preg_quote(self::$unsupportedKeyChars, '~') . ']+)~', $key, $matches)){ |
|
| 65 | + if (preg_match('~([' . preg_quote(self::$unsupportedKeyChars, '~') . ']+)~', $key, $matches)) { |
|
| 66 | 66 | throw new phpFastCacheInvalidArgumentException('Unsupported key character detected: "' . $matches[1] . '". Please check: https://github.com/PHPSocialNetwork/phpfastcache/wiki/%5BV6%5D-Unsupported-characters-in-key-identifiers'); |
| 67 | 67 | } |
| 68 | 68 | if (!array_key_exists($key, $this->itemInstances)) { |
@@ -81,14 +81,14 @@ discard block |
||
| 81 | 81 | $driverArray = $this->driverRead($item); |
| 82 | 82 | |
| 83 | 83 | if ($driverArray) { |
| 84 | - if(!is_array($driverArray)){ |
|
| 84 | + if (!is_array($driverArray)) { |
|
| 85 | 85 | throw new phpFastCacheCoreException(sprintf('The driverRead method returned an unexpected variable type: %s', gettype($driverArray))); |
| 86 | 86 | } |
| 87 | 87 | $driverData = $this->driverUnwrapData($driverArray); |
| 88 | 88 | |
| 89 | - if($this->getConfig()[ 'preventCacheSlams' ]){ |
|
| 90 | - while($driverData instanceof ItemBatch) { |
|
| 91 | - if($driverData->getItemDate()->getTimestamp() + $this->getConfig()[ 'cacheSlamsTimeout' ] < time()){ |
|
| 89 | + if ($this->getConfig()['preventCacheSlams']) { |
|
| 90 | + while ($driverData instanceof ItemBatch) { |
|
| 91 | + if ($driverData->getItemDate()->getTimestamp() + $this->getConfig()['cacheSlamsTimeout'] < time()) { |
|
| 92 | 92 | /** |
| 93 | 93 | * The timeout has been reached |
| 94 | 94 | * Consider that the batch has |
@@ -120,7 +120,7 @@ discard block |
||
| 120 | 120 | $item->set($driverData); |
| 121 | 121 | $item->expiresAt($this->driverUnwrapEdate($driverArray)); |
| 122 | 122 | |
| 123 | - if($this->config['itemDetailedDate']){ |
|
| 123 | + if ($this->config['itemDetailedDate']) { |
|
| 124 | 124 | |
| 125 | 125 | /** |
| 126 | 126 | * If the itemDetailedDate has been |
@@ -148,10 +148,10 @@ discard block |
||
| 148 | 148 | * Reset the Item |
| 149 | 149 | */ |
| 150 | 150 | $item->set(null) |
| 151 | - ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
| 151 | + ->expiresAfter(abs((int) $this->getConfig()['defaultTtl'])) |
|
| 152 | 152 | ->setHit(false) |
| 153 | 153 | ->setTags([]); |
| 154 | - if($this->config['itemDetailedDate']){ |
|
| 154 | + if ($this->config['itemDetailedDate']) { |
|
| 155 | 155 | |
| 156 | 156 | /** |
| 157 | 157 | * If the itemDetailedDate has been |
@@ -164,8 +164,8 @@ discard block |
||
| 164 | 164 | } else { |
| 165 | 165 | $item->setHit(true); |
| 166 | 166 | } |
| 167 | - }else{ |
|
| 168 | - $item->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])); |
|
| 167 | + } else { |
|
| 168 | + $item->expiresAfter(abs((int) $this->getConfig()['defaultTtl'])); |
|
| 169 | 169 | } |
| 170 | 170 | } |
| 171 | 171 | } |
@@ -178,9 +178,9 @@ discard block |
||
| 178 | 178 | * @param $this ExtendedCacheItemPoolInterface |
| 179 | 179 | * @param $this ExtendedCacheItemInterface |
| 180 | 180 | */ |
| 181 | - $this->eventManager->dispatch('CacheGetItem', $this, $this->itemInstances[ $key ]); |
|
| 181 | + $this->eventManager->dispatch('CacheGetItem', $this, $this->itemInstances[$key]); |
|
| 182 | 182 | |
| 183 | - return $this->itemInstances[ $key ]; |
|
| 183 | + return $this->itemInstances[$key]; |
|
| 184 | 184 | } |
| 185 | 185 | |
| 186 | 186 | /** |
@@ -191,7 +191,7 @@ discard block |
||
| 191 | 191 | public function setItem(CacheItemInterface $item) |
| 192 | 192 | { |
| 193 | 193 | if ($this->getClassNamespace() . '\\Item' === get_class($item)) { |
| 194 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
| 194 | + $this->itemInstances[$item->getKey()] = $item; |
|
| 195 | 195 | |
| 196 | 196 | return $this; |
| 197 | 197 | } else { |
@@ -208,7 +208,7 @@ discard block |
||
| 208 | 208 | { |
| 209 | 209 | $collection = []; |
| 210 | 210 | foreach ($keys as $key) { |
| 211 | - $collection[ $key ] = $this->getItem($key); |
|
| 211 | + $collection[$key] = $this->getItem($key); |
|
| 212 | 212 | } |
| 213 | 213 | |
| 214 | 214 | return $collection; |
@@ -305,8 +305,8 @@ discard block |
||
| 305 | 305 | * @var ExtendedCacheItemInterface $item |
| 306 | 306 | */ |
| 307 | 307 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
| 308 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
| 309 | - } else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
| 308 | + $this->itemInstances[$item->getKey()] = $item; |
|
| 309 | + } else if (spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
| 310 | 310 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
| 311 | 311 | } |
| 312 | 312 | |
@@ -318,7 +318,7 @@ discard block |
||
| 318 | 318 | $this->eventManager->dispatch('CacheSaveItem', $this, $item); |
| 319 | 319 | |
| 320 | 320 | |
| 321 | - if($this->getConfig()[ 'preventCacheSlams' ]){ |
|
| 321 | + if ($this->getConfig()['preventCacheSlams']) { |
|
| 322 | 322 | /** |
| 323 | 323 | * @var $itemBatch ExtendedCacheItemInterface |
| 324 | 324 | */ |
@@ -326,7 +326,7 @@ discard block |
||
| 326 | 326 | $itemBatch = $class->newInstanceArgs([$this, $item->getKey()]); |
| 327 | 327 | $itemBatch->setEventManager($this->eventManager) |
| 328 | 328 | ->set(new ItemBatch($item->getKey(), new \DateTime())) |
| 329 | - ->expiresAfter($this->getConfig()[ 'cacheSlamsTimeout' ]); |
|
| 329 | + ->expiresAfter($this->getConfig()['cacheSlamsTimeout']); |
|
| 330 | 330 | |
| 331 | 331 | /** |
| 332 | 332 | * To avoid SPL mismatches |
@@ -358,8 +358,8 @@ discard block |
||
| 358 | 358 | public function saveDeferred(CacheItemInterface $item) |
| 359 | 359 | { |
| 360 | 360 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
| 361 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
| 362 | - }else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
| 361 | + $this->itemInstances[$item->getKey()] = $item; |
|
| 362 | + } else if (spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
| 363 | 363 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
| 364 | 364 | } |
| 365 | 365 | |
@@ -370,7 +370,7 @@ discard block |
||
| 370 | 370 | */ |
| 371 | 371 | $this->eventManager->dispatch('CacheSaveDeferredItem', $this, $item); |
| 372 | 372 | |
| 373 | - return $this->deferredList[ $item->getKey() ] = $item; |
|
| 373 | + return $this->deferredList[$item->getKey()] = $item; |
|
| 374 | 374 | } |
| 375 | 375 | |
| 376 | 376 | /** |
@@ -390,7 +390,7 @@ discard block |
||
| 390 | 390 | foreach ($this->deferredList as $key => $item) { |
| 391 | 391 | $result = $this->save($item); |
| 392 | 392 | if ($return !== false) { |
| 393 | - unset($this->deferredList[ $key ]); |
|
| 393 | + unset($this->deferredList[$key]); |
|
| 394 | 394 | $return = $result; |
| 395 | 395 | } |
| 396 | 396 | } |
@@ -164,7 +164,7 @@ discard block |
||
| 164 | 164 | } else { |
| 165 | 165 | $item->setHit(true); |
| 166 | 166 | } |
| 167 | - }else{ |
|
| 167 | + } else{ |
|
| 168 | 168 | $item->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])); |
| 169 | 169 | } |
| 170 | 170 | } |
@@ -359,7 +359,7 @@ discard block |
||
| 359 | 359 | { |
| 360 | 360 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
| 361 | 361 | $this->itemInstances[ $item->getKey() ] = $item; |
| 362 | - }else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
| 362 | + } else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
| 363 | 363 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
| 364 | 364 | } |
| 365 | 365 | |
@@ -38,6 +38,7 @@ discard block |
||
| 38 | 38 | |
| 39 | 39 | /** |
| 40 | 40 | * @inheritdoc |
| 41 | + * @param string $tagName |
|
| 41 | 42 | */ |
| 42 | 43 | public function getItemsByTag($tagName) |
| 43 | 44 | { |
@@ -408,7 +409,7 @@ discard block |
||
| 408 | 409 | |
| 409 | 410 | /** |
| 410 | 411 | * @internal This method de-register an item from $this->itemInstances |
| 411 | - * @param CacheItemInterface|string $item |
|
| 412 | + * @param CacheItemInterface $item |
|
| 412 | 413 | * @throws phpFastCacheInvalidArgumentException |
| 413 | 414 | */ |
| 414 | 415 | protected function deregisterItem($item) |
@@ -14,7 +14,6 @@ |
||
| 14 | 14 | |
| 15 | 15 | namespace phpFastCache\Core\Pool; |
| 16 | 16 | |
| 17 | -use InvalidArgumentException; |
|
| 18 | 17 | use phpFastCache\Core\Item\ExtendedCacheItemInterface; |
| 19 | 18 | use phpFastCache\EventManager; |
| 20 | 19 | use phpFastCache\Exceptions\phpFastCacheInvalidArgumentException; |
@@ -31,7 +31,7 @@ discard block |
||
| 31 | 31 | */ |
| 32 | 32 | public function getItemsAsJsonString(array $keys = [], $option = 0, $depth = 512) |
| 33 | 33 | { |
| 34 | - $callback = function (CacheItemInterface $item) { |
|
| 34 | + $callback = function(CacheItemInterface $item) { |
|
| 35 | 35 | return $item->get(); |
| 36 | 36 | }; |
| 37 | 37 | return json_encode(array_map($callback, array_values($this->getItems($keys))), $option, $depth); |
@@ -45,7 +45,7 @@ discard block |
||
| 45 | 45 | if (is_string($tagName)) { |
| 46 | 46 | $driverResponse = $this->getItem($this->getTagKey($tagName)); |
| 47 | 47 | if ($driverResponse->isHit()) { |
| 48 | - $items = (array)$driverResponse->get(); |
|
| 48 | + $items = (array) $driverResponse->get(); |
|
| 49 | 49 | |
| 50 | 50 | /** |
| 51 | 51 | * getItems() may provides expired item(s) |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | * |
| 58 | 58 | * #headache |
| 59 | 59 | */ |
| 60 | - return array_filter($this->getItems(array_unique(array_keys($items))), function (ExtendedCacheItemInterface $item) { |
|
| 60 | + return array_filter($this->getItems(array_unique(array_keys($items))), function(ExtendedCacheItemInterface $item) { |
|
| 61 | 61 | return $item->isHit(); |
| 62 | 62 | }); |
| 63 | 63 | } else { |
@@ -75,9 +75,9 @@ discard block |
||
| 75 | 75 | { |
| 76 | 76 | $items = []; |
| 77 | 77 | foreach (array_unique($tagNames) as $tagName) { |
| 78 | - if(is_string($tagName)){ |
|
| 78 | + if (is_string($tagName)) { |
|
| 79 | 79 | $items = array_merge($items, $this->getItemsByTag($tagName)); |
| 80 | - }else{ |
|
| 80 | + } else { |
|
| 81 | 81 | throw new phpFastCacheInvalidArgumentException('$tagName must be a a string'); |
| 82 | 82 | } |
| 83 | 83 | } |
@@ -95,7 +95,7 @@ discard block |
||
| 95 | 95 | |
| 96 | 96 | foreach ($items as $key => $item) { |
| 97 | 97 | if (array_diff($tagNames, $item->getTags())) { |
| 98 | - unset($items[ $key ]); |
|
| 98 | + unset($items[$key]); |
|
| 99 | 99 | } |
| 100 | 100 | } |
| 101 | 101 | |
@@ -108,7 +108,7 @@ discard block |
||
| 108 | 108 | */ |
| 109 | 109 | public function getItemsByTagsAsJsonString(array $tagNames, $option = 0, $depth = 512) |
| 110 | 110 | { |
| 111 | - $callback = function (CacheItemInterface $item) { |
|
| 111 | + $callback = function(CacheItemInterface $item) { |
|
| 112 | 112 | return $item->get(); |
| 113 | 113 | }; |
| 114 | 114 | |
@@ -379,7 +379,7 @@ discard block |
||
| 379 | 379 | */ |
| 380 | 380 | public function detachItem(CacheItemInterface $item) |
| 381 | 381 | { |
| 382 | - if (isset($this->itemInstances[ $item->getKey() ])) { |
|
| 382 | + if (isset($this->itemInstances[$item->getKey()])) { |
|
| 383 | 383 | $this->deregisterItem($item); |
| 384 | 384 | } |
| 385 | 385 | } |
@@ -399,10 +399,10 @@ discard block |
||
| 399 | 399 | */ |
| 400 | 400 | public function attachItem(CacheItemInterface $item) |
| 401 | 401 | { |
| 402 | - if (isset($this->itemInstances[ $item->getKey() ]) && spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])) { |
|
| 402 | + if (isset($this->itemInstances[$item->getKey()]) && spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
| 403 | 403 | throw new phpFastCacheLogicException('The item already exists and cannot be overwritten because the Spl object hash mismatches ! You probably tried to re-attach a detached item which has been already retrieved from cache.'); |
| 404 | 404 | } else { |
| 405 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
| 405 | + $this->itemInstances[$item->getKey()] = $item; |
|
| 406 | 406 | } |
| 407 | 407 | } |
| 408 | 408 | |
@@ -415,10 +415,10 @@ discard block |
||
| 415 | 415 | protected function deregisterItem($item) |
| 416 | 416 | { |
| 417 | 417 | if ($item instanceof CacheItemInterface) { |
| 418 | - unset($this->itemInstances[ $item->getKey() ]); |
|
| 418 | + unset($this->itemInstances[$item->getKey()]); |
|
| 419 | 419 | |
| 420 | 420 | } else if (is_string($item)) { |
| 421 | - unset($this->itemInstances[ $item ]); |
|
| 421 | + unset($this->itemInstances[$item]); |
|
| 422 | 422 | } else { |
| 423 | 423 | throw new phpFastCacheInvalidArgumentException('Invalid type for $item variable'); |
| 424 | 424 | } |
@@ -437,8 +437,8 @@ discard block |
||
| 437 | 437 | */ |
| 438 | 438 | public function isAttached(CacheItemInterface $item) |
| 439 | 439 | { |
| 440 | - if (isset($this->itemInstances[ $item->getKey() ])) { |
|
| 441 | - return spl_object_hash($item) === spl_object_hash($this->itemInstances[ $item->getKey() ]); |
|
| 440 | + if (isset($this->itemInstances[$item->getKey()])) { |
|
| 441 | + return spl_object_hash($item) === spl_object_hash($this->itemInstances[$item->getKey()]); |
|
| 442 | 442 | } |
| 443 | 443 | return null; |
| 444 | 444 | } |
@@ -458,8 +458,8 @@ discard block |
||
| 458 | 458 | */ |
| 459 | 459 | public function saveMultiple(...$items) |
| 460 | 460 | { |
| 461 | - if (isset($items[ 0 ]) && is_array($items[ 0 ])) { |
|
| 462 | - foreach ($items[ 0 ] as $item) { |
|
| 461 | + if (isset($items[0]) && is_array($items[0])) { |
|
| 462 | + foreach ($items[0] as $item) { |
|
| 463 | 463 | $this->save($item); |
| 464 | 464 | } |
| 465 | 465 | return true; |
@@ -77,7 +77,7 @@ |
||
| 77 | 77 | foreach (array_unique($tagNames) as $tagName) { |
| 78 | 78 | if(is_string($tagName)){ |
| 79 | 79 | $items = array_merge($items, $this->getItemsByTag($tagName)); |
| 80 | - }else{ |
|
| 80 | + } else{ |
|
| 81 | 81 | throw new phpFastCacheInvalidArgumentException('$tagName must be a a string'); |
| 82 | 82 | } |
| 83 | 83 | } |
@@ -62,7 +62,7 @@ |
||
| 62 | 62 | |
| 63 | 63 | /** |
| 64 | 64 | * @param \Psr\Cache\CacheItemInterface $item |
| 65 | - * @return mixed |
|
| 65 | + * @return boolean |
|
| 66 | 66 | * @throws phpFastCacheInvalidArgumentException |
| 67 | 67 | */ |
| 68 | 68 | protected function driverWrite(CacheItemInterface $item) |
@@ -75,16 +75,16 @@ discard block |
||
| 75 | 75 | try{ |
| 76 | 76 | $cacheData = $this->encode($this->driverPreWrap($item)); |
| 77 | 77 | $options = new Cassandra\ExecutionOptions([ |
| 78 | - 'arguments' => [ |
|
| 78 | + 'arguments' => [ |
|
| 79 | 79 | 'cache_uuid' => new Cassandra\Uuid(), |
| 80 | 80 | 'cache_id' => $item->getKey(), |
| 81 | 81 | 'cache_data' => $cacheData, |
| 82 | 82 | 'cache_creation_date' => new Cassandra\Timestamp((new \DateTime())->getTimestamp()), |
| 83 | 83 | 'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp()), |
| 84 | 84 | 'cache_length' => strlen($cacheData) |
| 85 | - ], |
|
| 86 | - 'consistency' => Cassandra::CONSISTENCY_ALL, |
|
| 87 | - 'serial_consistency' => Cassandra::CONSISTENCY_SERIAL |
|
| 85 | + ], |
|
| 86 | + 'consistency' => Cassandra::CONSISTENCY_ALL, |
|
| 87 | + 'serial_consistency' => Cassandra::CONSISTENCY_SERIAL |
|
| 88 | 88 | ]); |
| 89 | 89 | |
| 90 | 90 | $query = sprintf('INSERT INTO %s.%s |
@@ -122,13 +122,13 @@ discard block |
||
| 122 | 122 | { |
| 123 | 123 | try { |
| 124 | 124 | $options = new Cassandra\ExecutionOptions([ |
| 125 | - 'arguments' => ['cache_id' => $item->getKey()], |
|
| 126 | - 'page_size' => 1 |
|
| 125 | + 'arguments' => ['cache_id' => $item->getKey()], |
|
| 126 | + 'page_size' => 1 |
|
| 127 | 127 | ]); |
| 128 | 128 | $query = sprintf( |
| 129 | - 'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;', |
|
| 130 | - self::CASSANDRA_KEY_SPACE, |
|
| 131 | - self::CASSANDRA_TABLE |
|
| 129 | + 'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;', |
|
| 130 | + self::CASSANDRA_KEY_SPACE, |
|
| 131 | + self::CASSANDRA_TABLE |
|
| 132 | 132 | ); |
| 133 | 133 | $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options); |
| 134 | 134 | |
@@ -155,14 +155,14 @@ discard block |
||
| 155 | 155 | if ($item instanceof Item) { |
| 156 | 156 | try { |
| 157 | 157 | $options = new Cassandra\ExecutionOptions([ |
| 158 | - 'arguments' => [ |
|
| 158 | + 'arguments' => [ |
|
| 159 | 159 | 'cache_id' => $item->getKey(), |
| 160 | - ], |
|
| 160 | + ], |
|
| 161 | 161 | ]); |
| 162 | 162 | $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
| 163 | - 'DELETE FROM %s.%s WHERE cache_id = :cache_id;', |
|
| 164 | - self::CASSANDRA_KEY_SPACE, |
|
| 165 | - self::CASSANDRA_TABLE |
|
| 163 | + 'DELETE FROM %s.%s WHERE cache_id = :cache_id;', |
|
| 164 | + self::CASSANDRA_KEY_SPACE, |
|
| 165 | + self::CASSANDRA_TABLE |
|
| 166 | 166 | )), $options); |
| 167 | 167 | |
| 168 | 168 | /** |
@@ -186,8 +186,8 @@ discard block |
||
| 186 | 186 | { |
| 187 | 187 | try { |
| 188 | 188 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
| 189 | - 'TRUNCATE %s.%s;', |
|
| 190 | - self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE |
|
| 189 | + 'TRUNCATE %s.%s;', |
|
| 190 | + self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE |
|
| 191 | 191 | ))); |
| 192 | 192 | |
| 193 | 193 | return true; |
@@ -213,8 +213,8 @@ discard block |
||
| 213 | 213 | $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
| 214 | 214 | |
| 215 | 215 | $clusterBuilder = Cassandra::cluster() |
| 216 | - ->withContactPoints($host) |
|
| 217 | - ->withPort($port); |
|
| 216 | + ->withContactPoints($host) |
|
| 217 | + ->withPort($port); |
|
| 218 | 218 | |
| 219 | 219 | if(!empty($this->config['ssl']['enabled'])){ |
| 220 | 220 | if(!empty($this->config['ssl']['verify'])){ |
@@ -242,8 +242,8 @@ discard block |
||
| 242 | 242 | */ |
| 243 | 243 | |
| 244 | 244 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
| 245 | - "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };", |
|
| 246 | - self::CASSANDRA_KEY_SPACE |
|
| 245 | + "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };", |
|
| 246 | + self::CASSANDRA_KEY_SPACE |
|
| 247 | 247 | ))); |
| 248 | 248 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf('USE %s;', self::CASSANDRA_KEY_SPACE))); |
| 249 | 249 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf(' |
@@ -290,15 +290,15 @@ discard block |
||
| 290 | 290 | public function getStats() |
| 291 | 291 | { |
| 292 | 292 | $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
| 293 | - 'SELECT SUM(cache_length) as cache_size FROM %s.%s', |
|
| 294 | - self::CASSANDRA_KEY_SPACE, |
|
| 295 | - self::CASSANDRA_TABLE |
|
| 293 | + 'SELECT SUM(cache_length) as cache_size FROM %s.%s', |
|
| 294 | + self::CASSANDRA_KEY_SPACE, |
|
| 295 | + self::CASSANDRA_TABLE |
|
| 296 | 296 | ))); |
| 297 | 297 | |
| 298 | 298 | return (new driverStatistic()) |
| 299 | - ->setSize($result->first()[ 'cache_size' ]) |
|
| 300 | - ->setRawData([]) |
|
| 301 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 302 | - ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
|
| 299 | + ->setSize($result->first()[ 'cache_size' ]) |
|
| 300 | + ->setRawData([]) |
|
| 301 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 302 | + ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
|
| 303 | 303 | } |
| 304 | 304 | } |
| 305 | 305 | \ No newline at end of file |
@@ -72,7 +72,7 @@ discard block |
||
| 72 | 72 | * Check for Cross-Driver type confusion |
| 73 | 73 | */ |
| 74 | 74 | if ($item instanceof Item) { |
| 75 | - try{ |
|
| 75 | + try { |
|
| 76 | 76 | $cacheData = $this->encode($this->driverPreWrap($item)); |
| 77 | 77 | $options = new Cassandra\ExecutionOptions([ |
| 78 | 78 | 'arguments' => [ |
@@ -106,7 +106,7 @@ discard block |
||
| 106 | 106 | * been really upserted |
| 107 | 107 | */ |
| 108 | 108 | return $result instanceof Cassandra\Rows; |
| 109 | - }catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
| 109 | + } catch (\Cassandra\Exception\InvalidArgumentException $e) { |
|
| 110 | 110 | throw new phpFastCacheInvalidArgumentException($e, 0, $e); |
| 111 | 111 | } |
| 112 | 112 | } else { |
@@ -132,9 +132,9 @@ discard block |
||
| 132 | 132 | ); |
| 133 | 133 | $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options); |
| 134 | 134 | |
| 135 | - if($results instanceof Cassandra\Rows && $results->count() === 1){ |
|
| 135 | + if ($results instanceof Cassandra\Rows && $results->count() === 1) { |
|
| 136 | 136 | return $this->decode($results->first()['cache_data']); |
| 137 | - }else{ |
|
| 137 | + } else { |
|
| 138 | 138 | return null; |
| 139 | 139 | } |
| 140 | 140 | } catch (Cassandra\Exception $e) { |
@@ -206,20 +206,20 @@ discard block |
||
| 206 | 206 | if ($this->instance instanceof CassandraSession) { |
| 207 | 207 | throw new phpFastCacheLogicException('Already connected to Couchbase server'); |
| 208 | 208 | } else { |
| 209 | - $host = isset($this->config[ 'host' ]) ? $this->config[ 'host' ] : '127.0.0.1'; |
|
| 210 | - $port = isset($this->config[ 'port' ]) ? $this->config[ 'port' ] : 9042; |
|
| 211 | - $timeout = isset($this->config[ 'timeout' ]) ? $this->config[ 'timeout' ] : 2; |
|
| 212 | - $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
|
| 213 | - $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
|
| 209 | + $host = isset($this->config['host']) ? $this->config['host'] : '127.0.0.1'; |
|
| 210 | + $port = isset($this->config['port']) ? $this->config['port'] : 9042; |
|
| 211 | + $timeout = isset($this->config['timeout']) ? $this->config['timeout'] : 2; |
|
| 212 | + $password = isset($this->config['password']) ? $this->config['password'] : ''; |
|
| 213 | + $username = isset($this->config['username']) ? $this->config['username'] : ''; |
|
| 214 | 214 | |
| 215 | 215 | $clusterBuilder = Cassandra::cluster() |
| 216 | 216 | ->withContactPoints($host) |
| 217 | 217 | ->withPort($port); |
| 218 | 218 | |
| 219 | - if(!empty($this->config['ssl']['enabled'])){ |
|
| 220 | - if(!empty($this->config['ssl']['verify'])){ |
|
| 219 | + if (!empty($this->config['ssl']['enabled'])) { |
|
| 220 | + if (!empty($this->config['ssl']['verify'])) { |
|
| 221 | 221 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_PEER_CERT); |
| 222 | - }else{ |
|
| 222 | + } else { |
|
| 223 | 223 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_NONE); |
| 224 | 224 | } |
| 225 | 225 | |
@@ -228,7 +228,7 @@ discard block |
||
| 228 | 228 | |
| 229 | 229 | $clusterBuilder->withConnectTimeout($timeout); |
| 230 | 230 | |
| 231 | - if($username){ |
|
| 231 | + if ($username) { |
|
| 232 | 232 | $clusterBuilder->withCredentials($username, $password); |
| 233 | 233 | } |
| 234 | 234 | |
@@ -296,7 +296,7 @@ discard block |
||
| 296 | 296 | ))); |
| 297 | 297 | |
| 298 | 298 | return (new driverStatistic()) |
| 299 | - ->setSize($result->first()[ 'cache_size' ]) |
|
| 299 | + ->setSize($result->first()['cache_size']) |
|
| 300 | 300 | ->setRawData([]) |
| 301 | 301 | ->setData(implode(', ', array_keys($this->itemInstances))) |
| 302 | 302 | ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
@@ -106,7 +106,7 @@ discard block |
||
| 106 | 106 | * been really upserted |
| 107 | 107 | */ |
| 108 | 108 | return $result instanceof Cassandra\Rows; |
| 109 | - }catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
| 109 | + } catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
| 110 | 110 | throw new phpFastCacheInvalidArgumentException($e, 0, $e); |
| 111 | 111 | } |
| 112 | 112 | } else { |
@@ -134,7 +134,7 @@ discard block |
||
| 134 | 134 | |
| 135 | 135 | if($results instanceof Cassandra\Rows && $results->count() === 1){ |
| 136 | 136 | return $this->decode($results->first()['cache_data']); |
| 137 | - }else{ |
|
| 137 | + } else{ |
|
| 138 | 138 | return null; |
| 139 | 139 | } |
| 140 | 140 | } catch (Cassandra\Exception $e) { |
@@ -219,7 +219,7 @@ discard block |
||
| 219 | 219 | if(!empty($this->config['ssl']['enabled'])){ |
| 220 | 220 | if(!empty($this->config['ssl']['verify'])){ |
| 221 | 221 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_PEER_CERT); |
| 222 | - }else{ |
|
| 222 | + } else{ |
|
| 223 | 223 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_NONE); |
| 224 | 224 | } |
| 225 | 225 | |
@@ -60,7 +60,7 @@ discard block |
||
| 60 | 60 | |
| 61 | 61 | /** |
| 62 | 62 | * @param \Psr\Cache\CacheItemInterface $item |
| 63 | - * @return mixed |
|
| 63 | + * @return boolean |
|
| 64 | 64 | * @throws phpFastCacheInvalidArgumentException |
| 65 | 65 | */ |
| 66 | 66 | protected function driverWrite(CacheItemInterface $item) |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | /** |
| 147 | 147 | * @param string $optionName |
| 148 | 148 | * @param mixed $optionValue |
| 149 | - * @return bool |
|
| 149 | + * @return boolean|null |
|
| 150 | 150 | * @throws phpFastCacheInvalidArgumentException |
| 151 | 151 | */ |
| 152 | 152 | public static function isValidOption($optionName, $optionValue) |
@@ -179,7 +179,7 @@ discard block |
||
| 179 | 179 | } |
| 180 | 180 | |
| 181 | 181 | /** |
| 182 | - * @return array |
|
| 182 | + * @return string[] |
|
| 183 | 183 | */ |
| 184 | 184 | public static function getValidOptions() |
| 185 | 185 | { |
@@ -187,7 +187,7 @@ discard block |
||
| 187 | 187 | } |
| 188 | 188 | |
| 189 | 189 | /** |
| 190 | - * @return array |
|
| 190 | + * @return string[] |
|
| 191 | 191 | */ |
| 192 | 192 | public static function getRequiredOptions() |
| 193 | 193 | { |
@@ -69,8 +69,8 @@ discard block |
||
| 69 | 69 | public function dispatch($eventName, ...$args) |
| 70 | 70 | { |
| 71 | 71 | $eventName = 'on' . ucfirst($eventName); |
| 72 | - if(array_key_exists($eventName, $this->events)){ |
|
| 73 | - foreach ($this->events[ $eventName ] as $event) { |
|
| 72 | + if (array_key_exists($eventName, $this->events)) { |
|
| 73 | + foreach ($this->events[$eventName] as $event) { |
|
| 74 | 74 | call_user_func_array($event, $args); |
| 75 | 75 | } |
| 76 | 76 | } |
@@ -84,17 +84,17 @@ discard block |
||
| 84 | 84 | */ |
| 85 | 85 | public function __call($name, $arguments) |
| 86 | 86 | { |
| 87 | - if(strpos($name, 'on') === 0){ |
|
| 88 | - if(is_callable($arguments[0])){ |
|
| 89 | - if(isset($arguments[1]) && is_string($arguments[0])){ |
|
| 87 | + if (strpos($name, 'on') === 0) { |
|
| 88 | + if (is_callable($arguments[0])) { |
|
| 89 | + if (isset($arguments[1]) && is_string($arguments[0])) { |
|
| 90 | 90 | $this->events[$name][$arguments[1]] = $arguments[0]; |
| 91 | - }else { |
|
| 91 | + } else { |
|
| 92 | 92 | $this->events[$name][] = $arguments[0]; |
| 93 | 93 | } |
| 94 | - }else{ |
|
| 94 | + } else { |
|
| 95 | 95 | throw new phpFastCacheInvalidArgumentException(sprintf('Expected Callable, got "%s"', gettype($arguments[0]))); |
| 96 | 96 | } |
| 97 | - }else{ |
|
| 97 | + } else { |
|
| 98 | 98 | throw new \BadMethodCallException('An event must start with "on" such as "onCacheGetItem"'); |
| 99 | 99 | } |
| 100 | 100 | } |
@@ -106,7 +106,7 @@ discard block |
||
| 106 | 106 | */ |
| 107 | 107 | public function unbindEventCallback($eventName, $callbackName) |
| 108 | 108 | { |
| 109 | - if(isset($this->events[$eventName][$callbackName])){ |
|
| 109 | + if (isset($this->events[$eventName][$callbackName])) { |
|
| 110 | 110 | unset($this->events[$eventName][$callbackName]); |
| 111 | 111 | return true; |
| 112 | 112 | } |
@@ -88,13 +88,13 @@ |
||
| 88 | 88 | if(is_callable($arguments[0])){ |
| 89 | 89 | if(isset($arguments[1]) && is_string($arguments[0])){ |
| 90 | 90 | $this->events[$name][$arguments[1]] = $arguments[0]; |
| 91 | - }else { |
|
| 91 | + } else { |
|
| 92 | 92 | $this->events[$name][] = $arguments[0]; |
| 93 | 93 | } |
| 94 | - }else{ |
|
| 94 | + } else{ |
|
| 95 | 95 | throw new phpFastCacheInvalidArgumentException(sprintf('Expected Callable, got "%s"', gettype($arguments[0]))); |
| 96 | 96 | } |
| 97 | - }else{ |
|
| 97 | + } else{ |
|
| 98 | 98 | throw new \BadMethodCallException('An event must start with "on" such as "onCacheGetItem"'); |
| 99 | 99 | } |
| 100 | 100 | } |
@@ -43,7 +43,7 @@ |
||
| 43 | 43 | $this->driver->setItem($this); |
| 44 | 44 | } else { |
| 45 | 45 | throw new phpFastCacheInvalidArgumentException(sprintf('$key must be a string, got type "%s" instead.', |
| 46 | - gettype($key))); |
|
| 46 | + gettype($key))); |
|
| 47 | 47 | } |
| 48 | 48 | } |
| 49 | 49 | |
@@ -142,10 +142,10 @@ discard block |
||
| 142 | 142 | $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
| 143 | 143 | $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
| 144 | 144 | $buckets = isset($this->config[ 'buckets' ]) ? $this->config[ 'buckets' ] : [ |
| 145 | - [ |
|
| 145 | + [ |
|
| 146 | 146 | 'bucket' => 'default', |
| 147 | 147 | 'password' => '', |
| 148 | - ], |
|
| 148 | + ], |
|
| 149 | 149 | ]; |
| 150 | 150 | |
| 151 | 151 | $this->instance = new CouchbaseClient("couchbase://{$host}", $username, $password); |
@@ -195,9 +195,9 @@ discard block |
||
| 195 | 195 | $info = $this->getBucket()->manager()->info(); |
| 196 | 196 | |
| 197 | 197 | return (new driverStatistic()) |
| 198 | - ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
| 199 | - ->setRawData($info) |
|
| 200 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 201 | - ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
| 198 | + ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
| 199 | + ->setRawData($info) |
|
| 200 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
| 201 | + ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
| 202 | 202 | } |
| 203 | 203 | } |
| 204 | 204 | \ No newline at end of file |
@@ -136,10 +136,10 @@ discard block |
||
| 136 | 136 | } else { |
| 137 | 137 | |
| 138 | 138 | |
| 139 | - $host = isset($this->config[ 'host' ]) ? $this->config[ 'host' ] : '127.0.0.1'; |
|
| 140 | - $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
|
| 141 | - $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
|
| 142 | - $buckets = isset($this->config[ 'buckets' ]) ? $this->config[ 'buckets' ] : [ |
|
| 139 | + $host = isset($this->config['host']) ? $this->config['host'] : '127.0.0.1'; |
|
| 140 | + $password = isset($this->config['password']) ? $this->config['password'] : ''; |
|
| 141 | + $username = isset($this->config['username']) ? $this->config['username'] : ''; |
|
| 142 | + $buckets = isset($this->config['buckets']) ? $this->config['buckets'] : [ |
|
| 143 | 143 | [ |
| 144 | 144 | 'bucket' => 'default', |
| 145 | 145 | 'password' => '', |
@@ -149,8 +149,8 @@ discard block |
||
| 149 | 149 | $this->instance = new CouchbaseClient("couchbase://{$host}", $username, $password); |
| 150 | 150 | |
| 151 | 151 | foreach ($buckets as $bucket) { |
| 152 | - $this->bucketCurrent = $this->bucketCurrent ?: $bucket[ 'bucket' ]; |
|
| 153 | - $this->setBucket($bucket[ 'bucket' ], $this->instance->openBucket($bucket[ 'bucket' ], $bucket[ 'password' ])); |
|
| 152 | + $this->bucketCurrent = $this->bucketCurrent ?: $bucket['bucket']; |
|
| 153 | + $this->setBucket($bucket['bucket'], $this->instance->openBucket($bucket['bucket'], $bucket['password'])); |
|
| 154 | 154 | } |
| 155 | 155 | } |
| 156 | 156 | |
@@ -162,7 +162,7 @@ discard block |
||
| 162 | 162 | */ |
| 163 | 163 | protected function getBucket() |
| 164 | 164 | { |
| 165 | - return $this->bucketInstances[ $this->bucketCurrent ]; |
|
| 165 | + return $this->bucketInstances[$this->bucketCurrent]; |
|
| 166 | 166 | } |
| 167 | 167 | |
| 168 | 168 | /** |
@@ -173,7 +173,7 @@ discard block |
||
| 173 | 173 | protected function setBucket($bucketName, \CouchbaseBucket $CouchbaseBucket) |
| 174 | 174 | { |
| 175 | 175 | if (!array_key_exists($bucketName, $this->bucketInstances)) { |
| 176 | - $this->bucketInstances[ $bucketName ] = $CouchbaseBucket; |
|
| 176 | + $this->bucketInstances[$bucketName] = $CouchbaseBucket; |
|
| 177 | 177 | } else { |
| 178 | 178 | throw new phpFastCacheLogicException('A bucket instance with this name already exists.'); |
| 179 | 179 | } |
@@ -193,9 +193,9 @@ discard block |
||
| 193 | 193 | $info = $this->getBucket()->manager()->info(); |
| 194 | 194 | |
| 195 | 195 | return (new driverStatistic()) |
| 196 | - ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
| 196 | + ->setSize($info['basicStats']['diskUsed']) |
|
| 197 | 197 | ->setRawData($info) |
| 198 | 198 | ->setData(implode(', ', array_keys($this->itemInstances))) |
| 199 | - ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
| 199 | + ->setInfo('CouchBase version ' . $info['nodes'][0]['version'] . ', Uptime (in days): ' . round($info['nodes'][0]['uptime'] / 86400, 1) . "\n For more information see RawData."); |
|
| 200 | 200 | } |
| 201 | 201 | } |
| 202 | 202 | \ No newline at end of file |