sentinel; } /** * Set the pool for read commands. * * @return void */ protected function setPool() { $this->pool = $this->replicas; } /** * Connect to the first available Sentinel. * * @return void */ protected function connectToSentinels() { foreach ($this->sentinels as $url => $state) { if ($state === false) { continue; } try { $this->sentinel = $url; if ($state instanceof ClientInterface) { $this->discoverPrimary(); $this->discoverReplicas(); } else { $this->establishConnections($url); } $this->setPool(); return; } catch (Throwable $error) { $this->sentinels[$url] = false; log('warning', $error->getMessage()); } } $lastMessage = isset($error) ? "[{$error->getMessage()}]" : ''; throw new ConnectionException("Unable to connect to any valid sentinels {$lastMessage}", 0, $error ?? null); } /** * Run a command against Redis Sentinel. * * @param string $name * @param array $parameters * @return mixed */ public function command(string $name, array $parameters = []) { $this->lastCommand = null; $isReading = \in_array(\strtoupper($name), $this->readonly); // send `alloptions` read requests to the primary node if ($isReading && \is_string($parameters[0] ?? null)) { $isReading = \strpos($parameters[0], 'options:alloptions') === false; } $node = $isReading && ! empty($this->pool) ? $this->pool[\array_rand($this->pool)] : $this->primary; try { $result = $node->command($name, $parameters); $this->lastCommand = $node->lastCommand; return $result; } catch (Throwable $error) { if ($node === $this->primary) { $this->connectToSentinels(); } $node = $this->primary; } $result = $node->command($name, $parameters); $this->lastCommand = $node->lastCommand; return $result; } }