smi2 / phpClickHouse

src/Cluster.php

<?php

Missing declare(strict_types=1).

namespace ClickHouseDB;

Expected 1 lines before namespace statement, found 0.

use ClickHouseDB\Exception\QueryException;

class Cluster
{
    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$nodes with single line content, use one-line comment instead.

     * @var array

@var annotation of property \ClickHouseDB\Cluster::$nodes does not specify type hint for its items.

     */
    private $nodes = [];


    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$clients with single line content, use one-line comment instead.

     * @var Client[]
     */
    private $clients = [];

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$defaultClient with single line content, use one-line comment instead.

     * @var Client
     */
    private $defaultClient;

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$badNodes with single line content, use one-line comment instead.

     * @var array

@var annotation of property \ClickHouseDB\Cluster::$badNodes does not specify type hint for its items.

     */
    private $badNodes = [];

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$error with single line content, use one-line comment instead.

     * @var array|bool

@var annotation of property \ClickHouseDB\Cluster::$error does not specify type hint for its items.

     */
    private $error = [];
    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$resultScan with single line content, use one-line comment instead.

     * @var array

@var annotation of property \ClickHouseDB\Cluster::$resultScan does not specify type hint for its items.

     */
    private $resultScan = [];
    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$defaultHostName with single line content, use one-line comment instead.

     * @var string
     */
    private $defaultHostName;

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$scanTimeOut with single line content, use one-line comment instead.

     * @var int|float
     */
    private $scanTimeOut = 10;

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$tables with single line content, use one-line comment instead.

     * @var array

@var annotation of property \ClickHouseDB\Cluster::$tables does not specify type hint for its items.

     */
    private $tables = [];

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$hostsnames with single line content, use one-line comment instead.

     * @var array

@var annotation of property \ClickHouseDB\Cluster::$hostsnames does not specify type hint for its items.

     */
    private $hostsnames = [];

Class Cluster contains write-only property $hostsnames.

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$isScaned with single line content, use one-line comment instead.

     * @var bool
     */
    private $isScaned = false;


    /**
     * A symptom of straining CH when checking a cluster request in Zookiper
     * false - send a request to ZK, do not do SELECT * FROM system.replicas
     *
     * @var bool
     */
    private $softCheck = true;

    /**

Found multi-line comment for property \ClickHouseDB\Cluster::$replicasIsOk with single line content, use one-line comment instead.

     * @var bool
     */
    private $replicasIsOk;

Class Cluster contains write-only property $replicasIsOk.

    /**
     * Cache
     *
     * @var array

@var annotation of property \ClickHouseDB\Cluster::$_table_size_cache does not specify type hint for its items.

     */
    private $_table_size_cache = [];

    /**
     * Cluster constructor.

Documentation comment contains forbidden comment "Cluster constructor.".

     *
     * @param array $connect_params

@param annotation of method \ClickHouseDB\Cluster::__construct() does not specify type hint for items of its traversable parameter $connect_params.

     * @param array $settings

@param annotation of method \ClickHouseDB\Cluster::__construct() does not specify type hint for items of its traversable parameter $settings.

     */
    public function __construct($connect_params, $settings = [])

Method \ClickHouseDB\Cluster::__construct() does not have native type hint for its parameter $connect_params but it should be possible to add it based on @param annotation "array".

Method \ClickHouseDB\Cluster::__construct() does not have native type hint for its parameter $settings but it should be possible to add it based on @param annotation "array".

    {
        $this->defaultClient = new Client($connect_params, $settings);
        $this->defaultHostName = $this->defaultClient->getConnectHost();
        $this->setNodes(gethostbynamel($this->defaultHostName));

Function gethostbynamel() should not be referenced via a fallback global name, but via a use statement.

    }

    /**
     * @return Client
     */
    private function defaultClient()

Method \ClickHouseDB\Cluster::defaultClient() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "Client".

    {
        return $this->defaultClient;
    }

    /**
     * @param bool $softCheck
     */
    public function setSoftCheck($softCheck)

Method \ClickHouseDB\Cluster::setSoftCheck() does not have native type hint for its parameter $softCheck but it should be possible to add it based on @param annotation "bool".

Method \ClickHouseDB\Cluster::setSoftCheck() does not have void return type hint.

