for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/**
* Request tagging
* User: moyo
* Date: 2018/7/25
* Time: 2:52 PM
*/
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 Tagging implements Layered
{
* @var Cluster
private $cluster = null;
* Tagging 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->hasTags() || $request->setTags(...$this->cluster->tags());
return $request;
* @param Response $response
* @return Response
public function outbound($response, Context $ctx)
return $response;
* @param Throwable $e
* @throws Throwable
public function exception(Throwable $e, Context $ctx)
throw $e;