You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2016/10/28 16:45:58 UTC
[09/20] airavata-php-gateway git commit: AIRAVATA-2156 Updating
thrift stubs
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/4ffaa68a/app/libraries/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/API/Airavata.php b/app/libraries/Airavata/API/Airavata.php
index 0c6e126..7d5325a 100644
--- a/app/libraries/Airavata/API/Airavata.php
+++ b/app/libraries/Airavata/API/Airavata.php
@@ -269,6 +269,35 @@ interface AiravataIf {
*/
public function generateAndRegisterSSHKeys(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName);
/**
+ * Generate and Register SSH Key Pair with Airavata Credential Store.
+ *
+ * @param gatewayId
+ * The identifier for the requested Gateway.
+ *
+ * @param userName
+ * The User for which the credential should be registered. For community accounts, this user is the name of the
+ * community user name. For computational resources, this user name need not be the same user name on resoruces.
+ *
+ * @param description
+ * The description field for a credential type, all type of credential can have a description.
+ *
+ * @return airavataCredStoreToken
+ * An SSH Key pair is generated and stored in the credential store and associated with users or community account
+ * belonging to a Gateway.
+ *
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayId
+ * @param string $userName
+ * @param string $description
+ * @return string
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ */
+ public function generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description);
+ /**
* Generate and Register Username PWD Pair with Airavata Credential Store.
*
* @param gatewayId
@@ -345,6 +374,54 @@ interface AiravataIf {
*/
public function getAllGatewaySSHPubKeys(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId);
/**
+ *
+ * Get all Public Keys of the Gateway
+ *
+ * @param CredStoreToken
+ * Credential Store Token which you want to find the Public Key for.
+ *
+ * @param gatewayId
+ * This is the unique identifier of your gateway where the token and public key was generated from.
+ *
+ * @return publicKey
+ *
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayId
+ * @return \Airavata\Model\AppCatalog\CredetialSummary\CredentialSummary[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ */
+ public function getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId);
+ /**
+ *
+ * Get all Public Key summaries for user in a Gateway
+ *
+ * @param CredStoreToken
+ * Credential Store Token which you want to find the Public Key for.
+ *
+ * @param gatewayId
+ * This is the unique identifier of your gateway where the token and public key was generated from.
+ *
+ * @param userId
+ * This is the unique identifier of user whose public keys are to be fetched.
+ *
+ * @return CredentialSummary
+ *
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $gatewayId
+ * @param string $userId
+ * @return \Airavata\Model\AppCatalog\CredetialSummary\CredentialSummary[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ */
+ public function getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId);
+ /**
* @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $gatewayId
* @return array
@@ -3229,12 +3306,428 @@ 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 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.
*
* @param gatewayID
- * The identifier of the gateway profile to be deleted.
+ * The identifier to link a gateway for the requested user resource profile.
*
- * @param storageId
+ * @return UserResourceProfile
+ * User Resource Profile Object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile User Resource Profile
+ *
+ * userId:
+ * Unique identifier used to link user to corresponding user data model
+ *
+ * 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:
+ *
+ * isNull:
+ * Indicates that this instance is just a container for a null value.
+ *
+ *
+ * @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, $gatewayID);
+ /**
+ * Update a User Resource Profile.
+ *
+ * @param userId
+ * The identifier for the requested user resource to be updated.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @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 string $gatewayID
+ * @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, $gatewayID, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile);
+ /**
+ * Delete the given User Resource Profile.
+ *
+ * @param userId
+ * The identifier for the requested user resource to be deleted.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @return status
+ * Returns a success/failure of the deletion.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @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, $gatewayID);
+ /**
+ * Add a Compute Resource Preference to a registered User profile.
+ *
+ * @param userId
+ * The identifier for the User resource profile to be added.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @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 $gatewayID
+ * @param string $userComputeResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference
+ * @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, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference);
+ /**
+ * Add a Storage Resource Preference to a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to be added.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @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 $gatewayID
+ * @param string $userStorageResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference
+ * @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, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference);
+ /**
+ *
+ * Fetch a Compute Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier for the user profile to be requested
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userComputeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @return computeResourcePreference
+ * Returns the ComputeResourcePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @param string $userComputeResourceId
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference User 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, $gatewayID, $userComputeResourceId);
+ /**
+ *
+ * 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 gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userStorageResourceId
+ * Identifier of the Stprage Preference required to be fetched.
+ *
+ * @return UserStoragePreference
+ * Returns the StoragePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @param string $userStorageResourceId
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference
+ * @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, $gatewayID, $userStorageResourceId);
+ /**
+ *
+ * Fetch all Compute Resource Preferences of a registered gateway profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to request to fetch the particular storage resource preference.
+ *
+ * @param gatewayID
+ * The identifier for the gateway profile to be requested
+ *
+ * @return computeResourcePreference
+ * Returns the ComputeResourcePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID);
+ /**
+ * Fetch all User Storage Resource Preferences of a registered user profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to request to fetch the particular storage resource preference.
+ *
+ * @param gatewayID
+ * The identifier for the gateway profile to be requested
+ *
+ * @return StoragePreference
+ * Returns the StoragePreference object.
+ *
+ *
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @return \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference[]
+ * @throws \Airavata\API\Error\InvalidRequestException
+ * @throws \Airavata\API\Error\AiravataClientException
+ * @throws \Airavata\API\Error\AiravataSystemException
+ * @throws \Airavata\API\Error\AuthorizationException
+ */
+ public function getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID);
+ /**
+ *
+ * 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 gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userComputeResourceId
+ * Preferences related to a particular compute resource
+ *
+ * @param userComputeResourcePreference
+ * 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 $gatewayID
+ * @param string $userComputeResourceId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference
+ * @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, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference);
+ /**
+ * Update a Storage Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user resource profile to be updated.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userStorageId
+ * The Storage resource identifier of the one that you want to update
+ *
+ * @param userStoragePreference
+ * 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 $gatewayID
+ * @param string $userStorageId
+ * @param \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference
+ * @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, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference);
+ /**
+ * Delete the Compute Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier for the user resource profile to be deleted.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userComputeResourceId
+ * 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 $gatewayID
+ * @param string $userComputeResourceId
+ * @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, $gatewayID, $userComputeResourceId);
+ /**
+ * Delete the Storage Resource Preference of a registered user resource profile.
+ *
+ * @param userId
+ * The identifier of the user profile to be deleted.
+ *
+ * @param gatewayID
+ * The identifier to link a gateway for the requested user resource profile.
+ *
+ * @param userStorageId
* ID of the storage preference you want to delete.
*
* @return status
@@ -3242,6 +3735,18 @@ interface AiravataIf {
*
*
* @param \Airavata\Model\Security\AuthzToken $authzToken
+ * @param string $userId
+ * @param string $gatewayID
+ * @param string $userStorageId
+ * @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, $gatewayID, $userStorageId);
+ /**
+ * @param \Airavata\Model\Security\AuthzToken $authzToken
* @param string $gatewayId
* @return string[]
* @throws \Airavata\API\Error\InvalidRequestException
@@ -4432,6 +4937,69 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("generateAndRegisterSSHKeys failed: unknown result");
}
+ public function generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description)
+ {
+ $this->send_generateAndRegisterSSHKeysWithDescription($authzToken, $gatewayId, $userName, $description);
+ return $this->recv_generateAndRegisterSSHKeysWithDescription();
+ }
+
+ public function send_generateAndRegisterSSHKeysWithDescription(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description)
+ {
+ $args = new \Airavata\API\Airavata_generateAndRegisterSSHKeysWithDescription_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayId = $gatewayId;
+ $args->userName = $userName;
+ $args->description = $description;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'generateAndRegisterSSHKeysWithDescription', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('generateAndRegisterSSHKeysWithDescription', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_generateAndRegisterSSHKeysWithDescription()
+ {
+ $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_generateAndRegisterSSHKeysWithDescription_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_generateAndRegisterSSHKeysWithDescription_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;
+ }
+ throw new \Exception("generateAndRegisterSSHKeysWithDescription failed: unknown result");
+ }
+
public function registerPwdCredential(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $portalUserName, $loginUserName, $password, $description)
{
$this->send_registerPwdCredential($authzToken, $gatewayId, $portalUserName, $loginUserName, $password, $description);
@@ -4620,6 +5188,129 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("getAllGatewaySSHPubKeys failed: unknown result");
}
+ public function getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
+ {
+ $this->send_getAllGatewaySSHPubKeysSummary($authzToken, $gatewayId);
+ return $this->recv_getAllGatewaySSHPubKeysSummary();
+ }
+
+ public function send_getAllGatewaySSHPubKeysSummary(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
+ {
+ $args = new \Airavata\API\Airavata_getAllGatewaySSHPubKeysSummary_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayId = $gatewayId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAllGatewaySSHPubKeysSummary', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAllGatewaySSHPubKeysSummary', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAllGatewaySSHPubKeysSummary()
+ {
+ $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_getAllGatewaySSHPubKeysSummary_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_getAllGatewaySSHPubKeysSummary_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;
+ }
+ throw new \Exception("getAllGatewaySSHPubKeysSummary failed: unknown result");
+ }
+
+ public function getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId)
+ {
+ $this->send_getAllSSHPubKeysSummaryForUserInGateway($authzToken, $gatewayId, $userId);
+ return $this->recv_getAllSSHPubKeysSummaryForUserInGateway();
+ }
+
+ public function send_getAllSSHPubKeysSummaryForUserInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userId)
+ {
+ $args = new \Airavata\API\Airavata_getAllSSHPubKeysSummaryForUserInGateway_args();
+ $args->authzToken = $authzToken;
+ $args->gatewayId = $gatewayId;
+ $args->userId = $userId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getAllSSHPubKeysSummaryForUserInGateway', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getAllSSHPubKeysSummaryForUserInGateway', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getAllSSHPubKeysSummaryForUserInGateway()
+ {
+ $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_getAllSSHPubKeysSummaryForUserInGateway_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_getAllSSHPubKeysSummaryForUserInGateway_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;
+ }
+ throw new \Exception("getAllSSHPubKeysSummaryForUserInGateway failed: unknown result");
+ }
+
public function getAllGatewayPWDCredentials(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
$this->send_getAllGatewayPWDCredentials($authzToken, $gatewayId);
@@ -11813,35 +12504,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 +12546,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 +12565,39 @@ 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, $gatewayID)
{
- $this->send_getWorkflow($authzToken, $workflowTemplateId);
- return $this->recv_getWorkflow();
+ $this->send_getUserResourceProfile($authzToken, $userId, $gatewayID);
+ return $this->recv_getUserResourceProfile();
}
- public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
+ public function send_getUserResourceProfile(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID)
{
- $args = new \Airavata\API\Airavata_getWorkflow_args();
+ $args = new \Airavata\API\Airavata_getUserResourceProfile_args();
$args->authzToken = $authzToken;
- $args->workflowTemplateId = $workflowTemplateId;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
$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 +12611,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 +12630,40 @@ 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, $gatewayID, \Airavata\Model\AppCatalog\UserResourceProfile\UserResourceProfile $userResourceProfile)
{
- $this->send_deleteWorkflow($authzToken, $workflowTemplateId);
- $this->recv_deleteWorkflow();
+ $this->send_updateUserResourceProfile($authzToken, $userId, $gatewayID, $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, $gatewayID, \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->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_, '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 +12677,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 +12696,39 @@ 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, $gatewayID)
{
- $this->send_registerWorkflow($authzToken, $gatewayId, $workflow);
- return $this->recv_registerWorkflow();
+ $this->send_deleteUserResourceProfile($authzToken, $userId, $gatewayID);
+ 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, $gatewayID)
{
- $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;
+ $args->gatewayID = $gatewayID;
$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 +12742,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 +12761,41 @@ 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, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference)
{
- $this->send_updateWorkflow($authzToken, $workflowTemplateId, $workflow);
- $this->recv_updateWorkflow();
+ $this->send_addUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId, $userComputeResourcePreference);
+ 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, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference)
{
- $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->gatewayID = $gatewayID;
+ $args->userComputeResourceId = $userComputeResourceId;
+ $args->userComputeResourcePreference = $userComputeResourcePreference;
$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 +12809,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 +12828,41 @@ 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, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference)
{
- $this->send_getWorkflowTemplateId($authzToken, $workflowName);
- return $this->recv_getWorkflowTemplateId();
+ $this->send_addUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageResourceId, $userStoragePreference);
+ return $this->recv_addUserStoragePreference();
}
- public function send_getWorkflowTemplateId(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function send_addUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference)
{
- $args = new \Airavata\API\Airavata_getWorkflowTemplateId_args();
+ $args = new \Airavata\API\Airavata_addUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->workflowName = $workflowName;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userStorageResourceId = $userStorageResourceId;
+ $args->userStoragePreference = $userStoragePreference;
$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 +12876,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 +12895,40 @@ 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, $gatewayID, $userComputeResourceId)
{
- $this->send_isWorkflowExistWithName($authzToken, $workflowName);
- return $this->recv_isWorkflowExistWithName();
+ $this->send_getUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId);
+ return $this->recv_getUserComputeResourcePreference();
}
- public function send_isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName)
+ public function send_getUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId)
{
- $args = new \Airavata\API\Airavata_isWorkflowExistWithName_args();
+ $args = new \Airavata\API\Airavata_getUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->workflowName = $workflowName;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userComputeResourceId = $userComputeResourceId;
$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 +12942,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 +12961,40 @@ 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, $gatewayID, $userStorageResourceId)
{
- $this->send_registerDataProduct($authzToken, $dataProductModel);
- return $this->recv_registerDataProduct();
+ $this->send_getUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageResourceId);
+ 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, $gatewayID, $userStorageResourceId)
{
- $args = new \Airavata\API\Airavata_registerDataProduct_args();
+ $args = new \Airavata\API\Airavata_getUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->dataProductModel = $dataProductModel;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userStorageResourceId = $userStorageResourceId;
$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 +13008,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 +13027,39 @@ 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 getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID)
{
- $this->send_getDataProduct($authzToken, $dataProductUri);
- return $this->recv_getDataProduct();
+ $this->send_getAllUserComputeResourcePreferences($authzToken, $userId, $gatewayID);
+ return $this->recv_getAllUserComputeResourcePreferences();
}
- public function send_getDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $dataProductUri)
+ public function send_getAllUserComputeResourcePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID)
{
- $args = new \Airavata\API\Airavata_getDataProduct_args();
+ $args = new \Airavata\API\Airavata_getAllUserComputeResourcePreferences_args();
$args->authzToken = $authzToken;
- $args->dataProductUri = $dataProductUri;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
$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_, 'getAllUserComputeResourcePreferences', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getDataProduct', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getAllUserComputeResourcePreferences', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_getDataProduct()
+ public function recv_getAllUserComputeResourcePreferences()
{
$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_getAllUserComputeResourcePreferences_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12363,7 +13073,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getDataProduct_result();
+ $result = new \Airavata\API\Airavata_getAllUserComputeResourcePreferences_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12382,38 +13092,39 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getDataProduct failed: unknown result");
+ throw new \Exception("getAllUserComputeResourcePreferences failed: unknown result");
}
- public function registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ public function getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID)
{
- $this->send_registerReplicaLocation($authzToken, $replicaLocationModel);
- return $this->recv_registerReplicaLocation();
+ $this->send_getAllUserStoragePreferences($authzToken, $userId, $gatewayID);
+ return $this->recv_getAllUserStoragePreferences();
}
- public function send_registerReplicaLocation(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Replica\DataReplicaLocationModel $replicaLocationModel)
+ public function send_getAllUserStoragePreferences(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID)
{
- $args = new \Airavata\API\Airavata_registerReplicaLocation_args();
+ $args = new \Airavata\API\Airavata_getAllUserStoragePreferences_args();
$args->authzToken = $authzToken;
- $args->replicaLocationModel = $replicaLocationModel;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
$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_, 'getAllUserStoragePreferences', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('registerReplicaLocation', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('getAllUserStoragePreferences', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_registerReplicaLocation()
+ public function recv_getAllUserStoragePreferences()
{
$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_getAllUserStoragePreferences_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -12427,7 +13138,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_registerReplicaLocation_result();
+ $result = new \Airavata\API\Airavata_getAllUserStoragePreferences_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12446,38 +13157,37 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("registerReplicaLocation failed: unknown result");
+ throw new \Exception("getAllUserStoragePreferences failed: unknown result");
}
- public function getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken)
{
- $this->send_getParentDataProduct($authzToken, $productUri);
- return $this->recv_getParentDataProduct();
+ $this->send_getAllUserResourceProfiles($authzToken);
+ return $this->recv_getAllUserResourceProfiles();
}
- public function send_getParentDataProduct(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function send_getAllUserResourceProfiles(\Airavata\Model\Security\AuthzToken $authzToken)
{
- $args = new \Airavata\API\Airavata_getParentDataProduct_args();
+ $args = new \Airavata\API\Airavata_getAllUserResourceProfiles_args();
$args->authzToken = $authzToken;
- $args->productUri = $productUri;
$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_, 'getAllUserResourceProfiles', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getParentDataProduct', 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_getParentDataProduct()
+ 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_getParentDataProduct_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;
@@ -12491,7 +13201,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getParentDataProduct_result();
+ $result = new \Airavata\API\Airavata_getAllUserResourceProfiles_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12510,38 +13220,41 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getParentDataProduct failed: unknown result");
+ throw new \Exception("getAllUserResourceProfiles failed: unknown result");
}
- public function getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference)
{
- $this->send_getChildDataProducts($authzToken, $productUri);
- return $this->recv_getChildDataProducts();
+ $this->send_updateUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId, $userComputeResourcePreference);
+ return $this->recv_updateUserComputeResourcePreference();
}
- public function send_getChildDataProducts(\Airavata\Model\Security\AuthzToken $authzToken, $productUri)
+ public function send_updateUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId, \Airavata\Model\AppCatalog\UserResourceProfile\UserComputeResourcePreference $userComputeResourcePreference)
{
- $args = new \Airavata\API\Airavata_getChildDataProducts_args();
+ $args = new \Airavata\API\Airavata_updateUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->productUri = $productUri;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userComputeResourceId = $userComputeResourceId;
+ $args->userComputeResourcePreference = $userComputeResourcePreference;
$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_, 'updateUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getChildDataProducts', 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_getChildDataProducts()
+ 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_getChildDataProducts_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;
@@ -12555,7 +13268,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getChildDataProducts_result();
+ $result = new \Airavata\API\Airavata_updateUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12574,40 +13287,41 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getChildDataProducts failed: unknown result");
+ throw new \Exception("updateUserComputeResourcePreference failed: unknown result");
}
- public function shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference)
{
- $this->send_shareResourceWithUsers($authzToken, $resourceId, $resourceType, $userPermissionList);
- return $this->recv_shareResourceWithUsers();
+ $this->send_updateUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageId, $userStoragePreference);
+ return $this->recv_updateUserStoragePreference();
}
- public function send_shareResourceWithUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function send_updateUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId, \Airavata\Model\AppCatalog\UserResourceProfile\UserStoragePreference $userStoragePreference)
{
- $args = new \Airavata\API\Airavata_shareResourceWithUsers_args();
+ $args = new \Airavata\API\Airavata_updateUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->userPermissionList = $userPermissionList;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userStorageId = $userStorageId;
+ $args->userStoragePreference = $userStoragePreference;
$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_, 'updateUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('shareResourceWithUsers', 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_shareResourceWithUsers()
+ 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_shareResourceWithUsers_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;
@@ -12621,7 +13335,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_shareResourceWithUsers_result();
+ $result = new \Airavata\API\Airavata_updateUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12640,40 +13354,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("shareResourceWithUsers failed: unknown result");
+ throw new \Exception("updateUserStoragePreference failed: unknown result");
}
- public function revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId)
{
- $this->send_revokeSharingOfResourceFromUsers($authzToken, $resourceId, $resourceType, $userPermissionList);
- return $this->recv_revokeSharingOfResourceFromUsers();
+ $this->send_deleteUserComputeResourcePreference($authzToken, $userId, $gatewayID, $userComputeResourceId);
+ return $this->recv_deleteUserComputeResourcePreference();
}
- public function send_revokeSharingOfResourceFromUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, array $userPermissionList)
+ public function send_deleteUserComputeResourcePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userComputeResourceId)
{
- $args = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_args();
+ $args = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->userPermissionList = $userPermissionList;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userComputeResourceId = $userComputeResourceId;
$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_, 'deleteUserComputeResourcePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('revokeSharingOfResourceFromUsers', 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_revokeSharingOfResourceFromUsers()
+ 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_revokeSharingOfResourceFromUsers_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;
@@ -12687,7 +13401,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_revokeSharingOfResourceFromUsers_result();
+ $result = new \Airavata\API\Airavata_deleteUserComputeResourcePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12706,40 +13420,40 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("revokeSharingOfResourceFromUsers failed: unknown result");
+ throw new \Exception("deleteUserComputeResourcePreference failed: unknown result");
}
- public function getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType)
+ public function deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId)
{
- $this->send_getAllAccessibleUsers($authzToken, $resourceId, $resourceType, $permissionType);
- return $this->recv_getAllAccessibleUsers();
+ $this->send_deleteUserStoragePreference($authzToken, $userId, $gatewayID, $userStorageId);
+ return $this->recv_deleteUserStoragePreference();
}
- public function send_getAllAccessibleUsers(\Airavata\Model\Security\AuthzToken $authzToken, $resourceId, $resourceType, $permissionType)
+ public function send_deleteUserStoragePreference(\Airavata\Model\Security\AuthzToken $authzToken, $userId, $gatewayID, $userStorageId)
{
- $args = new \Airavata\API\Airavata_getAllAccessibleUsers_args();
+ $args = new \Airavata\API\Airavata_deleteUserStoragePreference_args();
$args->authzToken = $authzToken;
- $args->resourceId = $resourceId;
- $args->resourceType = $resourceType;
- $args->permissionType = $permissionType;
+ $args->userId = $userId;
+ $args->gatewayID = $gatewayID;
+ $args->userStorageId = $userStorageId;
$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_, 'deleteUserStoragePreference', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('getAllAccessibleUsers', 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_getAllAccessibleUsers()
+ 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_getAllAccessibleUsers_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;
@@ -12753,7 +13467,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_getAllAccessibleUsers_result();
+ $result = new \Airavata\API\Airavata_deleteUserStoragePreference_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12772,38 +13486,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("getAllAccessibleUsers failed: unknown result");
+ throw new \Exception("deleteUserStoragePreference failed: unknown result");
}
- public function createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
- $this->send_createGroup($authzToken, $groupModel);
- return $this->recv_createGroup();
+ $this->send_getAllWorkflows($authzToken, $gatewayId);
+ return $this->recv_getAllWorkflows();
}
- public function send_createGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function send_getAllWorkflows(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId)
{
- $args = new \Airavata\API\Airavata_createGroup_args();
+ $args = new \Airavata\API\Airavata_getAllWorkflows_args();
$args->authzToken = $authzToken;
- $args->groupModel = $groupModel;
+ $args->gatewayId = $gatewayId;
$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_, 'getAllWorkflows', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('createGroup', 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_createGroup()
+ 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_createGroup_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;
@@ -12817,7 +13531,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_createGroup_result();
+ $result = new \Airavata\API\Airavata_getAllWorkflows_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12836,38 +13550,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("createGroup failed: unknown result");
+ throw new \Exception("getAllWorkflows failed: unknown result");
}
- public function updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $this->send_updateGroup($authzToken, $groupModel);
- return $this->recv_updateGroup();
+ $this->send_getWorkflow($authzToken, $workflowTemplateId);
+ return $this->recv_getWorkflow();
}
- public function send_updateGroup(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Group\GroupModel $groupModel)
+ public function send_getWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $args = new \Airavata\API\Airavata_updateGroup_args();
+ $args = new \Airavata\API\Airavata_getWorkflow_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_, 'updateGroup', 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('updateGroup', 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_updateGroup()
+ 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_updateGroup_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;
@@ -12881,7 +13595,7 @@ class AiravataClient implements \Airavata\API\AiravataIf {
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \Airavata\API\Airavata_updateGroup_result();
+ $result = new \Airavata\API\Airavata_getWorkflow_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -12900,40 +13614,38 @@ class AiravataClient implements \Airavata\API\AiravataIf {
if ($result->ae !== null) {
throw $result->ae;
}
- throw new \Exception("updateGroup failed: unknown result");
+ throw new \Exception("getWorkflow failed: unknown result");
}
- public function deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId)
+ public function deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $this->send_deleteGroup($authzToken, $groupId, $ownerId, $gatewayId);
- return $this->recv_deleteGroup();
+ $this->send_deleteWorkflow($authzToken, $workflowTemplateId);
+ $this->recv_deleteWorkflow();
}
- public function send_deleteGroup(\Airavata\Model\Security\AuthzToken $authzToken, $groupId, $ownerId, $gatewayId)
+ public function send_deleteWorkflow(\Airavata\Model\Security\AuthzToken $authzToken, $workflowTemplateId)
{
- $args = new \Airavata\API\Airavata_deleteGroup_args();
+ $args = new \Airavata\API\Airavata_deleteWorkflow_args();
$args->authzToken = $authzToken;
- $args->groupId = $groupId;
- $args->ownerId = $ownerId;
- $args->gatewayId = $gatewayId;
+ $args->workflowTemplateId = $workflowTemplateId;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protoco
<TRUNCATED>