    {
        $this->softCheck = $softCheck;
    }

    /**
     * @param float|integer $scanTimeOut

Expected "int" but found "integer" in @param annotation.

     */
    public function setScanTimeOut($scanTimeOut)

Method \ClickHouseDB\Cluster::setScanTimeOut() does not have void return type hint.

    {
        $this->scanTimeOut = $scanTimeOut;
    }

    /**
     * @param array $nodes

@param annotation of method \ClickHouseDB\Cluster::setNodes() does not specify type hint for items of its traversable parameter $nodes.

     */
    public function setNodes($nodes)

Method \ClickHouseDB\Cluster::setNodes() does not have native type hint for its parameter $nodes but it should be possible to add it based on @param annotation "array".

Method \ClickHouseDB\Cluster::setNodes() does not have void return type hint.

    {
        $this->nodes = $nodes;
    }

    /**
     * @return array

@return annotation of method \ClickHouseDB\Cluster::getNodes() does not specify type hint for items of its traversable return value.

     */
    public function getNodes()

Method \ClickHouseDB\Cluster::getNodes() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        return $this->nodes;
    }

    /**
     * @return array

@return annotation of method \ClickHouseDB\Cluster::getBadNodes() does not specify type hint for items of its traversable return value.

     */
    public function getBadNodes()

Method \ClickHouseDB\Cluster::getBadNodes() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        return $this->badNodes;
    }


    /**
     * Connect all nodes and scan
     *
     * @return $this

Incorrect annotations group.

     * @throws Exception\TransportException
     */
    public function connect()
    {
        if (!$this->isScaned) {

Expected 1 lines after "if", found 0.

            $this->rescan();
        }
        return $this;

Expected 1 lines before "return", found 0.

    }

    /**
     * Check the status of the cluster, the request is taken from the documentation for CH
     * total_replicas <2 - not suitable for no replication clusters
     *
     *
     * @param mixed $replicas

Expected 1 lines between description and annotations, found 2.

Incorrect annotations group.

     * @return bool
     */
    private function isReplicasWork($replicas)

