Carno\HRPC\Client\Clustered

Complexity

Total Complexity

6

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	leaving()	0	3	1
A	joining()	0	8	1
A	__construct()	0	4	1
A	tags()	0	3	1
A	picking()	0	6	2

<?php
/**
 * Clustered resources
 * User: moyo
 * Date: 2018/7/25
 * Time: 11:03 AM
 */

namespace Carno\HRPC\Client;

use Carno\Cluster\Classify\Scenes;
use Carno\Cluster\Resources;
use Carno\HRPC\Client\Chips\Modifier;
use Carno\HRPC\Client\Chips\Options;
use Carno\HRPC\Client\Exception\EndpointsNotFoundException;
use Carno\HTTP\Client;
use Carno\RPC\Contracts\Client\Cluster;

class Clustered implements Cluster
{
    use Options;
    use Modifier;

    /**
     * @var Resources
     */
    private $resources = null;

    /**
     * @var Endpoints[]
     */
    private $targets = [];

    /**
     * @var array
     */
    private $tags = [];

    /**
     * Clustered constructor.
     * @param Resources $resources
     * @param string ...$tags
     */
    public function __construct(Resources $resources, string ...$tags)
    {
        $this->resources = $resources;
        $this->tags = $tags;
    }

    /**
     * @return string[]
     */
    public function tags() : array
    {
        return $this->tags;
    }

    /**
     * @param string $server
     */
    public function joining(string $server) : void
    {
        $cluster =
            $this->targets[$server] ??
            $this->targets[$server] = $this->modifying(new Endpoints($server, $this->tags(), $this->options($server)))
        ;

        $this->resources->initialize(Scenes::SERVICE, '', $server, $cluster);
    }

    /**
     * @param string $server
     */
    public function leaving(string $server) : void
    {
        $this->resources->forget('', $server);
    }

    /**
     * @param string $server
     * @param string ...$tags
     * @return Client
     */
    public function picking(string $server, string ...$tags) : object
    {
        if (is_null($endpoints = $this->targets[$server] ?? null)) {
            throw new EndpointsNotFoundException();
        } else {
            return $endpoints->select(...$tags);
        }
    }
}