Files
predis/src/Command/ServerSentinel.php
T
Vadim Borodavko 5004f5d6fc Add PHP 8.1 support (#712)
* Add PHP 8.1 support

* Update AbortedMultiExecException.php

* Update CommunicationException.php

* Update ServerSentinel.php

* Update CursorBasedIterator.php

* Update ReplicationStrategy.php

Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>
2021-09-12 15:07:16 -07:00

70 lines
1.5 KiB
PHP

<?php
/*
* This file is part of the Predis package.
*
* (c) Daniele Alessandri <suppakilla@gmail.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Predis\Command;
/**
* @link http://redis.io/topics/sentinel
*
* @author Daniele Alessandri <suppakilla@gmail.com>
*/
class ServerSentinel extends Command
{
/**
* {@inheritdoc}
*/
public function getId()
{
return 'SENTINEL';
}
/**
* {@inheritdoc}
*/
public function parseResponse($data)
{
$argument = $this->getArgument(0);
$argument = is_null($argument) ? null : strtolower($argument);
switch ($argument) {
case 'masters':
case 'slaves':
return self::processMastersOrSlaves($data);
default:
return $data;
}
}
/**
* Returns a processed response to SENTINEL MASTERS or SENTINEL SLAVES.
*
* @param array $servers List of Redis servers.
*
* @return array
*/
protected static function processMastersOrSlaves(array $servers)
{
foreach ($servers as $idx => $node) {
$processed = array();
$count = count($node);
for ($i = 0; $i < $count; ++$i) {
$processed[$node[$i]] = $node[++$i];
}
$servers[$idx] = $processed;
}
return $servers;
}
}