Method \ClickHouseDB\Cluster::isReplicasWork() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "bool".

    {
        $ok = true;
        if (!is_array($replicas)) {

Function is_array() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

            // @todo нет массива ошибка, т/к мы работем с репликами?
            // @todo Как быть есть в кластере НЕТ реплик ?
            return false;
        }
        foreach ($replicas as $replica) {

Expected 1 lines after "foreach", found 0.

            if ($replica['is_readonly']) {

Expected 1 lines after "if", found 0.

                $ok = false;
                $this->error[] = 'is_readonly : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if ($replica['is_session_expired']) {

Expected 1 lines after "if", found 0.

                $ok = false;
                $this->error[] = 'is_session_expired : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if ($replica['future_parts'] > 20) {

Expected 1 lines after "if", found 0.

                $ok = false;
                $this->error[] = 'future_parts : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if ($replica['parts_to_check'] > 10) {
                $ok = false;
                $this->error[] = 'parts_to_check : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }

            // @todo : rewrite total_replicas=1 если кластер без реплики , нужно проверять какой класте и сколько в нем реплик
//            if ($replica['total_replicas']<2) {$ok=false;$this->error[]='total_replicas : '.json_encode($replica);}
            if ($this->softCheck)
            {
                if (!$ok) {

Expected 1 lines after "if", found 0.

                    break;
                }
                continue;
            }

            if ($replica['active_replicas'] < $replica['total_replicas']) {

Expected 1 lines after "if", found 0.

                $ok = false;
                $this->error[] = 'active_replicas : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if ($replica['queue_size'] > 20) {

Expected 1 lines after "if", found 0.

                $ok = false;
                $this->error[] = 'queue_size : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if (($replica['log_max_index'] - $replica['log_pointer']) > 10) {

Expected 1 lines after "if", found 0.

Useless parentheses.

                $ok = false;
                $this->error[] = 'log_max_index : ' . json_encode($replica);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            }
            if (!$ok) {
                break;
            }
        }
        return $ok;

Expected 1 lines before "return", found 0.

    }

    private function getSelectSystemReplicas()

Method \ClickHouseDB\Cluster::getSelectSystemReplicas() does not have return type hint nor @return annotation for its return value.

    {
        // If you query all the columns, then the table may work slightly slow, since there are several readings from ZK per line.
        // If you do not query the last 4 columns (log_max_index, log_pointer, total_replicas, active_replicas), then the table works quickly.        if ($this->softCheck)

            return 'SELECT 
            database,table,engine,is_leader,is_readonly,
            is_session_expired,future_parts,parts_to_check,zookeeper_path,replica_name,replica_path,columns_version,
            queue_size,inserts_in_queue,merges_in_queue,queue_oldest_time,inserts_oldest_time,merges_oldest_time			
            FROM system.replicas
        ';
        //        return 'SELECT * FROM system.replicas';
    }

    /**
     * @return $this

Incorrect annotations group.

     * @throws Exception\TransportException
     */
    public function rescan()
    {
        $this->error = [];
        /*
         * 1) Get the IP list
         * 2) To each connect via IP, through activeClient replacing host on ip
         * 3) We get information system.clusters + system.replicas from each machine, overwrite {DnsCache + timeOuts}
         * 4) Determine the necessary machines for the cluster / replica
         * 5) .... ?
         */
        $statementsReplicas = [];
        $statementsClusters = [];
        $result = [];

        $badNodes = [];
        $replicasIsOk = true;

        foreach ($this->nodes as $node) {

Expected 1 lines after "foreach", found 0.

            $this->defaultClient()->setHost($node);




            $statementsReplicas[$node] = $this->defaultClient()->selectAsync($this->getSelectSystemReplicas());
            $statementsClusters[$node] = $this->defaultClient()->selectAsync('SELECT * FROM system.clusters');
            // пересетапим timeout
            $statementsReplicas[$node]->getRequest()->setDnsCache(0)->timeOut($this->scanTimeOut)->connectTimeOut($this->scanTimeOut);
            $statementsClusters[$node]->getRequest()->setDnsCache(0)->timeOut($this->scanTimeOut)->connectTimeOut($this->scanTimeOut);
        }
        $this->defaultClient()->executeAsync();
        $tables = [];

        foreach ($this->nodes as $node) {


            try {

Expected 1 lines after "try", found 0.

                $r = $statementsReplicas[$node]->rows();
                foreach ($r as $row) {

Expected 1 lines after "foreach", found 0.

                    $tables[$row['database']][$row['table']][$node] = $row;
                }
                $result['replicas'][$node] = $r;
            }catch (\Exception $E) {

Referencing general \Exception; use \Throwable instead.

Class \Exception should not be referenced via a fully qualified name, but via a use statement.

                $result['replicas'][$node] = false;
                $badNodes[$node] = $E->getMessage();
                $this->error[] = 'statementsReplicas:' . $E->getMessage();
            }
            // ---------------------------------------------------------------------------------------------------
            $hosts = [];

            try {

Expected 1 lines after "try", found 0.

                $c = $statementsClusters[$node]->rows();
                $result['clusters'][$node] = $c;
                foreach ($c as $row) {

Expected 0 lines after "foreach", found 1.

                    $hosts[$row['host_address']][$row['port']] = $row['host_name'];
                    $result['cluster.list'][$row['cluster']][$row['host_address']] =
                        [
                            'shard_weight' => $row['shard_weight'],
                            'replica_num' => $row['replica_num'],
                            'shard_num' => $row['shard_num'],
                            'is_local' => $row['is_local']

Multi-line arrays must have a trailing comma after the last element.

                        ];
                }

            }catch (\Exception $E) {

Referencing general \Exception; use \Throwable instead.

Class \Exception should not be referenced via a fully qualified name, but via a use statement.

                $result['clusters'][$node] = false;

                $this->error[] = 'clusters:' . $E->getMessage();
                $badNodes[$node] = $E->getMessage();

            }
            $this->hostsnames = $hosts;
            $this->tables = $tables;
            // ---------------------------------------------------------------------------------------------------
            // Let's check that replication goes well
            $rIsOk = $this->isReplicasWork($result['replicas'][$node]);
            $result['replicasIsOk'][$node] = $rIsOk;
            if (!$rIsOk) {
                $replicasIsOk = false;
            }
            // ---------------------------------------------------------------------------------------------------
        }

        // badNodes = array(6) {  '222.222.222.44' =>  string(13) "HttpCode:0 ; " , '222.222.222.11' =>  string(13) "HttpCode:0 ; "
        $this->badNodes = $badNodes;

        // Restore DNS host name on ch_client
        $this->defaultClient()->setHost($this->defaultHostName);


        $this->isScaned = true;
        $this->replicasIsOk = $replicasIsOk;
        $this->error[] = "Bad replicasIsOk, in " . json_encode($result['replicasIsOk']);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

        // ------------------------------------------------
        // @todo : To specify on fighting falls and at different-sided configurations ...
        if (sizeof($this->badNodes)) {

Function sizeof() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

            $this->error[] = 'Have bad node : ' . json_encode($this->badNodes);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

            $this->replicasIsOk = false;
        }
        if (!sizeof($this->error)) {

Function sizeof() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

            $this->error = false;
        }
        $this->resultScan = $result;
        // @todo  : We connect to everyone in the DNS list, we need to decry that the requests were returned by all the hosts to which we connected
        return $this;

Expected 1 lines before "return", found 0.

    }

    /**
     * @return boolean

Incorrect annotations group.

Expected "bool" but found "boolean" in @return annotation.

     * @throws Exception\TransportException
     */
    public function isReplicasIsOk()

Method \ClickHouseDB\Cluster::isReplicasIsOk() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "boolean".

    {
        return $this->connect()->replicasIsOk;
    }

    /**
     * @param  string $node

Incorrect annotations group.

     * @return Client
     */
    public function client($node)

Method \ClickHouseDB\Cluster::client() does not have native type hint for its parameter $node but it should be possible to add it based on @param annotation "string".

Method \ClickHouseDB\Cluster::client() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "Client".

    {
        // Создаем клиенты под каждый IP
        if (empty($this->clients[$node])) {
            $this->clients[$node] = clone $this->defaultClient();
        }

        $this->clients[$node]->setHost($node);

        return $this->clients[$node];
    }

    /**
     * @return Client

Incorrect annotations group.

     * @throws Exception\TransportException
     */
    public function clientLike($cluster, $ip_addr_like)

Method \ClickHouseDB\Cluster::clientLike() does not have parameter type hint nor @param annotation for its parameter $cluster.

Method \ClickHouseDB\Cluster::clientLike() does not have parameter type hint nor @param annotation for its parameter $ip_addr_like.

Method \ClickHouseDB\Cluster::clientLike() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "Client".

    {
        $nodes_check = $this->nodes;
        $nodes = $this->getClusterNodes($cluster);
        $list_ips_need = explode(';', $ip_addr_like);

Function explode() should not be referenced via a fallback global name, but via a use statement.

        $find = false;
        foreach ($list_ips_need as $like)

Expected 1 lines after "foreach", found 0.

        {
            foreach ($nodes as $node)

Expected 1 lines after "foreach", found 0.

            {

                if (stripos($node, $like) !== false)

Function stripos() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

                {
                    if (in_array($node, $nodes_check))

Function in_array() should not be referenced via a fallback global name, but via a use statement.

Expected 0 lines after "if", found 1.

                    {
                        $find = $node;
                    } else
                    {
                        // node exists on cluster, but not check
                    }

                }
                if ($find) {
                    break;
                }
            }
            if ($find) {
                break;
            }
        }
        if (!$find) {

Expected 1 lines after "if", found 0.

            $find = $nodes[0];
        }
        return $this->client($find);

Expected 1 lines before "return", found 0.

    }
    /**
     * @return Client
     */
    public function activeClient()

Method \ClickHouseDB\Cluster::activeClient() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "Client".

    {
        return $this->client($this->nodes[0]);
    }

    /**
     * @paramstring $cluster

Incorrect annotations group.

     * @return int
     * @throws Exception\TransportException
     */
    public function getClusterCountShard($cluster)

Method \ClickHouseDB\Cluster::getClusterCountShard() does not have parameter type hint nor @param annotation for its parameter $cluster.

Method \ClickHouseDB\Cluster::getClusterCountShard() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "int".

    {
        $table = $this->getClusterInfoTable($cluster);
        $c = [];
        foreach ($table as $row) {

Expected 1 lines after "foreach", found 0.

            $c[$row['shard_num']] = 1;
        }
        return sizeof($c);

Function sizeof() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines before "return", found 0.

    }

    /**
     * @paramstring $cluster

Incorrect annotations group.

     * @return int
     * @throws Exception\TransportException
     */
    public function getClusterCountReplica($cluster)

Method \ClickHouseDB\Cluster::getClusterCountReplica() does not have parameter type hint nor @param annotation for its parameter $cluster.

Method \ClickHouseDB\Cluster::getClusterCountReplica() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "int".

    {
        $table = $this->getClusterInfoTable($cluster);
        $c = [];
        foreach ($table as $row) {

Expected 1 lines after "foreach", found 0.

            $c[$row['replica_num']] = 1;
        }
        return sizeof($c);

Function sizeof() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines before "return", found 0.

    }

    /**
     * @paramstring $cluster

Incorrect annotations group.

     * @return mixed
     * @throws Exception\TransportException
     */
    public function getClusterInfoTable($cluster)

Method \ClickHouseDB\Cluster::getClusterInfoTable() does not have parameter type hint nor @param annotation for its parameter $cluster.

    {
        $this->connect();
        if (empty($this->resultScan['cluster.list'][$cluster])) {

Expected 1 lines after "if", found 0.

            throw new QueryException('Cluster not find:' . $cluster);
        }
        return $this->resultScan['cluster.list'][$cluster];

Expected 1 lines before "return", found 0.

    }

    /**
     * @paramstring $cluster

Incorrect annotations group.

     * @return array

@return annotation of method \ClickHouseDB\Cluster::getClusterNodes() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function getClusterNodes($cluster)

Method \ClickHouseDB\Cluster::getClusterNodes() does not have parameter type hint nor @param annotation for its parameter $cluster.

Method \ClickHouseDB\Cluster::getClusterNodes() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        return array_keys($this->getClusterInfoTable($cluster));

Function array_keys() should not be referenced via a fallback global name, but via a use statement.

    }

    /**
     * @return array

Incorrect annotations group.

@return annotation of method \ClickHouseDB\Cluster::getClusterList() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function getClusterList()

Method \ClickHouseDB\Cluster::getClusterList() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        $this->connect();
        return array_keys($this->resultScan['cluster.list']);

Function array_keys() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines before "return", found 0.

    }

    /**
     * list all tables on all nodes
     *
     * @return array

Incorrect annotations group.

@return annotation of method \ClickHouseDB\Cluster::getTables() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function getTables($resultDetail = false)

Method \ClickHouseDB\Cluster::getTables() does not have parameter type hint nor @param annotation for its parameter $resultDetail.

Method \ClickHouseDB\Cluster::getTables() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        $this->connect();
        $list = [];
        foreach ($this->tables as $db_name=>$tables)

Expected 1 lines after "foreach", found 0.

        {
            foreach ($tables as $table_name=>$nodes)
            {

                if ($resultDetail)
                {
                    $list[$db_name . '.' . $table_name] = $nodes;
                } else
                {
                    $list[$db_name . '.' . $table_name] = array_keys($nodes);

Function array_keys() should not be referenced via a fallback global name, but via a use statement.

                }
            }
        }
        return $list;

Expected 1 lines before "return", found 0.

    }

    /**
     * Table size on cluster
     *
     * @param string $database_table

Incorrect annotations group.

     * @return array|null

@return annotation of method \ClickHouseDB\Cluster::getSizeTable() does not specify type hint for items of its traversable return value.

     *
     * @throws Exception\TransportException
     */
    public function getSizeTable($database_table)

Method \ClickHouseDB\Cluster::getSizeTable() does not have native type hint for its parameter $database_table but it should be possible to add it based on @param annotation "string".

Method \ClickHouseDB\Cluster::getSizeTable() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array|null".

    {
        $nodes = $this->getNodesByTable($database_table);
        // scan need node`s
        foreach ($nodes as $node)
        {
            if (empty($this->_table_size_cache[$node]))

Use early exit to reduce code nesting.

            {
                $this->_table_size_cache[$node] = $this->client($node)->tablesSize(true);
            }
        }

        $sizes = [];
        foreach ($this->_table_size_cache as $node=>$rows)
        {
            foreach ($rows as $row)
            {
                $sizes[$row['database'] . '.' . $row['table']][$node] = $row;
                @$sizes[$row['database'] . '.' . $row['table']]['total']['sizebytes'] += $row['sizebytes'];



            }
        }

        if (empty($sizes[$database_table]))

Expected 1 lines after "if", found 0.

        {
            return null;
        }
        return $sizes[$database_table]['total']['sizebytes'];

Expected 1 lines before "return", found 0.

    }


    /**
     * Truncate on all nodes
     * @deprecated

Expected 1 lines between description and annotations, found 0.

Incorrect annotations group.

     * @param string $database_table
     * @return array

@return annotation of method \ClickHouseDB\Cluster::truncateTable() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function truncateTable($database_table, $timeOut = 2000)

Method \ClickHouseDB\Cluster::truncateTable() does not have native type hint for its parameter $database_table but it should be possible to add it based on @param annotation "string".

Method \ClickHouseDB\Cluster::truncateTable() does not have parameter type hint nor @param annotation for its parameter $timeOut.

Method \ClickHouseDB\Cluster::truncateTable() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        $out = [];
        list($db, $table) = explode('.', $database_table);

list(...) is forbidden, use [...] instead.

Function explode() should not be referenced via a fallback global name, but via a use statement.

        $nodes = $this->getMasterNodeForTable($database_table);
        // scan need node`s
        foreach ($nodes as $node)

Expected 1 lines after "foreach", found 0.

        {
            $def = $this->client($node)->getTimeout();
            $this->client($node)->database($db)->setTimeout($timeOut);
            $out[$node] = $this->client($node)->truncateTable($table);
            $this->client($node)->setTimeout($def);
        }
        return $out;

Expected 1 lines before "return", found 0.

    }

    /**
     * is_leader node
     *
     * @param string $database_table

Incorrect annotations group.

     * @return array

@return annotation of method \ClickHouseDB\Cluster::getMasterNodeForTable() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function getMasterNodeForTable($database_table)

Method \ClickHouseDB\Cluster::getMasterNodeForTable() does not have native type hint for its parameter $database_table but it should be possible to add it based on @param annotation "string".

Method \ClickHouseDB\Cluster::getMasterNodeForTable() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        $list = $this->getTables(true);

        if (empty($list[$database_table])) {

Expected 1 lines after "if", found 2.

            return [];
        }


        $result = [];
        foreach ($list[$database_table] as $node=>$row)

Expected 1 lines after "foreach", found 0.

        {
            if ($row['is_leader']) {

Use early exit to reduce code nesting.

                $result[] = $node;
            }
        }
        return $result;

Expected 1 lines before "return", found 0.

    }
    /**
     * Find nodes by : db_name.table_name
     *
     * @param string $database_table

Incorrect annotations group.

     * @return array

@return annotation of method \ClickHouseDB\Cluster::getNodesByTable() does not specify type hint for items of its traversable return value.

     * @throws Exception\TransportException
     */
    public function getNodesByTable($database_table)

Method \ClickHouseDB\Cluster::getNodesByTable() does not have native type hint for its parameter $database_table but it should be possible to add it based on @param annotation "string".

Method \ClickHouseDB\Cluster::getNodesByTable() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "array".

    {
        $list = $this->getTables();
        if (empty($list[$database_table])) {

Expected 1 lines after "if", found 0.

            throw new QueryException('Not find :' . $database_table);
        }
        return $list[$database_table];

Expected 1 lines before "return", found 0.

    }

    /**
     * Error string
     *
     * @return string|bool
     */
    public function getError()
    {
        if (is_array($this->error)) {

Function is_array() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

            return json_encode($this->error);

Function json_encode() should not be referenced via a fallback global name, but via a use statement.

        }
        return $this->error;

Expected 1 lines before "return", found 0.

    }

}

There must be exactly 0 empty lines before class closing brace.