Class yii\redis\Cache

                protected function addValue($key, $value, $expire)
{
    if ($expire == 0) {
        return (bool) $this->redis->executeCommand('SET', [$key, $value, 'NX']);
    }
    $expire = (int) ($expire * 1000);
    return (bool) $this->redis->executeCommand('SET', [$key, $value, 'PX', $expire, 'NX']);
}

            

                public function buildKey($key)
{
    if (
        is_string($key)
        && $this->isCluster
        && preg_match('/^(.*)({.+})(.*)$/', $key, $matches) === 1) {
        $this->_hashTagAvailable = true;
        return parent::buildKey($matches[1] . $matches[3]) . $matches[2];
    }
    return parent::buildKey($key);
}

            

                protected function deleteValue($key)
{
    return (bool) $this->redis->executeCommand('DEL', [$key]);
}

            

                public function exists($key)
{
    return (bool) $this->redis->executeCommand('EXISTS', [$this->buildKey($key)]);
}

            

                protected function flushValues()
{
    if ($this->shareDatabase) {
        $cursor = 0;
        do {
            list($cursor, $keys) = $this->redis->scan($cursor, 'MATCH', $this->keyPrefix . '*');
            $cursor = (int) $cursor;
            if (!empty($keys)) {
                $this->redis->executeCommand('DEL', $keys);
            }
        } while ($cursor !== 0);
        return true;
    }
    return $this->redis->executeCommand('FLUSHDB');
}

            

                public function getIsCluster()
{
    if ($this->forceClusterMode !== null) {
        return $this->forceClusterMode;
    }
    if ($this->_isCluster === null) {
        $this->_isCluster = false;
        try {
            $this->redis->executeCommand('CLUSTER INFO');
            $this->_isCluster = true;
        } catch (Exception $exception) {
            // if redis is running without cluster support, this command results in:
            // `ERR This instance has cluster support disabled`
            // and [[Connection::executeCommand]] throws an exception
            // we want to ignore it
        }
    }
    return $this->_isCluster;
}

            

                protected function getReplica()
{
    if ($this->enableReplicas === false) {
        return $this->redis;
    }
    if ($this->_replica !== null) {
        return $this->_replica;
    }
    if (empty($this->replicas)) {
        return $this->_replica = $this->redis;
    }
    $replicas = $this->replicas;
    shuffle($replicas);
    $config = array_shift($replicas);
    $this->_replica = Instance::ensure($config, Connection::className());
    return $this->_replica;
}

            

                protected function getValue($key)
{
    $value = $this->getReplica()->executeCommand('GET', [$key]);
    if ($value === null) {
        return false; // Key is not in the cache or expired
    }
    return $value;
}

            

                protected function getValues($keys)
{
    if ($this->isCluster && !$this->_hashTagAvailable) {
        return parent::getValues($keys);
    }
    $response = $this->getReplica()->executeCommand('MGET', $keys);
    $result = [];
    $i = 0;
    foreach ($keys as $key) {
        $result[$key] = $response[$i++];
    }
    $this->_hashTagAvailable = false;
    return $result;
}

            

                public function init()
{
    parent::init();
    $this->redis = Instance::ensure($this->redis, Connection::className());
}

            

                protected function setValue($key, $value, $expire)
{
    if ($expire == 0) {
        return (bool) $this->redis->executeCommand('SET', [$key, $value]);
    }
    $expire = (int) ($expire * 1000);
    return (bool) $this->redis->executeCommand('SET', [$key, $value, 'PX', $expire]);
}

            

                protected function setValues($data, $expire)
{
    if ($this->isCluster && !$this->_hashTagAvailable) {
        return parent::setValues($data, $expire);
    }
    $args = [];
    foreach ($data as $key => $value) {
        $args[] = $key;
        $args[] = $value;
    }
    $failedKeys = [];
    if ($expire == 0) {
        $this->redis->executeCommand('MSET', $args);
    } else {
        $expire = (int) ($expire * 1000);
        $this->redis->executeCommand('MULTI');
        $this->redis->executeCommand('MSET', $args);
        $index = [];
        foreach ($data as $key => $value) {
            $this->redis->executeCommand('PEXPIRE', [$key, $expire]);
            $index[] = $key;
        }
        $result = $this->redis->executeCommand('EXEC');
        array_shift($result);
        foreach ($result as $i => $r) {
            if ($r != 1) {
                $failedKeys[] = $index[$i];
            }
        }
    }
    $this->_hashTagAvailable = false;
    return $failedKeys;
}