You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2016/10/07 20:52:42 UTC
[15/31] airavata git commit: correcting the registry code,
testing not yet complete
http://git-wip-us.apache.org/repos/asf/airavata/blob/8469effc/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
index a73c656..9c0c662 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
@@ -3229,10 +3229,330 @@ interface AiravataIf {
*/
public function deleteGatewayStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayID, $storageId);
/**
- * Delete the Storage Resource Preference of a registered gateway profile.
+ * Register User Resource Profile.
*
- * @param gatewayID
- * The identifier of the gateway profile to be deleted.
+ * @param UserResourceProfile
+ * User Resource Profile Object.
+ * The userId should be obtained from Airavata user profile data model and passed to register a corresponding
+ * resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the update.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile
+ * @return string
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile);
+ /**
+ * Fetch the given User Resource Profile.
+ *
+ * @param userId
+ * The identifier for the requested user resource profile.
+ *
+ * @return UserResourceProfile
+ * User Resource Profile Object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile Gateway Resource Profile
+ *
+ * gatewayID:
+ * Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration.
+ *
+ * credentialStoreToken:
+ * Gateway's defualt credential store token.
+ *
+ * computeResourcePreferences:
+ * List of resource preferences for each of the registered compute resources.
+ *
+ * identityServerTenant:
+ *
+ * identityServerPwdCredToken:
+ *
+ *
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId);
+ /**
+ * Update a User Resource Profile.
+ *
+ * @param userId
+ * The identifier for the requested user resource to be updated.
+ *
+ * @param UserResourceProfile
+ * User Resource Profile Object.
+ *
+ * @return status
+ * Returns a success/failure of the update.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile);
+ /**
+ * Delete the given User Resource Profile.
+ *
+ * @param userId
+ * The identifier for the requested user resource to be deleted.
+ *
+ * @return status
+ * Returns a success/failure of the deletion.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId);
+ /**
+ * Add a Compute Resource Preference to a registered User profile.
+ *
+ * @param userId
+ * The identifier for the User resource profile to be added.
+ *
+ * @param computeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @param computeResourcePreference
+ * The ComputeResourcePreference object to be added to the resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the addition. If a profile already exists, this operation will fail.
+ * Instead an update should be used.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $computeResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference);
+ /**
+ * Add a Storage Resource Preference to a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to be added.
+ *
+ * @param storageResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @param computeResourcePreference
+ * The ComputeResourcePreference object to be added to the resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the addition. If a profile already exists, this operation will fail.
+ * Instead an update should be used.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $storageResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference);
+ /**
+ *
+ * Fetch a Compute Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier for the user profile to be requested
+ *
+ * @param computeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @return computeResourcePreference
+ * Returns the ComputeResourcePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $computeResourceId
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference Gateway specific preferences for a Computer Resource
+ *
+ * computeResourceId:
+ * Corelate the preference to a compute resource.
+ *
+ *
+ * loginUserName:
+ * If turned true, Airavata will override the preferences of better alternatives exist.
+ *
+ *
+ * preferredBatchQueue:
+ * Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics.
+ *
+ * scratchLocation:
+ * Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution.
+ *
+ * allocationProjectNumber:
+ * Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an
+ * allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the
+ * account to be used has to be added to the allocation.
+ *
+ * resourceSpecificCredentialStoreToken:
+ * Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's
+ * default credential store.
+ *
+ *
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId);
+ /**
+ *
+ * Fetch a Storage Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to request to fetch the particular storage resource preference.
+ *
+ * @param storageResourceId
+ * Identifier of the Stprage Preference required to be fetched.
+ *
+ * @return StoragePreference
+ * Returns the StoragePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $storageResourceId
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId);
+ /**
+ *
+ * Fetch all user resources Profiles registered
+ *
+ * @return UserResourceProfile
+ * Returns all the UserResourcePrifle list object.
+ *
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken);
+ /**
+ * Update a Compute Resource Preference to a registered user resource profile.
+ *
+ * @param userId
+ * The identifier for the user profile to be updated.
+ *
+ * @param computeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @param computeResourcePreference
+ * The ComputeResourcePreference object to be updated to the resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the updation.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $computeResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference);
+ /**
+ * Update a Storage Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to be updated.
+ *
+ * @param storageId
+ * The Storage resource identifier of the one that you want to update
+ *
+ * @param storagePreference
+ * The storagePreference object to be updated to the resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the updation.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $storageId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference);
+ /**
+ * Delete the Compute Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier for the user resource profile to be deleted.
+ *
+ * @param computeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @return status
+ * Returns a success/failure of the deletion.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $computeResourceId
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId);
+ /**
+ * Delete the Storage Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user profile to be deleted.
*
* @param storageId
* ID of the storage preference you want to delete.
@@ -3242,6 +3562,17 @@ interface AiravataIf {
*
*
* @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $storageId
+ * @return bool
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $gatewayId
* @return string[]
* @throws \Airavata\API\Error\InvalidRequestException
@@ -11813,35 +12144,35 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("deleteGatewayStoragePreference failed: unknown result");
}
- public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
+ public function registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile)
{
- $this->send_getAllWorkflows($authzToken, $gatewayId);
- return $this->recv_getAllWorkflows();
+ $this->send_registerUserResourceProfile($authzToken, $userResourceProfile);
+ return $this->recv_registerUserResourceProfile();
}
- public function send_getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
+ public function send_registerUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile)
{
- $args = new \Airavata\API\Airavata_getAllWorkflows_args();
+ $args = new \Airavata\API\Airavata_registerUserResourceProfile_args();
$args->authzToken = $authzToken;
- $args->gatewayId = $gatewayId;
+ $args->userResourceProfile = $userResourceProfile;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getAllWorkflows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'registerUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getAllWorkflows', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('registerUserResourceProfile', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getAllWorkflows()
+ public function recv_registerUserResourceProfile()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllWorkflows_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerUserResourceProfile_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -11855,7 +12186,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getAllWorkflows_result();
+ $result = new \Airavata\API\Airavata_registerUserResourceProfile_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -11874,38 +12205,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getAllWorkflows failed: unknown result");
+ throw new \Exception("registerUserResourceProfile failed: unknown result");
}
- public function getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
+ public function getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId)
{
- $this->send_getWorkflow($authzToken, $workflowTemplateId);
- return $this->recv_getWorkflow();
+ $this->send_getUserResourceProfile($authzToken, $userId);
+ return $this->recv_getUserResourceProfile();
}
- public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
+ public function send_getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId)
{
- $args = new \Airavata\API\Airavata_getWorkflow_args();
+ $args = new \Airavata\API\Airavata_getUserResourceProfile_args();
$args->authzToken = $authzToken;
- $args->workflowTemplateId = $workflowTemplateId;
+ $args->userId = $userId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getWorkflow', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getUserResourceProfile', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getWorkflow()
+ public function recv_getUserResourceProfile()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflow_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserResourceProfile_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -11919,7 +12250,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getWorkflow_result();
+ $result = new \Airavata\API\Airavata_getUserResourceProfile_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -11938,38 +12269,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getWorkflow failed: unknown result");
+ throw new \Exception("getUserResourceProfile failed: unknown result");
}
- public function deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
+ public function updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile)
{
- $this->send_deleteWorkflow($authzToken, $workflowTemplateId);
- $this->recv_deleteWorkflow();
+ $this->send_updateUserResourceProfile($authzToken, $userId, $userResourceProfile);
+ return $this->recv_updateUserResourceProfile();
}
- public function send_deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
+ public function send_updateUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile)
{
- $args = new \Airavata\API\Airavata_deleteWorkflow_args();
+ $args = new \Airavata\API\Airavata_updateUserResourceProfile_args();
$args->authzToken = $authzToken;
- $args->workflowTemplateId = $workflowTemplateId;
+ $args->userId = $userId;
+ $args->userResourceProfile = $userResourceProfile;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'deleteWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'updateUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('deleteWorkflow', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('updateUserResourceProfile', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_deleteWorkflow()
+ public function recv_updateUserResourceProfile()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteWorkflow_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserResourceProfile_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -11983,10 +12315,13 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_deleteWorkflow_result();
+ $result = new \Airavata\API\Airavata_updateUserResourceProfile_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -11999,39 +12334,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- return;
+ throw new \Exception("updateUserResourceProfile failed: unknown result");
}
- public function registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow)
+ public function deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId)
{
- $this->send_registerWorkflow($authzToken, $gatewayId, $workflow);
- return $this->recv_registerWorkflow();
+ $this->send_deleteUserResourceProfile($authzToken, $userId);
+ return $this->recv_deleteUserResourceProfile();
}
- public function send_registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow)
+ public function send_deleteUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId)
{
- $args = new \Airavata\API\Airavata_registerWorkflow_args();
+ $args = new \Airavata\API\Airavata_deleteUserResourceProfile_args();
$args->authzToken = $authzToken;
- $args->gatewayId = $gatewayId;
- $args->workflow = $workflow;
+ $args->userId = $userId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'registerWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'deleteUserResourceProfile', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('registerWorkflow', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('deleteUserResourceProfile', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_registerWorkflow()
+ public function recv_deleteUserResourceProfile()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerWorkflow_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserResourceProfile_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12045,7 +12379,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_registerWorkflow_result();
+ $result = new \Airavata\API\Airavata_deleteUserResourceProfile_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12064,39 +12398,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("registerWorkflow failed: unknown result");
+ throw new \Exception("deleteUserResourceProfile failed: unknown result");
}
- public function updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow)
+ public function addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference)
{
- $this->send_updateWorkflow($authzToken, $workflowTemplateId, $workflow);
- $this->recv_updateWorkflow();
+ $this->send_addUserComputeResourcePreference($authzToken, $userId, $computeResourceId, $computeResourcePreference);
+ return $this->recv_addUserComputeResourcePreference();
}
- public function send_updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow)
+ public function send_addUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference)
{
- $args = new \Airavata\API\Airavata_updateWorkflow_args();
+ $args = new \Airavata\API\Airavata_addUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->workflowTemplateId = $workflowTemplateId;
- $args->workflow = $workflow;
+ $args->userId = $userId;
+ $args->computeResourceId = $computeResourceId;
+ $args->computeResourcePreference = $computeResourcePreference;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'updateWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'addUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('updateWorkflow', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('addUserComputeResourcePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_updateWorkflow()
+ public function recv_addUserComputeResourcePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateWorkflow_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_addUserComputeResourcePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12110,10 +12445,13 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_updateWorkflow_result();
+ $result = new \Airavata\API\Airavata_addUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -12126,38 +12464,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- return;
+ throw new \Exception("addUserComputeResourcePreference failed: unknown result");
}
- public function getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference)
{
- $this->send_getWorkflowTemplateId($authzToken, $workflowName);
- return $this->recv_getWorkflowTemplateId();
+ $this->send_addUserStoragePreference($authzToken, $userId, $storageResourceId, $storagePreference);
+ return $this->recv_addUserStoragePreference();
}
- public function send_getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function send_addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference)
{
- $args = new \Airavata\API\Airavata_getWorkflowTemplateId_args();
+ $args = new \Airavata\API\Airavata_addUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->workflowName = $workflowName;
+ $args->userId = $userId;
+ $args->storageResourceId = $storageResourceId;
+ $args->storagePreference = $storagePreference;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getWorkflowTemplateId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'addUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getWorkflowTemplateId', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('addUserStoragePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getWorkflowTemplateId()
+ public function recv_addUserStoragePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflowTemplateId_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_addUserStoragePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12171,7 +12511,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getWorkflowTemplateId_result();
+ $result = new \Airavata\API\Airavata_addUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12190,38 +12530,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getWorkflowTemplateId failed: unknown result");
+ throw new \Exception("addUserStoragePreference failed: unknown result");
}
- public function isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId)
{
- $this->send_isWorkflowExistWithName($authzToken, $workflowName);
- return $this->recv_isWorkflowExistWithName();
+ $this->send_getUserComputeResourcePreference($authzToken, $userId, $computeResourceId);
+ return $this->recv_getUserComputeResourcePreference();
}
- public function send_isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function send_getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId)
{
- $args = new \Airavata\API\Airavata_isWorkflowExistWithName_args();
+ $args = new \Airavata\API\Airavata_getUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->workflowName = $workflowName;
+ $args->userId = $userId;
+ $args->computeResourceId = $computeResourceId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'isWorkflowExistWithName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('isWorkflowExistWithName', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getUserComputeResourcePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_isWorkflowExistWithName()
+ public function recv_getUserComputeResourcePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_isWorkflowExistWithName_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserComputeResourcePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12235,7 +12576,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_isWorkflowExistWithName_result();
+ $result = new \Airavata\API\Airavata_getUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12254,38 +12595,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("isWorkflowExistWithName failed: unknown result");
+ throw new \Exception("getUserComputeResourcePreference failed: unknown result");
}
- public function registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel)
+ public function getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId)
{
- $this->send_registerDataProduct($authzToken, $dataProductModel);
- return $this->recv_registerDataProduct();
+ $this->send_getUserStoragePreference($authzToken, $userId, $storageResourceId);
+ return $this->recv_getUserStoragePreference();
}
- public function send_registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel)
+ public function send_getUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageResourceId)
{
- $args = new \Airavata\API\Airavata_registerDataProduct_args();
+ $args = new \Airavata\API\Airavata_getUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->dataProductModel = $dataProductModel;
+ $args->userId = $userId;
+ $args->storageResourceId = $storageResourceId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'registerDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('registerDataProduct', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getUserStoragePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_registerDataProduct()
+ public function recv_getUserStoragePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerDataProduct_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserStoragePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12299,7 +12641,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_registerDataProduct_result();
+ $result = new \Airavata\API\Airavata_getUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12318,38 +12660,37 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("registerDataProduct failed: unknown result");
+ throw new \Exception("getUserStoragePreference failed: unknown result");
}
- public function getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri)
+ public function getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken)
{
- $this->send_getDataProduct($authzToken, $dataProductUri);
- return $this->recv_getDataProduct();
+ $this->send_getAllUserResourceProfiles($authzToken);
+ return $this->recv_getAllUserResourceProfiles();
}
- public function send_getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri)
+ public function send_getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken)
{
- $args = new \Airavata\API\Airavata_getDataProduct_args();
+ $args = new \Airavata\API\Airavata_getAllUserResourceProfiles_args();
$args->authzToken = $authzToken;
- $args->dataProductUri = $dataProductUri;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getAllUserResourceProfiles', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getDataProduct', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getAllUserResourceProfiles', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getDataProduct()
+ public function recv_getAllUserResourceProfiles()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getDataProduct_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllUserResourceProfiles_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12363,7 +12704,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getDataProduct_result();
+ $result = new \Airavata\API\Airavata_getAllUserResourceProfiles_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12382,38 +12723,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getDataProduct failed: unknown result");
+ throw new \Exception("getAllUserResourceProfiles failed: unknown result");
}
- public function registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ public function updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference)
{
- $this->send_registerReplicaLocation($authzToken, $replicaLocationModel);
- return $this->recv_registerReplicaLocation();
+ $this->send_updateUserComputeResourcePreference($authzToken, $userId, $computeResourceId, $computeResourcePreference);
+ return $this->recv_updateUserComputeResourcePreference();
}
- public function send_registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ public function send_updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\ComputeResourcePreference $computeResourcePreference)
{
- $args = new \Airavata\API\Airavata_registerReplicaLocation_args();
+ $args = new \Airavata\API\Airavata_updateUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->replicaLocationModel = $replicaLocationModel;
+ $args->userId = $userId;
+ $args->computeResourceId = $computeResourceId;
+ $args->computeResourcePreference = $computeResourcePreference;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'registerReplicaLocation', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'updateUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('registerReplicaLocation', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('updateUserComputeResourcePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_registerReplicaLocation()
+ public function recv_updateUserComputeResourcePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerReplicaLocation_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserComputeResourcePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12427,7 +12770,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_registerReplicaLocation_result();
+ $result = new \Airavata\API\Airavata_updateUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12446,38 +12789,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("registerReplicaLocation failed: unknown result");
+ throw new \Exception("updateUserComputeResourcePreference failed: unknown result");
}
- public function getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference)
{
- $this->send_getParentDataProduct($authzToken, $productUri);
- return $this->recv_getParentDataProduct();
+ $this->send_updateUserStoragePreference($authzToken, $userId, $storageId, $storagePreference);
+ return $this->recv_updateUserStoragePreference();
}
- public function send_getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function send_updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId, \Airavata\Model\AppCatalog\UserResourceProfile\StoragePreference $storagePreference)
{
- $args = new \Airavata\API\Airavata_getParentDataProduct_args();
+ $args = new \Airavata\API\Airavata_updateUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->productUri = $productUri;
+ $args->userId = $userId;
+ $args->storageId = $storageId;
+ $args->storagePreference = $storagePreference;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getParentDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'updateUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getParentDataProduct', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('updateUserStoragePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getParentDataProduct()
+ public function recv_updateUserStoragePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getParentDataProduct_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateUserStoragePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12491,7 +12836,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getParentDataProduct_result();
+ $result = new \Airavata\API\Airavata_updateUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12510,38 +12855,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getParentDataProduct failed: unknown result");
+ throw new \Exception("updateUserStoragePreference failed: unknown result");
}
- public function getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId)
{
- $this->send_getChildDataProducts($authzToken, $productUri);
- return $this->recv_getChildDataProducts();
+ $this->send_deleteUserComputeResourcePreference($authzToken, $userId, $computeResourceId);
+ return $this->recv_deleteUserComputeResourcePreference();
}
- public function send_getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function send_deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $computeResourceId)
{
- $args = new \Airavata\API\Airavata_getChildDataProducts_args();
+ $args = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->productUri = $productUri;
+ $args->userId = $userId;
+ $args->computeResourceId = $computeResourceId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getChildDataProducts', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'deleteUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getChildDataProducts', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('deleteUserComputeResourcePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getChildDataProducts()
+ public function recv_deleteUserComputeResourcePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getChildDataProducts_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserComputeResourcePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12555,7 +12901,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getChildDataProducts_result();
+ $result = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12574,40 +12920,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getChildDataProducts failed: unknown result");
+ throw new \Exception("deleteUserComputeResourcePreference failed: unknown result");
}
- public function shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId)
{
- $this->send_shareResourceWithUsers($authzToken, $resourceId, $resourceType, $userPermissionList);
- return $this->recv_shareResourceWithUsers();
+ $this->send_deleteUserStoragePreference($authzToken, $userId, $storageId);
+ return $this->recv_deleteUserStoragePreference();
}
- public function send_shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function send_deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $storageId)
{
- $args = new \Airavata\API\Airavata_shareResourceWithUsers_args();
+ $args = new \Airavata\API\Airavata_deleteUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->userPermissionList = $userPermissionList;
+ $args->userId = $userId;
+ $args->storageId = $storageId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'shareResourceWithUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'deleteUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('shareResourceWithUsers', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('deleteUserStoragePreference', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_shareResourceWithUsers()
+ public function recv_deleteUserStoragePreference()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_shareResourceWithUsers_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteUserStoragePreference_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12621,7 +12966,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_shareResourceWithUsers_result();
+ $result = new \Airavata\API\Airavata_deleteUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12640,40 +12985,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("shareResourceWithUsers failed: unknown result");
+ throw new \Exception("deleteUserStoragePreference failed: unknown result");
}
- public function revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
- $this->send_revokeSharingOfResourceFromUsers($authzToken, $resourceId, $resourceType, $userPermissionList);
- return $this->recv_revokeSharingOfResourceFromUsers();
+ $this->send_getAllWorkflows($authzToken, $gatewayId);
+ return $this->recv_getAllWorkflows();
}
- public function send_revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function send_getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
- $args = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_args();
+ $args = new \Airavata\API\Airavata_getAllWorkflows_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->userPermissionList = $userPermissionList;
+ $args->gatewayId = $gatewayId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'revokeSharingOfResourceFromUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getAllWorkflows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('revokeSharingOfResourceFromUsers', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getAllWorkflows', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_revokeSharingOfResourceFromUsers()
+ public function recv_getAllWorkflows()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_revokeSharingOfResourceFromUsers_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllWorkflows_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12687,7 +13030,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_result();
+ $result = new \Airavata\API\Airavata_getAllWorkflows_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12706,40 +13049,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("revokeSharingOfResourceFromUsers failed: unknown result");
+ throw new \Exception("getAllWorkflows failed: unknown result");
}
- public function getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType)
+ public function getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $this->send_getAllAccessibleUsers($authzToken, $resourceId, $resourceType, $permissionType);
- return $this->recv_getAllAccessibleUsers();
+ $this->send_getWorkflow($authzToken, $workflowTemplateId);
+ return $this->recv_getWorkflow();
}
- public function send_getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType)
+ public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $args = new \Airavata\API\Airavata_getAllAccessibleUsers_args();
+ $args = new \Airavata\API\Airavata_getWorkflow_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->permissionType = $permissionType;
+ $args->workflowTemplateId = $workflowTemplateId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getAllAccessibleUsers', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getAllAccessibleUsers', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getWorkflow', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getAllAccessibleUsers()
+ public function recv_getWorkflow()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllAccessibleUsers_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflow_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12753,7 +13094,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getAllAccessibleUsers_result();
+ $result = new \Airavata\API\Airavata_getWorkflow_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12772,38 +13113,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getAllAccessibleUsers failed: unknown result");
+ throw new \Exception("getWorkflow failed: unknown result");
}
- public function createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $this->send_createGroup($authzToken, $groupModel);
- return $this->recv_createGroup();
+ $this->send_deleteWorkflow($authzToken, $workflowTemplateId);
+ $this->recv_deleteWorkflow();
}
- public function send_createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function send_deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $args = new \Airavata\API\Airavata_createGroup_args();
+ $args = new \Airavata\API\Airavata_deleteWorkflow_args();
$args->authzToken = $authzToken;
- $args->groupModel = $groupModel;
+ $args->workflowTemplateId = $workflowTemplateId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'createGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'deleteWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('createGroup', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('deleteWorkflow', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_createGroup()
+ public function recv_deleteWorkflow()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_createGroup_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteWorkflow_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12817,13 +13158,10 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_createGroup_result();
+ $result = new \Airavata\API\Airavata_deleteWorkflow_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
- if ($result->success !== null) {
- return $result->success;
- }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -12836,38 +13174,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("createGroup failed: unknown result");
+ return;
}
- public function updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow)
{
- $this->send_updateGroup($authzToken, $groupModel);
- return $this->recv_updateGroup();
+ $this->send_registerWorkflow($authzToken, $gatewayId, $workflow);
+ return $this->recv_registerWorkflow();
}
- public function send_updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function send_registerWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\WorkflowModel $workflow)
{
- $args = new \Airavata\API\Airavata_updateGroup_args();
+ $args = new \Airavata\API\Airavata_registerWorkflow_args();
$args->authzToken = $authzToken;
- $args->groupModel = $groupModel;
+ $args->gatewayId = $gatewayId;
+ $args->workflow = $workflow;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'updateGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'registerWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('updateGroup', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('registerWorkflow', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_updateGroup()
+ public function recv_registerWorkflow()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateGroup_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerWorkflow_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12881,7 +13220,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_updateGroup_result();
+ $result = new \Airavata\API\Airavata_registerWorkflow_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12900,40 +13239,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("updateGroup failed: unknown result");
+ throw new \Exception("registerWorkflow failed: unknown result");
}
- public function deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId)
+ public function updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow)
{
- $this->send_deleteGroup($authzToken, $groupId, $ownerId, $gatewayId);
- return $this->recv_deleteGroup();
+ $this->send_updateWorkflow($authzToken, $workflowTemplateId, $workflow);
+ $this->recv_updateWorkflow();
}
- public function send_deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId)
+ public function send_updateWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId, \Airavata\Model\WorkflowModel $workflow)
{
- $args = new \Airavata\API\Airavata_deleteGroup_args();
+ $args = new \Airavata\API\Airavata_updateWorkflow_args();
$args->authzToken = $authzToken;
- $args->groupId = $groupId;
- $args->ownerId = $ownerId;
- $args->gatewayId = $gatewayId;
+ $args->workflowTemplateId = $workflowTemplateId;
+ $args->workflow = $workflow;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'deleteGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'updateWorkflow', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('deleteGroup', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('updateWorkflow', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_deleteGroup()
+ public function recv_updateWorkflow()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteGroup_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateWorkflow_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12947,13 +13285,10 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_deleteGroup_result();
+ $result = new \Airavata\API\Airavata_updateWorkflow_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
- if ($result->success !== null) {
- return $result->success;
- }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -12966,38 +13301,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("deleteGroup failed: unknown result");
+ return;
}
- public function getGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId)
+ public function getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
{
- $this->send_getGroup($authzToken, $groupId);
- return $this->recv_getGroup();
+ $this->send_getWorkflowTemplateId($authzToken, $workflowName);
+ return $this->recv_getWorkflowTemplateId();
}
- public function send_getGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId)
+ public function send_getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
{
- $args = new \Airavata\API\Airavata_getGroup_args();
+ $args = new \Airavata\API\Airavata_getWorkflowTemplateId_args();
$args->authzToken = $authzToken;
- $args->groupId = $groupId;
+ $args->workflowName = $workflowName;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getGroup', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'getWorkflowTemplateId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getGroup', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getWorkflowTemplateId', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getGroup()
+ public function recv_getWorkflowTemplateId()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getGroup_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getWorkflowTemplateId_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -13011,7 +13346,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getGroup_result();
+ $result = new \Airavata\API\Airavata_getWorkflowTemplateId_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -13030,39 +13365,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getGroup failed: unknown result");
+ throw new \Exception("getWorkflowTemplateId failed: unknown result");
}
- public function getAllGroupsUserBelongs(\Airavata\Model\Security\AuthzToken $authzToken, $userName, $gatewayId)
+ public function isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
{
- $this->send_getAllGroupsUserBelongs($authzToken, $userName, $gatewayId);
- return $this->recv_getAllGroupsUserBelongs();
+ $this->send_isWorkflowExistWithName($authzToken, $workflowName);
+ return $this->recv_isWorkflowExistWithName();
}
- public function send_getAllGroupsUserBelongs(\Airavata\Model\Security\AuthzToken $authzToken, $userName, $gatewayId)
+ public function send_isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
{
- $args = new \Airavata\API\Airavata_getAllGroupsUserBelongs_args();
+ $args = new \Airavata\API\Airavata_isWorkflowExistWithName_args();
$args->authzToken = $authzToken;
- $args->userName = $userName;
- $args->gatewayId = $gatewayId;
+ $args->workflowName = $workflowName;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'getAllGroupsUserBelongs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'isWorkflowExistWithName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getAllGroupsUserBelongs', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('isWorkflowExistWithName', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getAllGroupsUserBelongs()
+ public function recv_isWorkflowExistWithName()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllGroupsUserBelongs_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_isWorkflowExistWithName_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -13076,7 +13410,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getAllGroupsUserBelongs_result();
+ $result = new \Airavata\API\Airavata_isWorkflowExistWithName_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -13095,98 +13429,4423 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getAllGroupsUserBelongs failed: unknown result");
+ throw new \Exception("isWorkflowExistWithName failed: unknown result");
}
-}
-
-// HELPER FUNCTIONS AND STRUCTURES
+ public function registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel)
+ {
+ $this->send_registerDataProduct($authzToken, $dataProductModel);
+ return $this->recv_registerDataProduct();
+ }
-class Airavata_getAPIVersion_args {
- static $_TSPEC;
+ public function send_registerDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataProductModel $dataProductModel)
+ {
+ $args = new \Airavata\API\Airavata_registerDataProduct_args();
+ $args->authzToken = $authzToken;
+ $args->dataProductModel = $dataProductModel;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'registerDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('registerDataProduct', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
- /**
- * @var \Airavata\Model\Security\AuthzToken
- */
- public $authzToken = null;
+ public function recv_registerDataProduct()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerDataProduct_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'authzToken',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\Security\AuthzToken',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['authzToken'])) {
- $this->authzToken = $vals['authzToken'];
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
}
+ $result = new \Airavata\API\Airavata_registerDataProduct_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
}
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("registerDataProduct failed: unknown result");
}
- public function getName() {
- return 'Airavata_getAPIVersion_args';
+ public function getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri)
+ {
+ $this->send_getDataProduct($authzToken, $dataProductUri);
+ return $this->recv_getDataProduct();
}
- public function read($input)
+ public function send_getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri)
{
- $xfer = 0;
- $fname = null;
- $ftype = 0;
- $fid = 0;
- $xfer += $input->readStructBegin($fname);
- while (true)
+ $args = new \Airavata\API\Airavata_getDataProduct_args();
+ $args->authzToken = $authzToken;
+ $args->dataProductUri = $dataProductUri;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
{
- $xfer += $input->readFieldBegin($fname, $ftype, $fid);
- if ($ftype == TType::STOP) {
- break;
- }
- switch ($fid)
- {
- case 1:
- if ($ftype == TType::STRUCT) {
- $this->authzToken = new \Airavata\Model\Security\AuthzToken();
- $xfer += $this->authzToken->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
+ thrift_protocol_write_binary($this->output_, 'getDataProduct', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('Airavata_getAPIVersion_args');
- if ($this->authzToken !== null) {
- if (!is_object($this->authzToken)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1);
- $xfer += $this->authzToken->write($output);
- $xfer += $output->writeFieldEnd();
+ else
+ {
+ $this->output_->writeMessageBegin('getDataProduct', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
}
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
}
-}
+ public function recv_getDataProduct()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getDataProduct_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_getDataProduct_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ if ($result->ae !== null) {
+ throw $result->ae;
+ }
+ throw new \Exception("getDataProduct failed: unknown result");
+ }
+
+ public function registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ {
+ $this->send_registerReplicaLocation($authzToken, $replicaLocationModel);
+ return $this->recv_registerReplicaLocation();
+ }
+
+ public function send_registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ {
+ $args = new \Airavata\API\Airavata_registerReplicaLocation_args();
+ $args->authzToken = $authzToken;
+ $args->replicaLocationModel = $replicaLocationModel;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'registerReplicaLocation', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('registerReplicaLocation', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_registerReplicaLocation()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_registerReplicaLocation_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_registerReplicaLocation_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+
<TRUNCATED>