@@ -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 | } |