@@ -309,6 +309,9 @@ discard block |
||
| 309 | 309 | return $this; |
| 310 | 310 | } |
| 311 | 311 | |
| 312 | + /** |
|
| 313 | + * @param string $id |
|
| 314 | + */ |
|
| 312 | 315 | public function getUsername($id) |
| 313 | 316 | { |
| 314 | 317 | if (!$this->hasResource($id)) { |
@@ -345,7 +348,7 @@ discard block |
||
| 345 | 348 | /** |
| 346 | 349 | * Get encoder. |
| 347 | 350 | * |
| 348 | - * @param $id |
|
| 351 | + * @param string $id |
|
| 349 | 352 | * |
| 350 | 353 | * @return CouchbaseBucketResource |
| 351 | 354 | */ |
@@ -385,7 +388,7 @@ discard block |
||
| 385 | 388 | /** |
| 386 | 389 | * Get decoder. |
| 387 | 390 | * |
| 388 | - * @param $id |
|
| 391 | + * @param string $id |
|
| 389 | 392 | * |
| 390 | 393 | * @return CouchbaseBucketResource |
| 391 | 394 | */ |
@@ -428,6 +431,9 @@ discard block |
||
| 428 | 431 | return $this; |
| 429 | 432 | } |
| 430 | 433 | |
| 434 | + /** |
|
| 435 | + * @param string $id |
|
| 436 | + */ |
|
| 431 | 437 | public function getBucket($id) |
| 432 | 438 | { |
| 433 | 439 | if (!$this->hasResource($id)) { |
@@ -467,6 +473,9 @@ discard block |
||
| 467 | 473 | return $this; |
| 468 | 474 | } |
| 469 | 475 | |
| 476 | + /** |
|
| 477 | + * @param string $id |
|
| 478 | + */ |
|
| 470 | 479 | public function getPassword($id) |
| 471 | 480 | { |
| 472 | 481 | if (!$this->hasResource($id)) { |
@@ -76,26 +76,26 @@ discard block |
||
| 76 | 76 | if (is_array($server)) { |
| 77 | 77 | // array(<host>[, <port>]) |
| 78 | 78 | if (isset($server[0])) { |
| 79 | - $host = (string) $server[0]; |
|
| 80 | - $port = isset($server[1]) ? (int) $server[1] : $port; |
|
| 79 | + $host = (string)$server[0]; |
|
| 80 | + $port = isset($server[1]) ? (int)$server[1] : $port; |
|
| 81 | 81 | } |
| 82 | 82 | // array('host' => <host>[, 'port' => <port>]) |
| 83 | 83 | if (!isset($server[0]) && isset($server['host'])) { |
| 84 | - $host = (string) $server['host']; |
|
| 85 | - $port = isset($server['port']) ? (int) $server['port'] : $port; |
|
| 84 | + $host = (string)$server['host']; |
|
| 85 | + $port = isset($server['port']) ? (int)$server['port'] : $port; |
|
| 86 | 86 | } |
| 87 | 87 | } else { |
| 88 | 88 | // parse server from URI host{:?port} |
| 89 | 89 | $server = trim($server); |
| 90 | 90 | if (strpos($server, '://') === false) { |
| 91 | - $server = 'couchbase://'.$server; |
|
| 91 | + $server = 'couchbase://' . $server; |
|
| 92 | 92 | } |
| 93 | 93 | $server = parse_url($server); |
| 94 | 94 | if (!$server) { |
| 95 | 95 | throw new Exception\InvalidArgumentException('Invalid server given'); |
| 96 | 96 | } |
| 97 | 97 | $host = $server['host']; |
| 98 | - $port = isset($server['port']) ? (int) $server['port'] : $port; |
|
| 98 | + $port = isset($server['port']) ? (int)$server['port'] : $port; |
|
| 99 | 99 | if (isset($server['query'])) { |
| 100 | 100 | $query = null; |
| 101 | 101 | parse_str($server['query'], $query); |
@@ -140,8 +140,8 @@ discard block |
||
| 140 | 140 | if ($resource instanceof \CouchbaseBucket) { |
| 141 | 141 | return $resource; |
| 142 | 142 | } |
| 143 | - $memc = new CouchbaseClusterResource('couchbase://'.$resource['server'][0]['host'].':'.$resource['server'][0]['port'], (string) $resource['username'], (string) $resource['password']); |
|
| 144 | - $bucket = $memc->openBucket((string) $resource['bucket'], (string) $resource['password']); |
|
| 143 | + $memc = new CouchbaseClusterResource('couchbase://' . $resource['server'][0]['host'] . ':' . $resource['server'][0]['port'], (string)$resource['username'], (string)$resource['password']); |
|
| 144 | + $bucket = $memc->openBucket((string)$resource['bucket'], (string)$resource['password']); |
|
| 145 | 145 | |
| 146 | 146 | $bucket->setTranscoder( |
| 147 | 147 | $resource['encoder'], |
@@ -167,7 +167,7 @@ discard block |
||
| 167 | 167 | */ |
| 168 | 168 | public function setResource($id, $resource) |
| 169 | 169 | { |
| 170 | - $id = (string) $id; |
|
| 170 | + $id = (string)$id; |
|
| 171 | 171 | if (!($resource instanceof CouchbaseBucketResource)) { |
| 172 | 172 | if ($resource instanceof \Traversable) { |
| 173 | 173 | $resource = ArrayUtils::iteratorToArray($resource); |
@@ -495,7 +495,7 @@ discard block |
||
| 495 | 495 | $result = []; |
| 496 | 496 | foreach ($servers as $server) { |
| 497 | 497 | $this->normalizeServer($server); |
| 498 | - $result[$server['host'].':'.$server['port']] = $server; |
|
| 498 | + $result[$server['host'] . ':' . $server['port']] = $server; |
|
| 499 | 499 | } |
| 500 | 500 | $servers = array_values($result); |
| 501 | 501 | } |
@@ -511,8 +511,8 @@ discard block |
||
| 511 | 511 | */ |
| 512 | 512 | protected function compareServers(array $serverA, array $serverB) |
| 513 | 513 | { |
| 514 | - $keyA = $serverA['host'].':'.$serverA['port']; |
|
| 515 | - $keyB = $serverB['host'].':'.$serverB['port']; |
|
| 514 | + $keyA = $serverA['host'] . ':' . $serverA['port']; |
|
| 515 | + $keyB = $serverB['host'] . ':' . $serverB['port']; |
|
| 516 | 516 | if ($keyA === $keyB) { |
| 517 | 517 | return 0; |
| 518 | 518 | } |