input_ = $input; $this->output_ = $output ? $output : $input; } public function save(\OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $this->send_save($firstRank); return $this->recv_save(); } public function send_save(\OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_save_args(); $args->firstRank = $firstRank; $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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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() { $this->send_listAll(); return $this->recv_listAll(); } public function send_listAll() { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_listAll_args(); $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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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 listByAppId($appId) { $this->send_listByAppId($appId); return $this->recv_listByAppId(); } public function send_listByAppId($appId) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppId_args(); $args->appId = $appId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'listByAppId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { $this->output_->writeMessageBegin('listByAppId', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } public function recv_listByAppId() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\FirstRank\FirstRankService_listByAppId_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\FirstRank\FirstRankService_listByAppId_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("listByAppId failed: unknown result"); } public function listByAppIdAndName($appId, $name) { $this->send_listByAppIdAndName($appId, $name); return $this->recv_listByAppIdAndName(); } public function send_listByAppIdAndName($appId, $name) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppIdAndName_args(); $args->appId = $appId; $args->name = $name; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'listByAppIdAndName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { $this->output_->writeMessageBegin('listByAppIdAndName', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } public function recv_listByAppIdAndName() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\FirstRank\FirstRankService_listByAppIdAndName_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\FirstRank\FirstRankService_listByAppIdAndName_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("listByAppIdAndName failed: unknown result"); } public function updateById($identity, \OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $this->send_updateById($identity, $firstRank); return $this->recv_updateById(); } public function send_updateById($identity, \OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_updateById_args(); $args->identity = $identity; $args->firstRank = $firstRank; $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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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 validateUpdateById($identity, \OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $this->send_validateUpdateById($identity, $firstRank); return $this->recv_validateUpdateById(); } public function send_validateUpdateById($identity, \OpenSearch\Generated\FirstRank\FirstRank $firstRank) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_validateUpdateById_args(); $args->identity = $identity; $args->firstRank = $firstRank; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'validateUpdateById', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { $this->output_->writeMessageBegin('validateUpdateById', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } public function recv_validateUpdateById() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\OpenSearch\Generated\FirstRank\FirstRankService_validateUpdateById_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\FirstRank\FirstRankService_validateUpdateById_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("validateUpdateById failed: unknown result"); } public function removeById($identity) { $this->send_removeById($identity); return $this->recv_removeById(); } public function send_removeById($identity) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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\FirstRank\FirstRankService_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"); } } // HELPER FUNCTIONS AND STRUCTURES class FirstRankService_save_args { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ public $firstRank = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( 'var' => 'firstRank', 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ); } if (is_array($vals)) { if (isset($vals['firstRank'])) { $this->firstRank = $vals['firstRank']; } } } public function getName() { return 'FirstRankService_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::STRUCT) { $this->firstRank = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $this->firstRank->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('FirstRankService_save_args'); if ($this->firstRank !== null) { if (!is_object($this->firstRank)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('firstRank', TType::STRUCT, 1); $xfer += $this->firstRank->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_save_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ 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\FirstRank\FirstRank', ), 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 'FirstRankService_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\FirstRank\FirstRank(); $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('FirstRankService_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 FirstRankService_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 'FirstRankService_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('FirstRankService_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 FirstRankService_getById_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ 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\FirstRank\FirstRank', ), 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 'FirstRankService_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\FirstRank\FirstRank(); $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('FirstRankService_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 FirstRankService_listAll_args { static $_TSPEC; public function __construct() { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( ); } } public function getName() { return 'FirstRankService_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) { default: $xfer += $input->skip($ftype); break; } $xfer += $input->readFieldEnd(); } $xfer += $input->readStructEnd(); return $xfer; } public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('FirstRankService_listAll_args'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_listAll_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank[] */ 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::LST, 'etype' => TType::STRUCT, 'elem' => array( 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ), 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 'FirstRankService_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::LST) { $this->success = array(); $_size7 = 0; $_etype10 = 0; $xfer += $input->readListBegin($_etype10, $_size7); for ($_i11 = 0; $_i11 < $_size7; ++$_i11) { $elem12 = null; $elem12 = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $elem12->read($input); $this->success []= $elem12; } $xfer += $input->readListEnd(); } 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('FirstRankService_listAll_result'); if ($this->success !== null) { if (!is_array($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('success', TType::LST, 0); { $output->writeListBegin(TType::STRUCT, count($this->success)); { foreach ($this->success as $iter13) { $xfer += $iter13->write($output); } } $output->writeListEnd(); } $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 FirstRankService_listByAppId_args { static $_TSPEC; /** * @var string */ public $appId = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( 'var' => 'appId', 'type' => TType::STRING, ), ); } if (is_array($vals)) { if (isset($vals['appId'])) { $this->appId = $vals['appId']; } } } public function getName() { return 'FirstRankService_listByAppId_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->appId); } 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('FirstRankService_listByAppId_args'); if ($this->appId !== null) { $xfer += $output->writeFieldBegin('appId', TType::STRING, 1); $xfer += $output->writeString($this->appId); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_listByAppId_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank[] */ 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::LST, 'etype' => TType::STRUCT, 'elem' => array( 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ), 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 'FirstRankService_listByAppId_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::LST) { $this->success = array(); $_size14 = 0; $_etype17 = 0; $xfer += $input->readListBegin($_etype17, $_size14); for ($_i18 = 0; $_i18 < $_size14; ++$_i18) { $elem19 = null; $elem19 = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $elem19->read($input); $this->success []= $elem19; } $xfer += $input->readListEnd(); } 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('FirstRankService_listByAppId_result'); if ($this->success !== null) { if (!is_array($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('success', TType::LST, 0); { $output->writeListBegin(TType::STRUCT, count($this->success)); { foreach ($this->success as $iter20) { $xfer += $iter20->write($output); } } $output->writeListEnd(); } $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 FirstRankService_listByAppIdAndName_args { static $_TSPEC; /** * @var string */ public $appId = null; /** * @var string */ public $name = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( 'var' => 'appId', 'type' => TType::STRING, ), 2 => array( 'var' => 'name', 'type' => TType::STRING, ), ); } if (is_array($vals)) { if (isset($vals['appId'])) { $this->appId = $vals['appId']; } if (isset($vals['name'])) { $this->name = $vals['name']; } } } public function getName() { return 'FirstRankService_listByAppIdAndName_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->appId); } else { $xfer += $input->skip($ftype); } break; case 2: if ($ftype == TType::STRING) { $xfer += $input->readString($this->name); } 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('FirstRankService_listByAppIdAndName_args'); if ($this->appId !== null) { $xfer += $output->writeFieldBegin('appId', TType::STRING, 1); $xfer += $output->writeString($this->appId); $xfer += $output->writeFieldEnd(); } if ($this->name !== null) { $xfer += $output->writeFieldBegin('name', TType::STRING, 2); $xfer += $output->writeString($this->name); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_listByAppIdAndName_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank[] */ 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::LST, 'etype' => TType::STRUCT, 'elem' => array( 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ), 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 'FirstRankService_listByAppIdAndName_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::LST) { $this->success = array(); $_size21 = 0; $_etype24 = 0; $xfer += $input->readListBegin($_etype24, $_size21); for ($_i25 = 0; $_i25 < $_size21; ++$_i25) { $elem26 = null; $elem26 = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $elem26->read($input); $this->success []= $elem26; } $xfer += $input->readListEnd(); } 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('FirstRankService_listByAppIdAndName_result'); if ($this->success !== null) { if (!is_array($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('success', TType::LST, 0); { $output->writeListBegin(TType::STRUCT, count($this->success)); { foreach ($this->success as $iter27) { $xfer += $iter27->write($output); } } $output->writeListEnd(); } $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 FirstRankService_updateById_args { static $_TSPEC; /** * @var string */ public $identity = null; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ public $firstRank = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( 'var' => 'identity', 'type' => TType::STRING, ), 2 => array( 'var' => 'firstRank', 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ); } if (is_array($vals)) { if (isset($vals['identity'])) { $this->identity = $vals['identity']; } if (isset($vals['firstRank'])) { $this->firstRank = $vals['firstRank']; } } } public function getName() { return 'FirstRankService_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::STRUCT) { $this->firstRank = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $this->firstRank->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('FirstRankService_updateById_args'); if ($this->identity !== null) { $xfer += $output->writeFieldBegin('identity', TType::STRING, 1); $xfer += $output->writeString($this->identity); $xfer += $output->writeFieldEnd(); } if ($this->firstRank !== null) { if (!is_object($this->firstRank)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('firstRank', TType::STRUCT, 2); $xfer += $this->firstRank->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_updateById_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ 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\FirstRank\FirstRank', ), 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 'FirstRankService_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\FirstRank\FirstRank(); $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('FirstRankService_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 FirstRankService_validateUpdateById_args { static $_TSPEC; /** * @var string */ public $identity = null; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ public $firstRank = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( 'var' => 'identity', 'type' => TType::STRING, ), 2 => array( 'var' => 'firstRank', 'type' => TType::STRUCT, 'class' => '\OpenSearch\Generated\FirstRank\FirstRank', ), ); } if (is_array($vals)) { if (isset($vals['identity'])) { $this->identity = $vals['identity']; } if (isset($vals['firstRank'])) { $this->firstRank = $vals['firstRank']; } } } public function getName() { return 'FirstRankService_validateUpdateById_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::STRUCT) { $this->firstRank = new \OpenSearch\Generated\FirstRank\FirstRank(); $xfer += $this->firstRank->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('FirstRankService_validateUpdateById_args'); if ($this->identity !== null) { $xfer += $output->writeFieldBegin('identity', TType::STRING, 1); $xfer += $output->writeString($this->identity); $xfer += $output->writeFieldEnd(); } if ($this->firstRank !== null) { if (!is_object($this->firstRank)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } $xfer += $output->writeFieldBegin('firstRank', TType::STRUCT, 2); $xfer += $this->firstRank->write($output); $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; } } class FirstRankService_validateUpdateById_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ 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\FirstRank\FirstRank', ), 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 'FirstRankService_validateUpdateById_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\FirstRank\FirstRank(); $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('FirstRankService_validateUpdateById_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 FirstRankService_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 'FirstRankService_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('FirstRankService_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 FirstRankService_removeById_result { static $_TSPEC; /** * @var \OpenSearch\Generated\FirstRank\FirstRank */ 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\FirstRank\FirstRank', ), 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 'FirstRankService_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\FirstRank\FirstRank(); $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('FirstRankService_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 FirstRankServiceProcessor { 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\FirstRank\FirstRankService_save_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_save_result(); try { $result->success = $this->handler_->save($args->firstRank); } 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\FirstRank\FirstRankService_getById_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_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\FirstRank\FirstRankService_listAll_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_listAll_result(); try { $result->success = $this->handler_->listAll(); } 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_listByAppId($seqid, $input, $output) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppId_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppId_result(); try { $result->success = $this->handler_->listByAppId($args->appId); } 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, 'listByAppId', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); } else { $output->writeMessageBegin('listByAppId', TMessageType::REPLY, $seqid); $result->write($output); $output->writeMessageEnd(); $output->getTransport()->flush(); } } protected function process_listByAppIdAndName($seqid, $input, $output) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppIdAndName_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_listByAppIdAndName_result(); try { $result->success = $this->handler_->listByAppIdAndName($args->appId, $args->name); } 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, 'listByAppIdAndName', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); } else { $output->writeMessageBegin('listByAppIdAndName', TMessageType::REPLY, $seqid); $result->write($output); $output->writeMessageEnd(); $output->getTransport()->flush(); } } protected function process_updateById($seqid, $input, $output) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_updateById_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_updateById_result(); try { $result->success = $this->handler_->updateById($args->identity, $args->firstRank); } 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_validateUpdateById($seqid, $input, $output) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_validateUpdateById_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_validateUpdateById_result(); try { $result->success = $this->handler_->validateUpdateById($args->identity, $args->firstRank); } 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, 'validateUpdateById', TMessageType::REPLY, $result, $seqid, $output->isStrictWrite()); } else { $output->writeMessageBegin('validateUpdateById', TMessageType::REPLY, $seqid); $result->write($output); $output->writeMessageEnd(); $output->getTransport()->flush(); } } protected function process_removeById($seqid, $input, $output) { $args = new \OpenSearch\Generated\FirstRank\FirstRankService_removeById_args(); $args->read($input); $input->readMessageEnd(); $result = new \OpenSearch\Generated\FirstRank\FirstRankService_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(); } } }