Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
Total | |
0.00% |
0 / 14 |
|
0.00% |
0 / 75 |
CRAP | |
0.00% |
0 / 1171 |
AppServiceClient | |
0.00% |
0 / 1 |
|
0.00% |
0 / 19 |
4692 | |
0.00% |
0 / 208 |
__construct | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 3 |
|||
save | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_save | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 11 |
|||
recv_save | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
getById | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_getById | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 11 |
|||
recv_getById | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
listAll | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_listAll | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 11 |
|||
recv_listAll | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
removeById | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_removeById | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 11 |
|||
recv_removeById | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
updateById | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_updateById | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 12 |
|||
recv_updateById | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
reindexById | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
send_reindexById | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 11 |
|||
recv_reindexById | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 21 |
|||
AppService_save_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
156 | |
0.00% |
0 / 47 |
__construct | |
0.00% |
0 / 1 |
20 | |
0.00% |
0 / 13 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 23 |
|||
write | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 10 |
|||
AppService_save_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppService_getById_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
156 | |
0.00% |
0 / 47 |
__construct | |
0.00% |
0 / 1 |
20 | |
0.00% |
0 / 13 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 23 |
|||
write | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 10 |
|||
AppService_getById_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppService_listAll_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
182 | |
0.00% |
0 / 51 |
__construct | |
0.00% |
0 / 1 |
20 | |
0.00% |
0 / 14 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 24 |
|||
write | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 12 |
|||
AppService_listAll_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppService_removeById_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
156 | |
0.00% |
0 / 47 |
__construct | |
0.00% |
0 / 1 |
20 | |
0.00% |
0 / 13 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 23 |
|||
write | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 10 |
|||
AppService_removeById_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppService_updateById_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
272 | |
0.00% |
0 / 64 |
__construct | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 19 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
56 | |
0.00% |
0 / 29 |
|||
write | |
0.00% |
0 / 1 |
12 | |
0.00% |
0 / 15 |
|||
AppService_updateById_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppService_reindexById_args | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
156 | |
0.00% |
0 / 47 |
__construct | |
0.00% |
0 / 1 |
20 | |
0.00% |
0 / 13 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 23 |
|||
write | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 10 |
|||
AppService_reindexById_result | |
0.00% |
0 / 1 |
|
0.00% |
0 / 4 |
462 | |
0.00% |
0 / 89 |
__construct | |
0.00% |
0 / 1 |
42 | |
0.00% |
0 / 28 |
|||
getName | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 1 |
|||
read | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 38 |
|||
write | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 22 |
|||
AppServiceProcessor | |
0.00% |
0 / 1 |
|
0.00% |
0 / 8 |
1122 | |
0.00% |
0 / 126 |
__construct | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
process | |
0.00% |
0 / 1 |
6 | |
0.00% |
0 / 16 |
|||
process_save | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
|||
process_getById | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
|||
process_listAll | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
|||
process_removeById | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
|||
process_updateById | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
|||
process_reindexById | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 18 |
<?php | |
namespace OpenSearch\Generated\App; | |
/** | |
* Autogenerated by Thrift Compiler (0.10.0) | |
* | |
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING | |
* @generated | |
*/ | |
use Thrift\Base\TBase; | |
use Thrift\Type\TType; | |
use Thrift\Type\TMessageType; | |
use Thrift\Exception\TException; | |
use Thrift\Exception\TProtocolException; | |
use Thrift\Protocol\TProtocol; | |
use Thrift\Protocol\TBinaryProtocolAccelerated; | |
use Thrift\Exception\TApplicationException; | |
interface AppServiceIf { | |
/** | |
* @param string $app | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function save($app); | |
/** | |
* @param string $identity | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function getById($identity); | |
/** | |
* @param \OpenSearch\Generated\Common\Pageable $pageable | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function listAll(\OpenSearch\Generated\Common\Pageable $pageable); | |
/** | |
* @param string $identity | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function removeById($identity); | |
/** | |
* @param string $identity | |
* @param string $app | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function updateById($identity, $app); | |
/** | |
* @param string $identity | |
* @return \OpenSearch\Generated\Common\OpenSearchResult | |
* @throws \OpenSearch\Generated\Common\OpenSearchException | |
* @throws \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public function reindexById($identity); | |
} | |
class AppServiceClient implements \OpenSearch\Generated\App\AppServiceIf { | |
protected $input_ = null; | |
protected $output_ = null; | |
protected $seqid_ = 0; | |
public function __construct($input, $output=null) { | |
$this->input_ = $input; | |
$this->output_ = $output ? $output : $input; | |
} | |
public function save($app) | |
{ | |
$this->send_save($app); | |
return $this->recv_save(); | |
} | |
public function send_save($app) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_save_args(); | |
$args->app = $app; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'save', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('save', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_save() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_save_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_save_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("save failed: unknown result"); | |
} | |
public function getById($identity) | |
{ | |
$this->send_getById($identity); | |
return $this->recv_getById(); | |
} | |
public function send_getById($identity) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_getById_args(); | |
$args->identity = $identity; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'getById', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('getById', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_getById() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_getById_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_getById_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("getById failed: unknown result"); | |
} | |
public function listAll(\OpenSearch\Generated\Common\Pageable $pageable) | |
{ | |
$this->send_listAll($pageable); | |
return $this->recv_listAll(); | |
} | |
public function send_listAll(\OpenSearch\Generated\Common\Pageable $pageable) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_listAll_args(); | |
$args->pageable = $pageable; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'listAll', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('listAll', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_listAll() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_listAll_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_listAll_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("listAll failed: unknown result"); | |
} | |
public function removeById($identity) | |
{ | |
$this->send_removeById($identity); | |
return $this->recv_removeById(); | |
} | |
public function send_removeById($identity) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_removeById_args(); | |
$args->identity = $identity; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'removeById', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('removeById', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_removeById() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_removeById_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_removeById_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("removeById failed: unknown result"); | |
} | |
public function updateById($identity, $app) | |
{ | |
$this->send_updateById($identity, $app); | |
return $this->recv_updateById(); | |
} | |
public function send_updateById($identity, $app) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_updateById_args(); | |
$args->identity = $identity; | |
$args->app = $app; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'updateById', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('updateById', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_updateById() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_updateById_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_updateById_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("updateById failed: unknown result"); | |
} | |
public function reindexById($identity) | |
{ | |
$this->send_reindexById($identity); | |
return $this->recv_reindexById(); | |
} | |
public function send_reindexById($identity) | |
{ | |
$args = new \OpenSearch\Generated\App\AppService_reindexById_args(); | |
$args->identity = $identity; | |
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($this->output_, 'reindexById', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); | |
} | |
else | |
{ | |
$this->output_->writeMessageBegin('reindexById', TMessageType::CALL, $this->seqid_); | |
$args->write($this->output_); | |
$this->output_->writeMessageEnd(); | |
$this->output_->getTransport()->flush(); | |
} | |
} | |
public function recv_reindexById() | |
{ | |
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); | |
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\App\AppService_reindexById_result', $this->input_->isStrictRead()); | |
else | |
{ | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$this->input_->readMessageBegin($fname, $mtype, $rseqid); | |
if ($mtype == TMessageType::EXCEPTION) { | |
$x = new TApplicationException(); | |
$x->read($this->input_); | |
$this->input_->readMessageEnd(); | |
throw $x; | |
} | |
$result = new \OpenSearch\Generated\App\AppService_reindexById_result(); | |
$result->read($this->input_); | |
$this->input_->readMessageEnd(); | |
} | |
if ($result->success !== null) { | |
return $result->success; | |
} | |
if ($result->error !== null) { | |
throw $result->error; | |
} | |
if ($result->e !== null) { | |
throw $result->e; | |
} | |
throw new \Exception("reindexById failed: unknown result"); | |
} | |
} | |
// HELPER FUNCTIONS AND STRUCTURES | |
class AppService_save_args { | |
static $_TSPEC; | |
/** | |
* @var string | |
*/ | |
public $app = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'app', | |
'type' => TType::STRING, | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['app'])) { | |
$this->app = $vals['app']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_save_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->app); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_save_args'); | |
if ($this->app !== null) { | |
$xfer += $output->writeFieldBegin('app', TType::STRING, 1); | |
$xfer += $output->writeString($this->app); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_save_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_save_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_save_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_getById_args { | |
static $_TSPEC; | |
/** | |
* @var string | |
*/ | |
public $identity = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'identity', | |
'type' => TType::STRING, | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['identity'])) { | |
$this->identity = $vals['identity']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_getById_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->identity); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_getById_args'); | |
if ($this->identity !== null) { | |
$xfer += $output->writeFieldBegin('identity', TType::STRING, 1); | |
$xfer += $output->writeString($this->identity); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_getById_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_getById_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_getById_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_listAll_args { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\Pageable | |
*/ | |
public $pageable = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'pageable', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\Pageable', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['pageable'])) { | |
$this->pageable = $vals['pageable']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_listAll_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->pageable = new \OpenSearch\Generated\Common\Pageable(); | |
$xfer += $this->pageable->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_listAll_args'); | |
if ($this->pageable !== null) { | |
if (!is_object($this->pageable)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('pageable', TType::STRUCT, 1); | |
$xfer += $this->pageable->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_listAll_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_listAll_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_listAll_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_removeById_args { | |
static $_TSPEC; | |
/** | |
* @var string | |
*/ | |
public $identity = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'identity', | |
'type' => TType::STRING, | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['identity'])) { | |
$this->identity = $vals['identity']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_removeById_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->identity); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_removeById_args'); | |
if ($this->identity !== null) { | |
$xfer += $output->writeFieldBegin('identity', TType::STRING, 1); | |
$xfer += $output->writeString($this->identity); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_removeById_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_removeById_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_removeById_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_updateById_args { | |
static $_TSPEC; | |
/** | |
* @var string | |
*/ | |
public $identity = null; | |
/** | |
* @var string | |
*/ | |
public $app = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'identity', | |
'type' => TType::STRING, | |
), | |
2 => array( | |
'var' => 'app', | |
'type' => TType::STRING, | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['identity'])) { | |
$this->identity = $vals['identity']; | |
} | |
if (isset($vals['app'])) { | |
$this->app = $vals['app']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_updateById_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->identity); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->app); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_updateById_args'); | |
if ($this->identity !== null) { | |
$xfer += $output->writeFieldBegin('identity', TType::STRING, 1); | |
$xfer += $output->writeString($this->identity); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->app !== null) { | |
$xfer += $output->writeFieldBegin('app', TType::STRING, 2); | |
$xfer += $output->writeString($this->app); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_updateById_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_updateById_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_updateById_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_reindexById_args { | |
static $_TSPEC; | |
/** | |
* @var string | |
*/ | |
public $identity = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
1 => array( | |
'var' => 'identity', | |
'type' => TType::STRING, | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['identity'])) { | |
$this->identity = $vals['identity']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_reindexById_args'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 1: | |
if ($ftype == TType::STRING) { | |
$xfer += $input->readString($this->identity); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_reindexById_args'); | |
if ($this->identity !== null) { | |
$xfer += $output->writeFieldBegin('identity', TType::STRING, 1); | |
$xfer += $output->writeString($this->identity); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppService_reindexById_result { | |
static $_TSPEC; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchResult | |
*/ | |
public $success = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchException | |
*/ | |
public $error = null; | |
/** | |
* @var \OpenSearch\Generated\Common\OpenSearchClientException | |
*/ | |
public $e = null; | |
public function __construct($vals=null) { | |
if (!isset(self::$_TSPEC)) { | |
self::$_TSPEC = array( | |
0 => array( | |
'var' => 'success', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchResult', | |
), | |
1 => array( | |
'var' => 'error', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchException', | |
), | |
2 => array( | |
'var' => 'e', | |
'type' => TType::STRUCT, | |
'class' => '\OpenSearch\Generated\Common\OpenSearchClientException', | |
), | |
); | |
} | |
if (is_array($vals)) { | |
if (isset($vals['success'])) { | |
$this->success = $vals['success']; | |
} | |
if (isset($vals['error'])) { | |
$this->error = $vals['error']; | |
} | |
if (isset($vals['e'])) { | |
$this->e = $vals['e']; | |
} | |
} | |
} | |
public function getName() { | |
return 'AppService_reindexById_result'; | |
} | |
public function read($input) | |
{ | |
$xfer = 0; | |
$fname = null; | |
$ftype = 0; | |
$fid = 0; | |
$xfer += $input->readStructBegin($fname); | |
while (true) | |
{ | |
$xfer += $input->readFieldBegin($fname, $ftype, $fid); | |
if ($ftype == TType::STOP) { | |
break; | |
} | |
switch ($fid) | |
{ | |
case 0: | |
if ($ftype == TType::STRUCT) { | |
$this->success = new \OpenSearch\Generated\Common\OpenSearchResult(); | |
$xfer += $this->success->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 1: | |
if ($ftype == TType::STRUCT) { | |
$this->error = new \OpenSearch\Generated\Common\OpenSearchException(); | |
$xfer += $this->error->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
case 2: | |
if ($ftype == TType::STRUCT) { | |
$this->e = new \OpenSearch\Generated\Common\OpenSearchClientException(); | |
$xfer += $this->e->read($input); | |
} else { | |
$xfer += $input->skip($ftype); | |
} | |
break; | |
default: | |
$xfer += $input->skip($ftype); | |
break; | |
} | |
$xfer += $input->readFieldEnd(); | |
} | |
$xfer += $input->readStructEnd(); | |
return $xfer; | |
} | |
public function write($output) { | |
$xfer = 0; | |
$xfer += $output->writeStructBegin('AppService_reindexById_result'); | |
if ($this->success !== null) { | |
if (!is_object($this->success)) { | |
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); | |
} | |
$xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); | |
$xfer += $this->success->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->error !== null) { | |
$xfer += $output->writeFieldBegin('error', TType::STRUCT, 1); | |
$xfer += $this->error->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
if ($this->e !== null) { | |
$xfer += $output->writeFieldBegin('e', TType::STRUCT, 2); | |
$xfer += $this->e->write($output); | |
$xfer += $output->writeFieldEnd(); | |
} | |
$xfer += $output->writeFieldStop(); | |
$xfer += $output->writeStructEnd(); | |
return $xfer; | |
} | |
} | |
class AppServiceProcessor { | |
protected $handler_ = null; | |
public function __construct($handler) { | |
$this->handler_ = $handler; | |
} | |
public function process($input, $output) { | |
$rseqid = 0; | |
$fname = null; | |
$mtype = 0; | |
$input->readMessageBegin($fname, $mtype, $rseqid); | |
$methodname = 'process_'.$fname; | |
if (!method_exists($this, $methodname)) { | |
$input->skip(TType::STRUCT); | |
$input->readMessageEnd(); | |
$x = new TApplicationException('Function '.$fname.' not implemented.', TApplicationException::UNKNOWN_METHOD); | |
$output->writeMessageBegin($fname, TMessageType::EXCEPTION, $rseqid); | |
$x->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
return; | |
} | |
$this->$methodname($rseqid, $input, $output); | |
return true; | |
} | |
protected function process_save($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_save_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_save_result(); | |
try { | |
$result->success = $this->handler_->save($args->app); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'save', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('save', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
protected function process_getById($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_getById_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_getById_result(); | |
try { | |
$result->success = $this->handler_->getById($args->identity); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'getById', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('getById', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
protected function process_listAll($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_listAll_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_listAll_result(); | |
try { | |
$result->success = $this->handler_->listAll($args->pageable); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'listAll', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('listAll', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
protected function process_removeById($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_removeById_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_removeById_result(); | |
try { | |
$result->success = $this->handler_->removeById($args->identity); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'removeById', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('removeById', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
protected function process_updateById($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_updateById_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_updateById_result(); | |
try { | |
$result->success = $this->handler_->updateById($args->identity, $args->app); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'updateById', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('updateById', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
protected function process_reindexById($seqid, $input, $output) { | |
$args = new \OpenSearch\Generated\App\AppService_reindexById_args(); | |
$args->read($input); | |
$input->readMessageEnd(); | |
$result = new \OpenSearch\Generated\App\AppService_reindexById_result(); | |
try { | |
$result->success = $this->handler_->reindexById($args->identity); | |
} catch (\OpenSearch\Generated\Common\OpenSearchException $error) { | |
$result->error = $error; | |
} catch (\OpenSearch\Generated\Common\OpenSearchClientException $e) { | |
$result->e = $e; | |
} | |
$bin_accel = ($output instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); | |
if ($bin_accel) | |
{ | |
thrift_protocol_write_binary($output, 'reindexById', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); | |
} | |
else | |
{ | |
$output->writeMessageBegin('reindexById', TMessageType::REPLY, $seqid); | |
$result->write($output); | |
$output->writeMessageEnd(); | |
$output->getTransport()->flush(); | |
} | |
} | |
} | |