http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Experiment/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Experiment/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Experiment/Types.php new file mode 100644 index 0000000..8ab0259 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Experiment/Types.php @@ -0,0 +1,1478 @@ +<?php +namespace Airavata\Model\Experiment; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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; + + +final class ExperimentType { + const SINGLE_APPLICATION = 0; + const WORKFLOW = 1; + static public $__names = array( + 0 => 'SINGLE_APPLICATION', + 1 => 'WORKFLOW', + ); +} + +final class ExperimentSearchFields { + const EXPERIMENT_NAME = 0; + const EXPERIMENT_DESC = 1; + const APPLICATION_ID = 2; + const FROM_DATE = 3; + const TO_DATE = 4; + const STATUS = 5; + static public $__names = array( + 0 => 'EXPERIMENT_NAME', + 1 => 'EXPERIMENT_DESC', + 2 => 'APPLICATION_ID', + 3 => 'FROM_DATE', + 4 => 'TO_DATE', + 5 => 'STATUS', + ); +} + +/** + * A structure holding the experiment configuration. + * + * + */ +class UserConfigurationDataModel { + static $_TSPEC; + + /** + * @var bool + */ + public $airavataAutoSchedule = false; + /** + * @var bool + */ + public $overrideManualScheduledParams = false; + /** + * @var bool + */ + public $shareExperimentPublicly = false; + /** + * @var \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel + */ + public $computationalResourceScheduling = null; + /** + * @var bool + */ + public $throttleResources = false; + /** + * @var string + */ + public $userDN = null; + /** + * @var bool + */ + public $generateCert = false; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'airavataAutoSchedule', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'overrideManualScheduledParams', + 'type' => TType::BOOL, + ), + 3 => array( + 'var' => 'shareExperimentPublicly', + 'type' => TType::BOOL, + ), + 4 => array( + 'var' => 'computationalResourceScheduling', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Scheduling\ComputationalResourceSchedulingModel', + ), + 5 => array( + 'var' => 'throttleResources', + 'type' => TType::BOOL, + ), + 6 => array( + 'var' => 'userDN', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'generateCert', + 'type' => TType::BOOL, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['airavataAutoSchedule'])) { + $this->airavataAutoSchedule = $vals['airavataAutoSchedule']; + } + if (isset($vals['overrideManualScheduledParams'])) { + $this->overrideManualScheduledParams = $vals['overrideManualScheduledParams']; + } + if (isset($vals['shareExperimentPublicly'])) { + $this->shareExperimentPublicly = $vals['shareExperimentPublicly']; + } + if (isset($vals['computationalResourceScheduling'])) { + $this->computationalResourceScheduling = $vals['computationalResourceScheduling']; + } + if (isset($vals['throttleResources'])) { + $this->throttleResources = $vals['throttleResources']; + } + if (isset($vals['userDN'])) { + $this->userDN = $vals['userDN']; + } + if (isset($vals['generateCert'])) { + $this->generateCert = $vals['generateCert']; + } + } + } + + public function getName() { + return 'UserConfigurationDataModel'; + } + + 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::BOOL) { + $xfer += $input->readBool($this->airavataAutoSchedule); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->overrideManualScheduledParams); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->shareExperimentPublicly); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRUCT) { + $this->computationalResourceScheduling = new \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel(); + $xfer += $this->computationalResourceScheduling->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->throttleResources); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userDN); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->generateCert); + } 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('UserConfigurationDataModel'); + if ($this->airavataAutoSchedule !== null) { + $xfer += $output->writeFieldBegin('airavataAutoSchedule', TType::BOOL, 1); + $xfer += $output->writeBool($this->airavataAutoSchedule); + $xfer += $output->writeFieldEnd(); + } + if ($this->overrideManualScheduledParams !== null) { + $xfer += $output->writeFieldBegin('overrideManualScheduledParams', TType::BOOL, 2); + $xfer += $output->writeBool($this->overrideManualScheduledParams); + $xfer += $output->writeFieldEnd(); + } + if ($this->shareExperimentPublicly !== null) { + $xfer += $output->writeFieldBegin('shareExperimentPublicly', TType::BOOL, 3); + $xfer += $output->writeBool($this->shareExperimentPublicly); + $xfer += $output->writeFieldEnd(); + } + if ($this->computationalResourceScheduling !== null) { + if (!is_object($this->computationalResourceScheduling)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('computationalResourceScheduling', TType::STRUCT, 4); + $xfer += $this->computationalResourceScheduling->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->throttleResources !== null) { + $xfer += $output->writeFieldBegin('throttleResources', TType::BOOL, 5); + $xfer += $output->writeBool($this->throttleResources); + $xfer += $output->writeFieldEnd(); + } + if ($this->userDN !== null) { + $xfer += $output->writeFieldBegin('userDN', TType::STRING, 6); + $xfer += $output->writeString($this->userDN); + $xfer += $output->writeFieldEnd(); + } + if ($this->generateCert !== null) { + $xfer += $output->writeFieldBegin('generateCert', TType::BOOL, 7); + $xfer += $output->writeBool($this->generateCert); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +/** + * A structure holding the experiment metadata and its child models. + * + * userName: + * The user name of the targeted gateway end user on whose behalf the experiment is being created. + * the associated gateway identity can only be inferred from the security hand-shake so as to avoid + * authorized Airavata Clients mimicking an unauthorized request. If a gateway is not registered with + * Airavata, an authorization exception is thrown. + * + * experimentName: + * The name of the experiment as defined by the user. The name need not be unique as uniqueness is enforced + * by the generated experiment id. + * + * experimentDescription: + * The verbose description of the experiment. This is an optional parameter. + */ +class ExperimentModel { + static $_TSPEC; + + /** + * @var string + */ + public $experimentId = "DO_NOT_SET_AT_CLIENTS"; + /** + * @var string + */ + public $projectId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var int + */ + public $experimentType = 0; + /** + * @var string + */ + public $userName = null; + /** + * @var string + */ + public $experimentName = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var string + */ + public $description = null; + /** + * @var string + */ + public $executionId = null; + /** + * @var string + */ + public $gatewayExecutionId = null; + /** + * @var bool + */ + public $enableEmailNotification = null; + /** + * @var string[] + */ + public $emailAddresses = null; + /** + * @var \Airavata\Model\Experiment\UserConfigurationDataModel + */ + public $userConfigurationData = null; + /** + * @var \Airavata\Model\Application\Io\InputDataObjectType[] + */ + public $experimentInputs = null; + /** + * @var \Airavata\Model\Application\Io\OutputDataObjectType[] + */ + public $experimentOutputs = null; + /** + * @var \Airavata\Model\Status\ExperimentStatus + */ + public $experimentStatus = null; + /** + * @var \Airavata\Model\Commons\ErrorModel[] + */ + public $errors = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'experimentId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'projectId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'experimentType', + 'type' => TType::I32, + ), + 5 => array( + 'var' => 'userName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'experimentName', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 8 => array( + 'var' => 'description', + 'type' => TType::STRING, + ), + 9 => array( + 'var' => 'executionId', + 'type' => TType::STRING, + ), + 10 => array( + 'var' => 'gatewayExecutionId', + 'type' => TType::STRING, + ), + 11 => array( + 'var' => 'enableEmailNotification', + 'type' => TType::BOOL, + ), + 12 => array( + 'var' => 'emailAddresses', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), + 13 => array( + 'var' => 'userConfigurationData', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Experiment\UserConfigurationDataModel', + ), + 14 => array( + 'var' => 'experimentInputs', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Application\Io\InputDataObjectType', + ), + ), + 15 => array( + 'var' => 'experimentOutputs', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Application\Io\OutputDataObjectType', + ), + ), + 16 => array( + 'var' => 'experimentStatus', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Status\ExperimentStatus', + ), + 17 => array( + 'var' => 'errors', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Commons\ErrorModel', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['experimentId'])) { + $this->experimentId = $vals['experimentId']; + } + if (isset($vals['projectId'])) { + $this->projectId = $vals['projectId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['experimentType'])) { + $this->experimentType = $vals['experimentType']; + } + if (isset($vals['userName'])) { + $this->userName = $vals['userName']; + } + if (isset($vals['experimentName'])) { + $this->experimentName = $vals['experimentName']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['description'])) { + $this->description = $vals['description']; + } + if (isset($vals['executionId'])) { + $this->executionId = $vals['executionId']; + } + if (isset($vals['gatewayExecutionId'])) { + $this->gatewayExecutionId = $vals['gatewayExecutionId']; + } + if (isset($vals['enableEmailNotification'])) { + $this->enableEmailNotification = $vals['enableEmailNotification']; + } + if (isset($vals['emailAddresses'])) { + $this->emailAddresses = $vals['emailAddresses']; + } + if (isset($vals['userConfigurationData'])) { + $this->userConfigurationData = $vals['userConfigurationData']; + } + if (isset($vals['experimentInputs'])) { + $this->experimentInputs = $vals['experimentInputs']; + } + if (isset($vals['experimentOutputs'])) { + $this->experimentOutputs = $vals['experimentOutputs']; + } + if (isset($vals['experimentStatus'])) { + $this->experimentStatus = $vals['experimentStatus']; + } + if (isset($vals['errors'])) { + $this->errors = $vals['errors']; + } + } + } + + public function getName() { + return 'ExperimentModel'; + } + + 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->experimentId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->projectId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->experimentType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->experimentName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->description); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->executionId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayExecutionId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->enableEmailNotification); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::LST) { + $this->emailAddresses = array(); + $_size0 = 0; + $_etype3 = 0; + $xfer += $input->readListBegin($_etype3, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $elem5 = null; + $xfer += $input->readString($elem5); + $this->emailAddresses []= $elem5; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: + if ($ftype == TType::STRUCT) { + $this->userConfigurationData = new \Airavata\Model\Experiment\UserConfigurationDataModel(); + $xfer += $this->userConfigurationData->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 14: + if ($ftype == TType::LST) { + $this->experimentInputs = array(); + $_size6 = 0; + $_etype9 = 0; + $xfer += $input->readListBegin($_etype9, $_size6); + for ($_i10 = 0; $_i10 < $_size6; ++$_i10) + { + $elem11 = null; + $elem11 = new \Airavata\Model\Application\Io\InputDataObjectType(); + $xfer += $elem11->read($input); + $this->experimentInputs []= $elem11; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 15: + if ($ftype == TType::LST) { + $this->experimentOutputs = array(); + $_size12 = 0; + $_etype15 = 0; + $xfer += $input->readListBegin($_etype15, $_size12); + for ($_i16 = 0; $_i16 < $_size12; ++$_i16) + { + $elem17 = null; + $elem17 = new \Airavata\Model\Application\Io\OutputDataObjectType(); + $xfer += $elem17->read($input); + $this->experimentOutputs []= $elem17; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 16: + if ($ftype == TType::STRUCT) { + $this->experimentStatus = new \Airavata\Model\Status\ExperimentStatus(); + $xfer += $this->experimentStatus->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 17: + if ($ftype == TType::LST) { + $this->errors = array(); + $_size18 = 0; + $_etype21 = 0; + $xfer += $input->readListBegin($_etype21, $_size18); + for ($_i22 = 0; $_i22 < $_size18; ++$_i22) + { + $elem23 = null; + $elem23 = new \Airavata\Model\Commons\ErrorModel(); + $xfer += $elem23->read($input); + $this->errors []= $elem23; + } + $xfer += $input->readListEnd(); + } 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('ExperimentModel'); + if ($this->experimentId !== null) { + $xfer += $output->writeFieldBegin('experimentId', TType::STRING, 1); + $xfer += $output->writeString($this->experimentId); + $xfer += $output->writeFieldEnd(); + } + if ($this->projectId !== null) { + $xfer += $output->writeFieldBegin('projectId', TType::STRING, 2); + $xfer += $output->writeString($this->projectId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 3); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentType !== null) { + $xfer += $output->writeFieldBegin('experimentType', TType::I32, 4); + $xfer += $output->writeI32($this->experimentType); + $xfer += $output->writeFieldEnd(); + } + if ($this->userName !== null) { + $xfer += $output->writeFieldBegin('userName', TType::STRING, 5); + $xfer += $output->writeString($this->userName); + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentName !== null) { + $xfer += $output->writeFieldBegin('experimentName', TType::STRING, 6); + $xfer += $output->writeString($this->experimentName); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 7); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->description !== null) { + $xfer += $output->writeFieldBegin('description', TType::STRING, 8); + $xfer += $output->writeString($this->description); + $xfer += $output->writeFieldEnd(); + } + if ($this->executionId !== null) { + $xfer += $output->writeFieldBegin('executionId', TType::STRING, 9); + $xfer += $output->writeString($this->executionId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayExecutionId !== null) { + $xfer += $output->writeFieldBegin('gatewayExecutionId', TType::STRING, 10); + $xfer += $output->writeString($this->gatewayExecutionId); + $xfer += $output->writeFieldEnd(); + } + if ($this->enableEmailNotification !== null) { + $xfer += $output->writeFieldBegin('enableEmailNotification', TType::BOOL, 11); + $xfer += $output->writeBool($this->enableEmailNotification); + $xfer += $output->writeFieldEnd(); + } + if ($this->emailAddresses !== null) { + if (!is_array($this->emailAddresses)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('emailAddresses', TType::LST, 12); + { + $output->writeListBegin(TType::STRING, count($this->emailAddresses)); + { + foreach ($this->emailAddresses as $iter24) + { + $xfer += $output->writeString($iter24); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->userConfigurationData !== null) { + if (!is_object($this->userConfigurationData)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('userConfigurationData', TType::STRUCT, 13); + $xfer += $this->userConfigurationData->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentInputs !== null) { + if (!is_array($this->experimentInputs)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('experimentInputs', TType::LST, 14); + { + $output->writeListBegin(TType::STRUCT, count($this->experimentInputs)); + { + foreach ($this->experimentInputs as $iter25) + { + $xfer += $iter25->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentOutputs !== null) { + if (!is_array($this->experimentOutputs)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('experimentOutputs', TType::LST, 15); + { + $output->writeListBegin(TType::STRUCT, count($this->experimentOutputs)); + { + foreach ($this->experimentOutputs as $iter26) + { + $xfer += $iter26->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentStatus !== null) { + if (!is_object($this->experimentStatus)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('experimentStatus', TType::STRUCT, 16); + $xfer += $this->experimentStatus->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->errors !== null) { + if (!is_array($this->errors)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('errors', TType::LST, 17); + { + $output->writeListBegin(TType::STRUCT, count($this->errors)); + { + foreach ($this->errors as $iter27) + { + $xfer += $iter27->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ExperimentSummaryModel { + static $_TSPEC; + + /** + * @var string + */ + public $experimentId = null; + /** + * @var string + */ + public $projectId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var string + */ + public $userName = null; + /** + * @var string + */ + public $name = null; + /** + * @var string + */ + public $description = null; + /** + * @var string + */ + public $executionId = null; + /** + * @var string + */ + public $experimentStatus = null; + /** + * @var int + */ + public $statusUpdateTime = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'experimentId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'projectId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 5 => array( + 'var' => 'userName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'name', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'description', + 'type' => TType::STRING, + ), + 8 => array( + 'var' => 'executionId', + 'type' => TType::STRING, + ), + 9 => array( + 'var' => 'experimentStatus', + 'type' => TType::STRING, + ), + 10 => array( + 'var' => 'statusUpdateTime', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['experimentId'])) { + $this->experimentId = $vals['experimentId']; + } + if (isset($vals['projectId'])) { + $this->projectId = $vals['projectId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['userName'])) { + $this->userName = $vals['userName']; + } + if (isset($vals['name'])) { + $this->name = $vals['name']; + } + if (isset($vals['description'])) { + $this->description = $vals['description']; + } + if (isset($vals['executionId'])) { + $this->executionId = $vals['executionId']; + } + if (isset($vals['experimentStatus'])) { + $this->experimentStatus = $vals['experimentStatus']; + } + if (isset($vals['statusUpdateTime'])) { + $this->statusUpdateTime = $vals['statusUpdateTime']; + } + } + } + + public function getName() { + return 'ExperimentSummaryModel'; + } + + 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->experimentId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->projectId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->userName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->name); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->description); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->executionId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->experimentStatus); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->statusUpdateTime); + } 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('ExperimentSummaryModel'); + if ($this->experimentId !== null) { + $xfer += $output->writeFieldBegin('experimentId', TType::STRING, 1); + $xfer += $output->writeString($this->experimentId); + $xfer += $output->writeFieldEnd(); + } + if ($this->projectId !== null) { + $xfer += $output->writeFieldBegin('projectId', TType::STRING, 2); + $xfer += $output->writeString($this->projectId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 3); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 4); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->userName !== null) { + $xfer += $output->writeFieldBegin('userName', TType::STRING, 5); + $xfer += $output->writeString($this->userName); + $xfer += $output->writeFieldEnd(); + } + if ($this->name !== null) { + $xfer += $output->writeFieldBegin('name', TType::STRING, 6); + $xfer += $output->writeString($this->name); + $xfer += $output->writeFieldEnd(); + } + if ($this->description !== null) { + $xfer += $output->writeFieldBegin('description', TType::STRING, 7); + $xfer += $output->writeString($this->description); + $xfer += $output->writeFieldEnd(); + } + if ($this->executionId !== null) { + $xfer += $output->writeFieldBegin('executionId', TType::STRING, 8); + $xfer += $output->writeString($this->executionId); + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentStatus !== null) { + $xfer += $output->writeFieldBegin('experimentStatus', TType::STRING, 9); + $xfer += $output->writeString($this->experimentStatus); + $xfer += $output->writeFieldEnd(); + } + if ($this->statusUpdateTime !== null) { + $xfer += $output->writeFieldBegin('statusUpdateTime', TType::I64, 10); + $xfer += $output->writeI64($this->statusUpdateTime); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ExperimentStatistics { + static $_TSPEC; + + /** + * @var int + */ + public $allExperimentCount = null; + /** + * @var int + */ + public $completedExperimentCount = null; + /** + * @var int + */ + public $cancelledExperimentCount = null; + /** + * @var int + */ + public $failedExperimentCount = null; + /** + * @var \Airavata\Model\Experiment\ExperimentSummaryModel[] + */ + public $allExperiments = null; + /** + * @var \Airavata\Model\Experiment\ExperimentSummaryModel[] + */ + public $completedExperiments = null; + /** + * @var \Airavata\Model\Experiment\ExperimentSummaryModel[] + */ + public $failedExperiments = null; + /** + * @var \Airavata\Model\Experiment\ExperimentSummaryModel[] + */ + public $cancelledExperiments = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'allExperimentCount', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'completedExperimentCount', + 'type' => TType::I32, + ), + 3 => array( + 'var' => 'cancelledExperimentCount', + 'type' => TType::I32, + ), + 4 => array( + 'var' => 'failedExperimentCount', + 'type' => TType::I32, + ), + 5 => array( + 'var' => 'allExperiments', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Experiment\ExperimentSummaryModel', + ), + ), + 6 => array( + 'var' => 'completedExperiments', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Experiment\ExperimentSummaryModel', + ), + ), + 7 => array( + 'var' => 'failedExperiments', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Experiment\ExperimentSummaryModel', + ), + ), + 8 => array( + 'var' => 'cancelledExperiments', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Experiment\ExperimentSummaryModel', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['allExperimentCount'])) { + $this->allExperimentCount = $vals['allExperimentCount']; + } + if (isset($vals['completedExperimentCount'])) { + $this->completedExperimentCount = $vals['completedExperimentCount']; + } + if (isset($vals['cancelledExperimentCount'])) { + $this->cancelledExperimentCount = $vals['cancelledExperimentCount']; + } + if (isset($vals['failedExperimentCount'])) { + $this->failedExperimentCount = $vals['failedExperimentCount']; + } + if (isset($vals['allExperiments'])) { + $this->allExperiments = $vals['allExperiments']; + } + if (isset($vals['completedExperiments'])) { + $this->completedExperiments = $vals['completedExperiments']; + } + if (isset($vals['failedExperiments'])) { + $this->failedExperiments = $vals['failedExperiments']; + } + if (isset($vals['cancelledExperiments'])) { + $this->cancelledExperiments = $vals['cancelledExperiments']; + } + } + } + + public function getName() { + return 'ExperimentStatistics'; + } + + 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::I32) { + $xfer += $input->readI32($this->allExperimentCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->completedExperimentCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->cancelledExperimentCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->failedExperimentCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::LST) { + $this->allExperiments = array(); + $_size28 = 0; + $_etype31 = 0; + $xfer += $input->readListBegin($_etype31, $_size28); + for ($_i32 = 0; $_i32 < $_size28; ++$_i32) + { + $elem33 = null; + $elem33 = new \Airavata\Model\Experiment\ExperimentSummaryModel(); + $xfer += $elem33->read($input); + $this->allExperiments []= $elem33; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::LST) { + $this->completedExperiments = array(); + $_size34 = 0; + $_etype37 = 0; + $xfer += $input->readListBegin($_etype37, $_size34); + for ($_i38 = 0; $_i38 < $_size34; ++$_i38) + { + $elem39 = null; + $elem39 = new \Airavata\Model\Experiment\ExperimentSummaryModel(); + $xfer += $elem39->read($input); + $this->completedExperiments []= $elem39; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::LST) { + $this->failedExperiments = array(); + $_size40 = 0; + $_etype43 = 0; + $xfer += $input->readListBegin($_etype43, $_size40); + for ($_i44 = 0; $_i44 < $_size40; ++$_i44) + { + $elem45 = null; + $elem45 = new \Airavata\Model\Experiment\ExperimentSummaryModel(); + $xfer += $elem45->read($input); + $this->failedExperiments []= $elem45; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::LST) { + $this->cancelledExperiments = array(); + $_size46 = 0; + $_etype49 = 0; + $xfer += $input->readListBegin($_etype49, $_size46); + for ($_i50 = 0; $_i50 < $_size46; ++$_i50) + { + $elem51 = null; + $elem51 = new \Airavata\Model\Experiment\ExperimentSummaryModel(); + $xfer += $elem51->read($input); + $this->cancelledExperiments []= $elem51; + } + $xfer += $input->readListEnd(); + } 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('ExperimentStatistics'); + if ($this->allExperimentCount !== null) { + $xfer += $output->writeFieldBegin('allExperimentCount', TType::I32, 1); + $xfer += $output->writeI32($this->allExperimentCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->completedExperimentCount !== null) { + $xfer += $output->writeFieldBegin('completedExperimentCount', TType::I32, 2); + $xfer += $output->writeI32($this->completedExperimentCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->cancelledExperimentCount !== null) { + $xfer += $output->writeFieldBegin('cancelledExperimentCount', TType::I32, 3); + $xfer += $output->writeI32($this->cancelledExperimentCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->failedExperimentCount !== null) { + $xfer += $output->writeFieldBegin('failedExperimentCount', TType::I32, 4); + $xfer += $output->writeI32($this->failedExperimentCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->allExperiments !== null) { + if (!is_array($this->allExperiments)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('allExperiments', TType::LST, 5); + { + $output->writeListBegin(TType::STRUCT, count($this->allExperiments)); + { + foreach ($this->allExperiments as $iter52) + { + $xfer += $iter52->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->completedExperiments !== null) { + if (!is_array($this->completedExperiments)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('completedExperiments', TType::LST, 6); + { + $output->writeListBegin(TType::STRUCT, count($this->completedExperiments)); + { + foreach ($this->completedExperiments as $iter53) + { + $xfer += $iter53->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->failedExperiments !== null) { + if (!is_array($this->failedExperiments)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('failedExperiments', TType::LST, 7); + { + $output->writeListBegin(TType::STRUCT, count($this->failedExperiments)); + { + foreach ($this->failedExperiments as $iter54) + { + $xfer += $iter54->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->cancelledExperiments !== null) { + if (!is_array($this->cancelledExperiments)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('cancelledExperiments', TType::LST, 8); + { + $output->writeListBegin(TType::STRUCT, count($this->cancelledExperiments)); + { + foreach ($this->cancelledExperiments as $iter55) + { + $xfer += $iter55->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +
http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Messaging/Event/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Messaging/Event/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Messaging/Event/Types.php index d90c6f8..c6dce6c 100644 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Messaging/Event/Types.php +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Messaging/Event/Types.php @@ -1760,12 +1760,4 @@ class Message { } -final class Constant extends \Thrift\Type\TConstant { - static protected $DEFAULT_ID; - - static protected function init_DEFAULT_ID() { - return "DO_NOT_SET_AT_CLIENTS"; - } -} - http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Process/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Process/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Process/Types.php new file mode 100644 index 0000000..2fd241f --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Process/Types.php @@ -0,0 +1,620 @@ +<?php +namespace Airavata\Model\Process; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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; + + +/** + * ProcessModel: A structure holding the process details. The infromation is derived based on user provided + * configuration data or system inferred information from scheduling and QoS parameters. + * + * processDetail: + * A friendly description of the process, usally used to communicate information to users. + * + * + */ +class ProcessModel { + static $_TSPEC; + + /** + * @var string + */ + public $processId = "DO_NOT_SET_AT_CLIENTS"; + /** + * @var string + */ + public $experimentId = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastUpdateTime = null; + /** + * @var \Airavata\Model\Status\ProcessStatus + */ + public $processStatus = null; + /** + * @var string + */ + public $processDetail = null; + /** + * @var string + */ + public $applicationInterfaceId = null; + /** + * @var string + */ + public $applicationDeploymentId = null; + /** + * @var string + */ + public $computeResourceId = null; + /** + * @var \Airavata\Model\Application\Io\InputDataObjectType[] + */ + public $processInputs = null; + /** + * @var \Airavata\Model\Application\Io\OutputDataObjectType[] + */ + public $processOutputs = null; + /** + * @var \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel + */ + public $resourceSchedule = null; + /** + * @var \Airavata\Model\Task\TaskModel[] + */ + public $tasks = null; + /** + * @var string + */ + public $taskDag = null; + /** + * @var \Airavata\Model\Commons\ErrorModel + */ + public $processError = null; + /** + * @var string + */ + public $gatewayExecutionId = null; + /** + * @var bool + */ + public $enableEmailNotification = null; + /** + * @var string[] + */ + public $emailAddresses = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'processId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'experimentId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 4 => array( + 'var' => 'lastUpdateTime', + 'type' => TType::I64, + ), + 5 => array( + 'var' => 'processStatus', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Status\ProcessStatus', + ), + 6 => array( + 'var' => 'processDetail', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'applicationInterfaceId', + 'type' => TType::STRING, + ), + 8 => array( + 'var' => 'applicationDeploymentId', + 'type' => TType::STRING, + ), + 9 => array( + 'var' => 'computeResourceId', + 'type' => TType::STRING, + ), + 10 => array( + 'var' => 'processInputs', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Application\Io\InputDataObjectType', + ), + ), + 11 => array( + 'var' => 'processOutputs', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Application\Io\OutputDataObjectType', + ), + ), + 12 => array( + 'var' => 'resourceSchedule', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Scheduling\ComputationalResourceSchedulingModel', + ), + 13 => array( + 'var' => 'tasks', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Task\TaskModel', + ), + ), + 14 => array( + 'var' => 'taskDag', + 'type' => TType::STRING, + ), + 15 => array( + 'var' => 'processError', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Commons\ErrorModel', + ), + 16 => array( + 'var' => 'gatewayExecutionId', + 'type' => TType::STRING, + ), + 17 => array( + 'var' => 'enableEmailNotification', + 'type' => TType::BOOL, + ), + 18 => array( + 'var' => 'emailAddresses', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['processId'])) { + $this->processId = $vals['processId']; + } + if (isset($vals['experimentId'])) { + $this->experimentId = $vals['experimentId']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastUpdateTime'])) { + $this->lastUpdateTime = $vals['lastUpdateTime']; + } + if (isset($vals['processStatus'])) { + $this->processStatus = $vals['processStatus']; + } + if (isset($vals['processDetail'])) { + $this->processDetail = $vals['processDetail']; + } + if (isset($vals['applicationInterfaceId'])) { + $this->applicationInterfaceId = $vals['applicationInterfaceId']; + } + if (isset($vals['applicationDeploymentId'])) { + $this->applicationDeploymentId = $vals['applicationDeploymentId']; + } + if (isset($vals['computeResourceId'])) { + $this->computeResourceId = $vals['computeResourceId']; + } + if (isset($vals['processInputs'])) { + $this->processInputs = $vals['processInputs']; + } + if (isset($vals['processOutputs'])) { + $this->processOutputs = $vals['processOutputs']; + } + if (isset($vals['resourceSchedule'])) { + $this->resourceSchedule = $vals['resourceSchedule']; + } + if (isset($vals['tasks'])) { + $this->tasks = $vals['tasks']; + } + if (isset($vals['taskDag'])) { + $this->taskDag = $vals['taskDag']; + } + if (isset($vals['processError'])) { + $this->processError = $vals['processError']; + } + if (isset($vals['gatewayExecutionId'])) { + $this->gatewayExecutionId = $vals['gatewayExecutionId']; + } + if (isset($vals['enableEmailNotification'])) { + $this->enableEmailNotification = $vals['enableEmailNotification']; + } + if (isset($vals['emailAddresses'])) { + $this->emailAddresses = $vals['emailAddresses']; + } + } + } + + public function getName() { + return 'ProcessModel'; + } + + 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->processId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->experimentId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastUpdateTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRUCT) { + $this->processStatus = new \Airavata\Model\Status\ProcessStatus(); + $xfer += $this->processStatus->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->processDetail); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->applicationInterfaceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->applicationDeploymentId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->computeResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::LST) { + $this->processInputs = array(); + $_size0 = 0; + $_etype3 = 0; + $xfer += $input->readListBegin($_etype3, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $elem5 = null; + $elem5 = new \Airavata\Model\Application\Io\InputDataObjectType(); + $xfer += $elem5->read($input); + $this->processInputs []= $elem5; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::LST) { + $this->processOutputs = array(); + $_size6 = 0; + $_etype9 = 0; + $xfer += $input->readListBegin($_etype9, $_size6); + for ($_i10 = 0; $_i10 < $_size6; ++$_i10) + { + $elem11 = null; + $elem11 = new \Airavata\Model\Application\Io\OutputDataObjectType(); + $xfer += $elem11->read($input); + $this->processOutputs []= $elem11; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::STRUCT) { + $this->resourceSchedule = new \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel(); + $xfer += $this->resourceSchedule->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: + if ($ftype == TType::LST) { + $this->tasks = array(); + $_size12 = 0; + $_etype15 = 0; + $xfer += $input->readListBegin($_etype15, $_size12); + for ($_i16 = 0; $_i16 < $_size12; ++$_i16) + { + $elem17 = null; + $elem17 = new \Airavata\Model\Task\TaskModel(); + $xfer += $elem17->read($input); + $this->tasks []= $elem17; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 14: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->taskDag); + } else { + $xfer += $input->skip($ftype); + } + break; + case 15: + if ($ftype == TType::STRUCT) { + $this->processError = new \Airavata\Model\Commons\ErrorModel(); + $xfer += $this->processError->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 16: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayExecutionId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 17: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->enableEmailNotification); + } else { + $xfer += $input->skip($ftype); + } + break; + case 18: + if ($ftype == TType::LST) { + $this->emailAddresses = array(); + $_size18 = 0; + $_etype21 = 0; + $xfer += $input->readListBegin($_etype21, $_size18); + for ($_i22 = 0; $_i22 < $_size18; ++$_i22) + { + $elem23 = null; + $xfer += $input->readString($elem23); + $this->emailAddresses []= $elem23; + } + $xfer += $input->readListEnd(); + } 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('ProcessModel'); + if ($this->processId !== null) { + $xfer += $output->writeFieldBegin('processId', TType::STRING, 1); + $xfer += $output->writeString($this->processId); + $xfer += $output->writeFieldEnd(); + } + if ($this->experimentId !== null) { + $xfer += $output->writeFieldBegin('experimentId', TType::STRING, 2); + $xfer += $output->writeString($this->experimentId); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 3); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastUpdateTime !== null) { + $xfer += $output->writeFieldBegin('lastUpdateTime', TType::I64, 4); + $xfer += $output->writeI64($this->lastUpdateTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->processStatus !== null) { + if (!is_object($this->processStatus)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('processStatus', TType::STRUCT, 5); + $xfer += $this->processStatus->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->processDetail !== null) { + $xfer += $output->writeFieldBegin('processDetail', TType::STRING, 6); + $xfer += $output->writeString($this->processDetail); + $xfer += $output->writeFieldEnd(); + } + if ($this->applicationInterfaceId !== null) { + $xfer += $output->writeFieldBegin('applicationInterfaceId', TType::STRING, 7); + $xfer += $output->writeString($this->applicationInterfaceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->applicationDeploymentId !== null) { + $xfer += $output->writeFieldBegin('applicationDeploymentId', TType::STRING, 8); + $xfer += $output->writeString($this->applicationDeploymentId); + $xfer += $output->writeFieldEnd(); + } + if ($this->computeResourceId !== null) { + $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 9); + $xfer += $output->writeString($this->computeResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->processInputs !== null) { + if (!is_array($this->processInputs)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('processInputs', TType::LST, 10); + { + $output->writeListBegin(TType::STRUCT, count($this->processInputs)); + { + foreach ($this->processInputs as $iter24) + { + $xfer += $iter24->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->processOutputs !== null) { + if (!is_array($this->processOutputs)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('processOutputs', TType::LST, 11); + { + $output->writeListBegin(TType::STRUCT, count($this->processOutputs)); + { + foreach ($this->processOutputs as $iter25) + { + $xfer += $iter25->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->resourceSchedule !== null) { + if (!is_object($this->resourceSchedule)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('resourceSchedule', TType::STRUCT, 12); + $xfer += $this->resourceSchedule->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->tasks !== null) { + if (!is_array($this->tasks)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('tasks', TType::LST, 13); + { + $output->writeListBegin(TType::STRUCT, count($this->tasks)); + { + foreach ($this->tasks as $iter26) + { + $xfer += $iter26->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->taskDag !== null) { + $xfer += $output->writeFieldBegin('taskDag', TType::STRING, 14); + $xfer += $output->writeString($this->taskDag); + $xfer += $output->writeFieldEnd(); + } + if ($this->processError !== null) { + if (!is_object($this->processError)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('processError', TType::STRUCT, 15); + $xfer += $this->processError->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayExecutionId !== null) { + $xfer += $output->writeFieldBegin('gatewayExecutionId', TType::STRING, 16); + $xfer += $output->writeString($this->gatewayExecutionId); + $xfer += $output->writeFieldEnd(); + } + if ($this->enableEmailNotification !== null) { + $xfer += $output->writeFieldBegin('enableEmailNotification', TType::BOOL, 17); + $xfer += $output->writeBool($this->enableEmailNotification); + $xfer += $output->writeFieldEnd(); + } + if ($this->emailAddresses !== null) { + if (!is_array($this->emailAddresses)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('emailAddresses', TType::LST, 18); + { + $output->writeListBegin(TType::STRING, count($this->emailAddresses)); + { + foreach ($this->emailAddresses as $iter27) + { + $xfer += $output->writeString($iter27); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Scheduling/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Scheduling/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Scheduling/Types.php new file mode 100644 index 0000000..ffda7fa --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Scheduling/Types.php @@ -0,0 +1,261 @@ +<?php +namespace Airavata\Model\Scheduling; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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; + + +/** + * ComputationalResourceSchedulingModel: + * + * + */ +class ComputationalResourceSchedulingModel { + static $_TSPEC; + + /** + * @var string + */ + public $resourceHostId = null; + /** + * @var int + */ + public $totalCPUCount = null; + /** + * @var int + */ + public $nodeCount = null; + /** + * @var int + */ + public $numberOfThreads = null; + /** + * @var string + */ + public $queueName = null; + /** + * @var int + */ + public $wallTimeLimit = null; + /** + * @var int + */ + public $totalPhysicalMemory = null; + /** + * @var string + */ + public $chessisNumber = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'resourceHostId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'totalCPUCount', + 'type' => TType::I32, + ), + 3 => array( + 'var' => 'nodeCount', + 'type' => TType::I32, + ), + 4 => array( + 'var' => 'numberOfThreads', + 'type' => TType::I32, + ), + 5 => array( + 'var' => 'queueName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'wallTimeLimit', + 'type' => TType::I32, + ), + 7 => array( + 'var' => 'totalPhysicalMemory', + 'type' => TType::I32, + ), + 8 => array( + 'var' => 'chessisNumber', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['resourceHostId'])) { + $this->resourceHostId = $vals['resourceHostId']; + } + if (isset($vals['totalCPUCount'])) { + $this->totalCPUCount = $vals['totalCPUCount']; + } + if (isset($vals['nodeCount'])) { + $this->nodeCount = $vals['nodeCount']; + } + if (isset($vals['numberOfThreads'])) { + $this->numberOfThreads = $vals['numberOfThreads']; + } + if (isset($vals['queueName'])) { + $this->queueName = $vals['queueName']; + } + if (isset($vals['wallTimeLimit'])) { + $this->wallTimeLimit = $vals['wallTimeLimit']; + } + if (isset($vals['totalPhysicalMemory'])) { + $this->totalPhysicalMemory = $vals['totalPhysicalMemory']; + } + if (isset($vals['chessisNumber'])) { + $this->chessisNumber = $vals['chessisNumber']; + } + } + } + + public function getName() { + return 'ComputationalResourceSchedulingModel'; + } + + 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->resourceHostId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->totalCPUCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->nodeCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->numberOfThreads); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->queueName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->wallTimeLimit); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->totalPhysicalMemory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->chessisNumber); + } 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('ComputationalResourceSchedulingModel'); + if ($this->resourceHostId !== null) { + $xfer += $output->writeFieldBegin('resourceHostId', TType::STRING, 1); + $xfer += $output->writeString($this->resourceHostId); + $xfer += $output->writeFieldEnd(); + } + if ($this->totalCPUCount !== null) { + $xfer += $output->writeFieldBegin('totalCPUCount', TType::I32, 2); + $xfer += $output->writeI32($this->totalCPUCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->nodeCount !== null) { + $xfer += $output->writeFieldBegin('nodeCount', TType::I32, 3); + $xfer += $output->writeI32($this->nodeCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->numberOfThreads !== null) { + $xfer += $output->writeFieldBegin('numberOfThreads', TType::I32, 4); + $xfer += $output->writeI32($this->numberOfThreads); + $xfer += $output->writeFieldEnd(); + } + if ($this->queueName !== null) { + $xfer += $output->writeFieldBegin('queueName', TType::STRING, 5); + $xfer += $output->writeString($this->queueName); + $xfer += $output->writeFieldEnd(); + } + if ($this->wallTimeLimit !== null) { + $xfer += $output->writeFieldBegin('wallTimeLimit', TType::I32, 6); + $xfer += $output->writeI32($this->wallTimeLimit); + $xfer += $output->writeFieldEnd(); + } + if ($this->totalPhysicalMemory !== null) { + $xfer += $output->writeFieldBegin('totalPhysicalMemory', TType::I32, 7); + $xfer += $output->writeI32($this->totalPhysicalMemory); + $xfer += $output->writeFieldEnd(); + } + if ($this->chessisNumber !== null) { + $xfer += $output->writeFieldBegin('chessisNumber', TType::STRING, 8); + $xfer += $output->writeString($this->chessisNumber); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Security/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Security/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Security/Types.php new file mode 100644 index 0000000..7904fef --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Security/Types.php @@ -0,0 +1,152 @@ +<?php +namespace Airavata\Model\Security; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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; + + +class AuthzToken { + static $_TSPEC; + + /** + * @var string + */ + public $accessToken = null; + /** + * @var array + */ + public $claimsMap = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'accessToken', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'claimsMap', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['accessToken'])) { + $this->accessToken = $vals['accessToken']; + } + if (isset($vals['claimsMap'])) { + $this->claimsMap = $vals['claimsMap']; + } + } + } + + public function getName() { + return 'AuthzToken'; + } + + 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->accessToken); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::MAP) { + $this->claimsMap = array(); + $_size0 = 0; + $_ktype1 = 0; + $_vtype2 = 0; + $xfer += $input->readMapBegin($_ktype1, $_vtype2, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $key5 = ''; + $val6 = ''; + $xfer += $input->readString($key5); + $xfer += $input->readString($val6); + $this->claimsMap[$key5] = $val6; + } + $xfer += $input->readMapEnd(); + } 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('AuthzToken'); + if ($this->accessToken !== null) { + $xfer += $output->writeFieldBegin('accessToken', TType::STRING, 1); + $xfer += $output->writeString($this->accessToken); + $xfer += $output->writeFieldEnd(); + } + if ($this->claimsMap !== null) { + if (!is_array($this->claimsMap)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('claimsMap', TType::MAP, 2); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->claimsMap)); + { + foreach ($this->claimsMap as $kiter7 => $viter8) + { + $xfer += $output->writeString($kiter7); + $xfer += $output->writeString($viter8); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +
