Predis.php in Redis 8

Namespace

Drupal\redis\Client

File

src/Client/Predis.php

<?php

namespace Drupal\redis\Client;

use Drupal\redis\ClientInterface;
use Predis\Client;

/**
 * Predis client specific implementation.
 */
class Predis implements ClientInterface {
  public function getClient($host = NULL, $port = NULL, $base = NULL, $password = NULL, $replicationHosts = [], $persistent = FALSE) {
    $connectionInfo = [
      'password' => $password,
      'host' => $host,
      'port' => $port,
      'database' => $base,
      'persistent' => $persistent,
    ];
    foreach ($connectionInfo as $key => $value) {
      if (!isset($value)) {
        unset($connectionInfo[$key]);
      }
    }

    // I'm not sure why but the error handler is driven crazy if timezone
    // is not set at this point.
    // Hopefully Drupal will restore the right one this once the current
    // account has logged in.
    date_default_timezone_set(@date_default_timezone_get());

    // If we are passed in an array of $replicationHosts, we should attempt a clustered client connection.
    if (!empty($replicationHosts)) {
      $parameters = [];
      foreach ($replicationHosts as $replicationHost) {
        $param = 'tcp://' . $replicationHost['host'] . ':' . $replicationHost['port'] . '?persistent=' . ($persistent ? 'true' : 'false');

        // Configure master.
        if ($replicationHost['role'] === 'primary') {
          $param .= '&alias=master';
        }
        $parameters[] = $param;
      }
      $options = [
        'replication' => true,
      ];
      $client = new Client($parameters, $options);
    }
    else {
      $client = new Client($connectionInfo);
    }
    return $client;
  }
  public function getName() {
    return 'Predis';
  }

}

Classes

Name	Description
Predis	Predis client specific implementation.