Carno\HRPC\Client\Endpoints

Complexity

Total Complexity

5

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	select()	0	3	1
A	connecting()	0	6	2
A	disconnecting()	0	3	1
A	__construct()	0	5	1

<?php
/**
 * Target endpoints
 * User: moyo
 * Date: 30/10/2017
 * Time: 3:12 PM
 */

namespace Carno\HRPC\Client;

use Carno\Cluster\Managed;
use Carno\Container\DI;
use Carno\HRPC\Client\Contracts\Defined;
use Carno\HTTP\Client;
use Carno\HTTP\Options;
use Carno\Net\Endpoint;
use Carno\Promise\Promised;

class Endpoints extends Managed
{
    /**
     * @var bool
     */
    protected $strict = false;

    /**
     * @var string
     */
    protected $type = 'rpc';

    /**
     * @var Options
     */
    private $options = null;

    /**
     * Clustered constructor.
     * @param string $server
     * @param array $tags
     * @param Options $options
     */
    public function __construct(string $server, array $tags, Options $options)
    {
        $this->tags = $tags;
        $this->server = $server;
        $this->options = $options;
    }

    /**
     * @param string ...$tags
     * @return Client
     */
    public function select(string ...$tags)
    {
        return $this->picking(...$tags);
    }

    /**
     * @param Endpoint $endpoint
     * @return Client
     */
    protected function connecting(Endpoint $endpoint)
    {
        if ($hjc = $endpoint->option(Defined::HJ_CLIENT)) {
            return DI::object($hjc, $this->options, $endpoint);
        }
        return new Client($this->options, $endpoint->address());
    }

    /**
     * @param Client $connected
     * @return Promised
     */
    protected function disconnecting($connected) : Promised
    {
        return $connected->close();
    }
}