Selector::outbound() - Code Metrics - carno-php/hrpcc - Measure and Improve Code Quality continuously with Scrutinizer

Selector::outbound() A
last analyzed 2019-07-26 06:23 UTC

↳ Parent: Selector

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
eloc	1
c	1
b	0
f	1
dl	0
loc	3
rs	10
cc	1
nc	1
nop	2

<?php
/**
 * Endpoint selector
 * User: moyo
 * Date: 2018/7/25
 * Time: 11:52 AM
 */

namespace Carno\HRPC\Client;

use Carno\Chain\Layered;
use Carno\Coroutine\Context;
use Carno\RPC\Contracts\Client\Cluster;
use Carno\RPC\Protocol\Request;
use Carno\RPC\Protocol\Response;
use Throwable;

class Selector implements Layered
{
    /**
     * rpc extra key for selected client
     */
    public const CLI = '~v';

    /**
     * @var Cluster
     */
    private $cluster = null;

    /**
     * Selector constructor.
     * @param Cluster $cluster
     */
    public function __construct(Cluster $cluster)
    {
        $this->cluster = $cluster;
    }

    /**
     * @param Request $request
     * @param Context $ctx
     * @return Request
     */
    public function inbound($request, Context $ctx)
    {
        $request->setExtra(self::CLI, $this->cluster->picking($request->server(), ...$request->getTags()));
        return $request;
    }

    /**
     * @param Response $response
     * @param Context $ctx
     * @return Response
     */
    public function outbound($response, Context $ctx)
    {
        return $response;
    }

    /**
     * @param Throwable $e
     * @param Context $ctx
     * @throws Throwable
     */
    public function exception(Throwable $e, Context $ctx)
    {
        throw $e;
    }
}


1			<?php
2			/**
3			* Endpoint selector
4			* User: moyo
5			* Date: 2018/7/25
6			* Time: 11:52 AM
7			*/
8
9			namespace Carno\HRPC\Client;
10
11			use Carno\Chain\Layered;
12			use Carno\Coroutine\Context;
13			use Carno\RPC\Contracts\Client\Cluster;
14			use Carno\RPC\Protocol\Request;
15			use Carno\RPC\Protocol\Response;
16			use Throwable;
17
18			class Selector implements Layered
19			{
20			/**
21			* rpc extra key for selected client
22			*/
23			public const CLI = '~v';
24
25			/**
26			* @var Cluster
27			*/
28			private $cluster = null;
29
30			/**
31			* Selector constructor.
32			* @param Cluster $cluster
33			*/
34			public function __construct(Cluster $cluster)
35			{
36			$this->cluster = $cluster;
37			}
38
39			/**
40			* @param Request $request
41			* @param Context $ctx
42			* @return Request
43			*/
44			public function inbound($request, Context $ctx)
45			{
46			$request->setExtra(self::CLI, $this->cluster->picking($request->server(), ...$request->getTags()));
47			return $request;
48			}
49
50			/**
51			* @param Response $response
52			* @param Context $ctx
53			* @return Response
54			*/
55			public function outbound($response, Context $ctx)
56			{
57			return $response;
58			}
59
60			/**
61			* @param Throwable $e
62			* @param Context $ctx
63			* @throws Throwable
64			*/
65			public function exception(Throwable $e, Context $ctx)
66			{
67			throw $e;
68			}
69			}
70

carno-php / hrpcc

Selector::outbound() A last analyzed 2019-07-26 06:23 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Selector::outbound() A
last analyzed 2019-07-26 06:23 UTC