http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Product/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Product/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Product/Types.php new file mode 100644 index 0000000..8e4ace9 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Product/Types.php @@ -0,0 +1,856 @@ +<?php +namespace Airavata\Model\Data\Product; + +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * 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 ReplicaLocationCategory { + const GATEWAY_DATA_STORE = 0; + const COMPUTE_RESOURCE = 1; + const LONG_TERM_STORAGE_RESOURCE = 2; + const OTHER = 3; + static public $__names = array( + 0 => 'GATEWAY_DATA_STORE', + 1 => 'COMPUTE_RESOURCE', + 2 => 'LONG_TERM_STORAGE_RESOURCE', + 3 => 'OTHER', + ); +} + +final class ReplicaPersistentType { + const TRANSIENT = 0; + const PERSISTENT = 1; + static public $__names = array( + 0 => 'TRANSIENT', + 1 => 'PERSISTENT', + ); +} + +final class DataProductType { + const DIR = 0; + const FILE = 1; + const COLLECTION = 2; + static public $__names = array( + 0 => 'DIR', + 1 => 'FILE', + 2 => 'COLLECTION', + ); +} + +class DataProductModel { + static $_TSPEC; + + /** + * @var string + */ + public $productId = null; + /** + * @var string + */ + public $gatewayId = null; + /** + * @var string + */ + public $parentProductId = null; + /** + * @var string + */ + public $productName = null; + /** + * @var string + */ + public $productDescription = null; + /** + * @var string + */ + public $ownerName = null; + /** + * @var int + */ + public $dataProductType = null; + /** + * @var int + */ + public $productSize = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var array + */ + public $productMetadata = null; + /** + * @var \Airavata\Model\Data\Product\DataReplicaLocationModel[] + */ + public $replicaLocations = null; + /** + * @var \Airavata\Model\Data\Product\DataProductModel[] + */ + public $childProducts = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'productId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'gatewayId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'parentProductId', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'productName', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'productDescription', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'ownerName', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'dataProductType', + 'type' => TType::I32, + ), + 8 => array( + 'var' => 'productSize', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 10 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 11 => array( + 'var' => 'productMetadata', + 'type' => TType::MAP, + 'ktype' => TType::STRING, + 'vtype' => TType::STRING, + 'key' => array( + 'type' => TType::STRING, + ), + 'val' => array( + 'type' => TType::STRING, + ), + ), + 12 => array( + 'var' => 'replicaLocations', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Product\DataReplicaLocationModel', + ), + ), + 13 => array( + 'var' => 'childProducts', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Data\Product\DataProductModel', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['productId'])) { + $this->productId = $vals['productId']; + } + if (isset($vals['gatewayId'])) { + $this->gatewayId = $vals['gatewayId']; + } + if (isset($vals['parentProductId'])) { + $this->parentProductId = $vals['parentProductId']; + } + if (isset($vals['productName'])) { + $this->productName = $vals['productName']; + } + if (isset($vals['productDescription'])) { + $this->productDescription = $vals['productDescription']; + } + if (isset($vals['ownerName'])) { + $this->ownerName = $vals['ownerName']; + } + if (isset($vals['dataProductType'])) { + $this->dataProductType = $vals['dataProductType']; + } + if (isset($vals['productSize'])) { + $this->productSize = $vals['productSize']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['productMetadata'])) { + $this->productMetadata = $vals['productMetadata']; + } + if (isset($vals['replicaLocations'])) { + $this->replicaLocations = $vals['replicaLocations']; + } + if (isset($vals['childProducts'])) { + $this->childProducts = $vals['childProducts']; + } + } + } + + public function getName() { + return 'DataProductModel'; + } + + 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->productId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gatewayId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->parentProductId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ownerName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->dataProductType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->productSize); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::MAP) { + $this->productMetadata = 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->productMetadata[$key5] = $val6; + } + $xfer += $input->readMapEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::LST) { + $this->replicaLocations = array(); + $_size7 = 0; + $_etype10 = 0; + $xfer += $input->readListBegin($_etype10, $_size7); + for ($_i11 = 0; $_i11 < $_size7; ++$_i11) + { + $elem12 = null; + $elem12 = new \Airavata\Model\Data\Product\DataReplicaLocationModel(); + $xfer += $elem12->read($input); + $this->replicaLocations []= $elem12; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: + if ($ftype == TType::LST) { + $this->childProducts = array(); + $_size13 = 0; + $_etype16 = 0; + $xfer += $input->readListBegin($_etype16, $_size13); + for ($_i17 = 0; $_i17 < $_size13; ++$_i17) + { + $elem18 = null; + $elem18 = new \Airavata\Model\Data\Product\DataProductModel(); + $xfer += $elem18->read($input); + $this->childProducts []= $elem18; + } + $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('DataProductModel'); + if ($this->productId !== null) { + $xfer += $output->writeFieldBegin('productId', TType::STRING, 1); + $xfer += $output->writeString($this->productId); + $xfer += $output->writeFieldEnd(); + } + if ($this->gatewayId !== null) { + $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); + $xfer += $output->writeString($this->gatewayId); + $xfer += $output->writeFieldEnd(); + } + if ($this->parentProductId !== null) { + $xfer += $output->writeFieldBegin('parentProductId', TType::STRING, 3); + $xfer += $output->writeString($this->parentProductId); + $xfer += $output->writeFieldEnd(); + } + if ($this->productName !== null) { + $xfer += $output->writeFieldBegin('productName', TType::STRING, 4); + $xfer += $output->writeString($this->productName); + $xfer += $output->writeFieldEnd(); + } + if ($this->productDescription !== null) { + $xfer += $output->writeFieldBegin('productDescription', TType::STRING, 5); + $xfer += $output->writeString($this->productDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->ownerName !== null) { + $xfer += $output->writeFieldBegin('ownerName', TType::STRING, 6); + $xfer += $output->writeString($this->ownerName); + $xfer += $output->writeFieldEnd(); + } + if ($this->dataProductType !== null) { + $xfer += $output->writeFieldBegin('dataProductType', TType::I32, 7); + $xfer += $output->writeI32($this->dataProductType); + $xfer += $output->writeFieldEnd(); + } + if ($this->productSize !== null) { + $xfer += $output->writeFieldBegin('productSize', TType::I32, 8); + $xfer += $output->writeI32($this->productSize); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 9); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 10); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->productMetadata !== null) { + if (!is_array($this->productMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('productMetadata', TType::MAP, 11); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->productMetadata)); + { + foreach ($this->productMetadata as $kiter19 => $viter20) + { + $xfer += $output->writeString($kiter19); + $xfer += $output->writeString($viter20); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocations !== null) { + if (!is_array($this->replicaLocations)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaLocations', TType::LST, 12); + { + $output->writeListBegin(TType::STRUCT, count($this->replicaLocations)); + { + foreach ($this->replicaLocations as $iter21) + { + $xfer += $iter21->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->childProducts !== null) { + if (!is_array($this->childProducts)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('childProducts', TType::LST, 13); + { + $output->writeListBegin(TType::STRUCT, count($this->childProducts)); + { + foreach ($this->childProducts as $iter22) + { + $xfer += $iter22->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class DataReplicaLocationModel { + static $_TSPEC; + + /** + * @var string + */ + public $replicaId = null; + /** + * @var string + */ + public $productId = null; + /** + * @var string + */ + public $replicaName = null; + /** + * @var string + */ + public $replicaDescription = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastModifiedTime = null; + /** + * @var int + */ + public $validUntilTime = null; + /** + * @var int + */ + public $replicaLocationCategory = null; + /** + * @var int + */ + public $replicaPersistentType = null; + /** + * @var string + */ + public $storageResourceId = null; + /** + * @var string + */ + public $fileAbsolutePath = null; + /** + * @var array + */ + public $replicaMetadata = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'replicaId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'productId', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'replicaName', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'replicaDescription', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 6 => array( + 'var' => 'lastModifiedTime', + 'type' => TType::I64, + ), + 7 => array( + 'var' => 'validUntilTime', + 'type' => TType::I64, + ), + 8 => array( + 'var' => 'replicaLocationCategory', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'replicaPersistentType', + 'type' => TType::I32, + ), + 10 => array( + 'var' => 'storageResourceId', + 'type' => TType::STRING, + ), + 11 => array( + 'var' => 'fileAbsolutePath', + 'type' => TType::STRING, + ), + 12 => array( + 'var' => 'replicaMetadata', + '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['replicaId'])) { + $this->replicaId = $vals['replicaId']; + } + if (isset($vals['productId'])) { + $this->productId = $vals['productId']; + } + if (isset($vals['replicaName'])) { + $this->replicaName = $vals['replicaName']; + } + if (isset($vals['replicaDescription'])) { + $this->replicaDescription = $vals['replicaDescription']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastModifiedTime'])) { + $this->lastModifiedTime = $vals['lastModifiedTime']; + } + if (isset($vals['validUntilTime'])) { + $this->validUntilTime = $vals['validUntilTime']; + } + if (isset($vals['replicaLocationCategory'])) { + $this->replicaLocationCategory = $vals['replicaLocationCategory']; + } + if (isset($vals['replicaPersistentType'])) { + $this->replicaPersistentType = $vals['replicaPersistentType']; + } + if (isset($vals['storageResourceId'])) { + $this->storageResourceId = $vals['storageResourceId']; + } + if (isset($vals['fileAbsolutePath'])) { + $this->fileAbsolutePath = $vals['fileAbsolutePath']; + } + if (isset($vals['replicaMetadata'])) { + $this->replicaMetadata = $vals['replicaMetadata']; + } + } + } + + public function getName() { + return 'DataReplicaLocationModel'; + } + + 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->replicaId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->productId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->replicaDescription); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastModifiedTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->validUntilTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaLocationCategory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->replicaPersistentType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->storageResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 11: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->fileAbsolutePath); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::MAP) { + $this->replicaMetadata = array(); + $_size23 = 0; + $_ktype24 = 0; + $_vtype25 = 0; + $xfer += $input->readMapBegin($_ktype24, $_vtype25, $_size23); + for ($_i27 = 0; $_i27 < $_size23; ++$_i27) + { + $key28 = ''; + $val29 = ''; + $xfer += $input->readString($key28); + $xfer += $input->readString($val29); + $this->replicaMetadata[$key28] = $val29; + } + $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('DataReplicaLocationModel'); + if ($this->replicaId !== null) { + $xfer += $output->writeFieldBegin('replicaId', TType::STRING, 1); + $xfer += $output->writeString($this->replicaId); + $xfer += $output->writeFieldEnd(); + } + if ($this->productId !== null) { + $xfer += $output->writeFieldBegin('productId', TType::STRING, 2); + $xfer += $output->writeString($this->productId); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaName !== null) { + $xfer += $output->writeFieldBegin('replicaName', TType::STRING, 3); + $xfer += $output->writeString($this->replicaName); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaDescription !== null) { + $xfer += $output->writeFieldBegin('replicaDescription', TType::STRING, 4); + $xfer += $output->writeString($this->replicaDescription); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 5); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastModifiedTime !== null) { + $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 6); + $xfer += $output->writeI64($this->lastModifiedTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->validUntilTime !== null) { + $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 7); + $xfer += $output->writeI64($this->validUntilTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaLocationCategory !== null) { + $xfer += $output->writeFieldBegin('replicaLocationCategory', TType::I32, 8); + $xfer += $output->writeI32($this->replicaLocationCategory); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaPersistentType !== null) { + $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 9); + $xfer += $output->writeI32($this->replicaPersistentType); + $xfer += $output->writeFieldEnd(); + } + if ($this->storageResourceId !== null) { + $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 10); + $xfer += $output->writeString($this->storageResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->fileAbsolutePath !== null) { + $xfer += $output->writeFieldBegin('fileAbsolutePath', TType::STRING, 11); + $xfer += $output->writeString($this->fileAbsolutePath); + $xfer += $output->writeFieldEnd(); + } + if ($this->replicaMetadata !== null) { + if (!is_array($this->replicaMetadata)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('replicaMetadata', TType::MAP, 12); + { + $output->writeMapBegin(TType::STRING, TType::STRING, count($this->replicaMetadata)); + { + foreach ($this->replicaMetadata as $kiter30 => $viter31) + { + $xfer += $output->writeString($kiter30); + $xfer += $output->writeString($viter31); + } + } + $output->writeMapEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +
http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote index 34c181e..b2abc19 100755 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote @@ -113,16 +113,16 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' bool updateSSHJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, SSHJobSubmission sshJobSubmission)') print(' bool updateCloudJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, CloudJobSubmission sshJobSubmission)') print(' bool updateUnicoreJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, UnicoreJobSubmission unicoreJobSubmission)') - print(' string addLocalDataMovementDetails(AuthzToken authzToken, string resourceId, DMType dataMoveType, i32 priorityOrder, LOCALDataMovement localDataMovement)') + print(' string addLocalDataMovementDetails(AuthzToken authzToken, string productId, DMType dataMoveType, i32 priorityOrder, LOCALDataMovement localDataMovement)') print(' bool updateLocalDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, LOCALDataMovement localDataMovement)') print(' LOCALDataMovement getLocalDataMovement(AuthzToken authzToken, string dataMovementId)') - print(' string addSCPDataMovementDetails(AuthzToken authzToken, string resourceId, DMType dataMoveType, i32 priorityOrder, SCPDataMovement scpDataMovement)') + print(' string addSCPDataMovementDetails(AuthzToken authzToken, string productId, DMType dataMoveType, i32 priorityOrder, SCPDataMovement scpDataMovement)') print(' bool updateSCPDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, SCPDataMovement scpDataMovement)') print(' SCPDataMovement getSCPDataMovement(AuthzToken authzToken, string dataMovementId)') - print(' string addUnicoreDataMovementDetails(AuthzToken authzToken, string resourceId, DMType dataMoveType, i32 priorityOrder, UnicoreDataMovement unicoreDataMovement)') + print(' string addUnicoreDataMovementDetails(AuthzToken authzToken, string productId, DMType dataMoveType, i32 priorityOrder, UnicoreDataMovement unicoreDataMovement)') print(' bool updateUnicoreDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, UnicoreDataMovement unicoreDataMovement)') print(' UnicoreDataMovement getUnicoreDataMovement(AuthzToken authzToken, string dataMovementId)') - print(' string addGridFTPDataMovementDetails(AuthzToken authzToken, string resourceId, DMType dataMoveType, i32 priorityOrder, GridFTPDataMovement gridFTPDataMovement)') + print(' string addGridFTPDataMovementDetails(AuthzToken authzToken, string productId, DMType dataMoveType, i32 priorityOrder, GridFTPDataMovement gridFTPDataMovement)') print(' bool updateGridFTPDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, GridFTPDataMovement gridFTPDataMovement)') print(' GridFTPDataMovement getGridFTPDataMovement(AuthzToken authzToken, string dataMovementId)') print(' bool changeJobSubmissionPriority(AuthzToken authzToken, string jobSubmissionInterfaceId, i32 newPriorityOrder)') @@ -130,7 +130,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' bool changeJobSubmissionPriorities(AuthzToken authzToken, jobSubmissionPriorityMap)') print(' bool changeDataMovementPriorities(AuthzToken authzToken, dataMovementPriorityMap)') print(' bool deleteJobSubmissionInterface(AuthzToken authzToken, string computeResourceId, string jobSubmissionInterfaceId)') - print(' bool deleteDataMovementInterface(AuthzToken authzToken, string resourceId, string dataMovementInterfaceId, DMType dataMoveType)') + print(' bool deleteDataMovementInterface(AuthzToken authzToken, string productId, string dataMovementInterfaceId, DMType dataMoveType)') print(' string registerResourceJobManager(AuthzToken authzToken, ResourceJobManager resourceJobManager)') print(' bool updateResourceJobManager(AuthzToken authzToken, string resourceJobManagerId, ResourceJobManager updatedResourceJobManager)') print(' ResourceJobManager getResourceJobManager(AuthzToken authzToken, string resourceJobManagerId)') @@ -158,12 +158,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' void updateWorkflow(AuthzToken authzToken, string workflowTemplateId, WorkflowModel workflow)') print(' string getWorkflowTemplateId(AuthzToken authzToken, string workflowName)') print(' bool isWorkflowExistWithName(AuthzToken authzToken, string workflowName)') - print(' string registerDataResource(AuthzToken authzToken, DataResourceModel dataResourceModel)') - print(' void updateDataResource(AuthzToken authzToken, DataResourceModel dataResourceModel)') - print(' void removeDataResource(AuthzToken authzToken, string resourceId)') - print(' DataResourceModel getDataResource(AuthzToken authzToken, string resourceId)') - print(' string copyDataResource(AuthzToken authzToken, string resourceId, string destStorageResourceId, string destinationParentPath)') - print(' string copyDataReplica(AuthzToken authzToken, string resourceId, string replicaId, string destStorageResourceId, string destinationParentPath)') print('') sys.exit(0) @@ -1024,42 +1018,6 @@ elif cmd == 'isWorkflowExistWithName': sys.exit(1) pp.pprint(client.isWorkflowExistWithName(eval(args[0]),args[1],)) -elif cmd == 'registerDataResource': - if len(args) != 2: - print('registerDataResource requires 2 args') - sys.exit(1) - pp.pprint(client.registerDataResource(eval(args[0]),eval(args[1]),)) - -elif cmd == 'updateDataResource': - if len(args) != 2: - print('updateDataResource requires 2 args') - sys.exit(1) - pp.pprint(client.updateDataResource(eval(args[0]),eval(args[1]),)) - -elif cmd == 'removeDataResource': - if len(args) != 2: - print('removeDataResource requires 2 args') - sys.exit(1) - pp.pprint(client.removeDataResource(eval(args[0]),args[1],)) - -elif cmd == 'getDataResource': - if len(args) != 2: - print('getDataResource requires 2 args') - sys.exit(1) - pp.pprint(client.getDataResource(eval(args[0]),args[1],)) - -elif cmd == 'copyDataResource': - if len(args) != 4: - print('copyDataResource requires 4 args') - sys.exit(1) - pp.pprint(client.copyDataResource(eval(args[0]),args[1],args[2],args[3],)) - -elif cmd == 'copyDataReplica': - if len(args) != 5: - print('copyDataReplica requires 5 args') - sys.exit(1) - pp.pprint(client.copyDataReplica(eval(args[0]),args[1],args[2],args[3],args[4],)) - else: print('Unrecognized method %s' % cmd) sys.exit(1)
