http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/cpi/CredentialStoreService.java ---------------------------------------------------------------------- diff --git a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/cpi/CredentialStoreService.java b/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/cpi/CredentialStoreService.java deleted file mode 100644 index 1686c76..0000000 --- a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/cpi/CredentialStoreService.java +++ /dev/null @@ -1,15458 +0,0 @@ - /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.airavata.credential.store.cpi; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") -public class CredentialStoreService { - - public interface Iface { - - /** - * Query CS server to fetch the CPI version - */ - public String getCSServiceVersion() throws org.apache.thrift.TException; - - /** - * This method is to add SSHCredential which will return the token Id in success - * - * - * @param sshCredential - */ - public String addSSHCredential(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public String addCertificateCredential(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public String addPasswordCredential(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public org.apache.airavata.credential.store.datamodel.SSHCredential getSSHCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public org.apache.airavata.credential.store.datamodel.SSHCredentialSummary getSSHCredentialSummary(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public org.apache.airavata.credential.store.datamodel.CertificateCredential getCertificateCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public org.apache.airavata.credential.store.datamodel.PasswordCredential getPasswordCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public Map<String,String> getAllSSHKeysForUser(String username) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public Map<String,String> getAllSSHKeysForGateway(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getAllGatewaySSHCredentialSummary(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getAllSSHCredentialSummaryForUserInGateway(String gatewayId, String userId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public Map<String,String> getAllPWDCredentialsForGateway(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public boolean deleteSSHCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - public boolean deletePWDCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException; - - } - - public interface AsyncIface { - - public void getCSServiceVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void addSSHCredential(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void addCertificateCredential(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void addPasswordCredential(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getSSHCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getSSHCredentialSummary(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getCertificateCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getPasswordCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllSSHKeysForUser(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllSSHKeysForGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllGatewaySSHCredentialSummary(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllSSHCredentialSummaryForUserInGateway(String gatewayId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllPWDCredentialsForGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deleteSSHCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deletePWDCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - } - - public static class Client extends org.apache.thrift.TServiceClient implements Iface { - public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { - public Factory() {} - public Client getClient(org.apache.thrift.protocol.TProtocol prot) { - return new Client(prot); - } - public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - return new Client(iprot, oprot); - } - } - - public Client(org.apache.thrift.protocol.TProtocol prot) - { - super(prot, prot); - } - - public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - super(iprot, oprot); - } - - public String getCSServiceVersion() throws org.apache.thrift.TException - { - send_getCSServiceVersion(); - return recv_getCSServiceVersion(); - } - - public void send_getCSServiceVersion() throws org.apache.thrift.TException - { - getCSServiceVersion_args args = new getCSServiceVersion_args(); - sendBase("getCSServiceVersion", args); - } - - public String recv_getCSServiceVersion() throws org.apache.thrift.TException - { - getCSServiceVersion_result result = new getCSServiceVersion_result(); - receiveBase(result, "getCSServiceVersion"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getCSServiceVersion failed: unknown result"); - } - - public String addSSHCredential(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_addSSHCredential(sshCredential); - return recv_addSSHCredential(); - } - - public void send_addSSHCredential(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential) throws org.apache.thrift.TException - { - addSSHCredential_args args = new addSSHCredential_args(); - args.setSshCredential(sshCredential); - sendBase("addSSHCredential", args); - } - - public String recv_addSSHCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - addSSHCredential_result result = new addSSHCredential_result(); - receiveBase(result, "addSSHCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addSSHCredential failed: unknown result"); - } - - public String addCertificateCredential(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_addCertificateCredential(certificateCredential); - return recv_addCertificateCredential(); - } - - public void send_addCertificateCredential(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential) throws org.apache.thrift.TException - { - addCertificateCredential_args args = new addCertificateCredential_args(); - args.setCertificateCredential(certificateCredential); - sendBase("addCertificateCredential", args); - } - - public String recv_addCertificateCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - addCertificateCredential_result result = new addCertificateCredential_result(); - receiveBase(result, "addCertificateCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addCertificateCredential failed: unknown result"); - } - - public String addPasswordCredential(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_addPasswordCredential(passwordCredential); - return recv_addPasswordCredential(); - } - - public void send_addPasswordCredential(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential) throws org.apache.thrift.TException - { - addPasswordCredential_args args = new addPasswordCredential_args(); - args.setPasswordCredential(passwordCredential); - sendBase("addPasswordCredential", args); - } - - public String recv_addPasswordCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - addPasswordCredential_result result = new addPasswordCredential_result(); - receiveBase(result, "addPasswordCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addPasswordCredential failed: unknown result"); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredential getSSHCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getSSHCredential(tokenId, gatewayId); - return recv_getSSHCredential(); - } - - public void send_getSSHCredential(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - getSSHCredential_args args = new getSSHCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("getSSHCredential", args); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredential recv_getSSHCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getSSHCredential_result result = new getSSHCredential_result(); - receiveBase(result, "getSSHCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHCredential failed: unknown result"); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredentialSummary getSSHCredentialSummary(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getSSHCredentialSummary(tokenId, gatewayId); - return recv_getSSHCredentialSummary(); - } - - public void send_getSSHCredentialSummary(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - getSSHCredentialSummary_args args = new getSSHCredentialSummary_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("getSSHCredentialSummary", args); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredentialSummary recv_getSSHCredentialSummary() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getSSHCredentialSummary_result result = new getSSHCredentialSummary_result(); - receiveBase(result, "getSSHCredentialSummary"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHCredentialSummary failed: unknown result"); - } - - public org.apache.airavata.credential.store.datamodel.CertificateCredential getCertificateCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getCertificateCredential(tokenId, gatewayId); - return recv_getCertificateCredential(); - } - - public void send_getCertificateCredential(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - getCertificateCredential_args args = new getCertificateCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("getCertificateCredential", args); - } - - public org.apache.airavata.credential.store.datamodel.CertificateCredential recv_getCertificateCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getCertificateCredential_result result = new getCertificateCredential_result(); - receiveBase(result, "getCertificateCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getCertificateCredential failed: unknown result"); - } - - public org.apache.airavata.credential.store.datamodel.PasswordCredential getPasswordCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getPasswordCredential(tokenId, gatewayId); - return recv_getPasswordCredential(); - } - - public void send_getPasswordCredential(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - getPasswordCredential_args args = new getPasswordCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("getPasswordCredential", args); - } - - public org.apache.airavata.credential.store.datamodel.PasswordCredential recv_getPasswordCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getPasswordCredential_result result = new getPasswordCredential_result(); - receiveBase(result, "getPasswordCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPasswordCredential failed: unknown result"); - } - - public Map<String,String> getAllSSHKeysForUser(String username) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getAllSSHKeysForUser(username); - return recv_getAllSSHKeysForUser(); - } - - public void send_getAllSSHKeysForUser(String username) throws org.apache.thrift.TException - { - getAllSSHKeysForUser_args args = new getAllSSHKeysForUser_args(); - args.setUsername(username); - sendBase("getAllSSHKeysForUser", args); - } - - public Map<String,String> recv_getAllSSHKeysForUser() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getAllSSHKeysForUser_result result = new getAllSSHKeysForUser_result(); - receiveBase(result, "getAllSSHKeysForUser"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllSSHKeysForUser failed: unknown result"); - } - - public Map<String,String> getAllSSHKeysForGateway(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getAllSSHKeysForGateway(gatewayId); - return recv_getAllSSHKeysForGateway(); - } - - public void send_getAllSSHKeysForGateway(String gatewayId) throws org.apache.thrift.TException - { - getAllSSHKeysForGateway_args args = new getAllSSHKeysForGateway_args(); - args.setGatewayId(gatewayId); - sendBase("getAllSSHKeysForGateway", args); - } - - public Map<String,String> recv_getAllSSHKeysForGateway() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getAllSSHKeysForGateway_result result = new getAllSSHKeysForGateway_result(); - receiveBase(result, "getAllSSHKeysForGateway"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllSSHKeysForGateway failed: unknown result"); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getAllGatewaySSHCredentialSummary(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getAllGatewaySSHCredentialSummary(gatewayId); - return recv_getAllGatewaySSHCredentialSummary(); - } - - public void send_getAllGatewaySSHCredentialSummary(String gatewayId) throws org.apache.thrift.TException - { - getAllGatewaySSHCredentialSummary_args args = new getAllGatewaySSHCredentialSummary_args(); - args.setGatewayId(gatewayId); - sendBase("getAllGatewaySSHCredentialSummary", args); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> recv_getAllGatewaySSHCredentialSummary() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getAllGatewaySSHCredentialSummary_result result = new getAllGatewaySSHCredentialSummary_result(); - receiveBase(result, "getAllGatewaySSHCredentialSummary"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllGatewaySSHCredentialSummary failed: unknown result"); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getAllSSHCredentialSummaryForUserInGateway(String gatewayId, String userId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getAllSSHCredentialSummaryForUserInGateway(gatewayId, userId); - return recv_getAllSSHCredentialSummaryForUserInGateway(); - } - - public void send_getAllSSHCredentialSummaryForUserInGateway(String gatewayId, String userId) throws org.apache.thrift.TException - { - getAllSSHCredentialSummaryForUserInGateway_args args = new getAllSSHCredentialSummaryForUserInGateway_args(); - args.setGatewayId(gatewayId); - args.setUserId(userId); - sendBase("getAllSSHCredentialSummaryForUserInGateway", args); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> recv_getAllSSHCredentialSummaryForUserInGateway() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getAllSSHCredentialSummaryForUserInGateway_result result = new getAllSSHCredentialSummaryForUserInGateway_result(); - receiveBase(result, "getAllSSHCredentialSummaryForUserInGateway"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllSSHCredentialSummaryForUserInGateway failed: unknown result"); - } - - public Map<String,String> getAllPWDCredentialsForGateway(String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_getAllPWDCredentialsForGateway(gatewayId); - return recv_getAllPWDCredentialsForGateway(); - } - - public void send_getAllPWDCredentialsForGateway(String gatewayId) throws org.apache.thrift.TException - { - getAllPWDCredentialsForGateway_args args = new getAllPWDCredentialsForGateway_args(); - args.setGatewayId(gatewayId); - sendBase("getAllPWDCredentialsForGateway", args); - } - - public Map<String,String> recv_getAllPWDCredentialsForGateway() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - getAllPWDCredentialsForGateway_result result = new getAllPWDCredentialsForGateway_result(); - receiveBase(result, "getAllPWDCredentialsForGateway"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllPWDCredentialsForGateway failed: unknown result"); - } - - public boolean deleteSSHCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_deleteSSHCredential(tokenId, gatewayId); - return recv_deleteSSHCredential(); - } - - public void send_deleteSSHCredential(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - deleteSSHCredential_args args = new deleteSSHCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("deleteSSHCredential", args); - } - - public boolean recv_deleteSSHCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - deleteSSHCredential_result result = new deleteSSHCredential_result(); - receiveBase(result, "deleteSSHCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteSSHCredential failed: unknown result"); - } - - public boolean deletePWDCredential(String tokenId, String gatewayId) throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - send_deletePWDCredential(tokenId, gatewayId); - return recv_deletePWDCredential(); - } - - public void send_deletePWDCredential(String tokenId, String gatewayId) throws org.apache.thrift.TException - { - deletePWDCredential_args args = new deletePWDCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - sendBase("deletePWDCredential", args); - } - - public boolean recv_deletePWDCredential() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException - { - deletePWDCredential_result result = new deletePWDCredential_result(); - receiveBase(result, "deletePWDCredential"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.csException != null) { - throw result.csException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deletePWDCredential failed: unknown result"); - } - - } - public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { - public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { - private org.apache.thrift.async.TAsyncClientManager clientManager; - private org.apache.thrift.protocol.TProtocolFactory protocolFactory; - public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { - this.clientManager = clientManager; - this.protocolFactory = protocolFactory; - } - public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { - return new AsyncClient(protocolFactory, clientManager, transport); - } - } - - public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { - super(protocolFactory, clientManager, transport); - } - - public void getCSServiceVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getCSServiceVersion_call method_call = new getCSServiceVersion_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getCSServiceVersion_call extends org.apache.thrift.async.TAsyncMethodCall { - public getCSServiceVersion_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getCSServiceVersion", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getCSServiceVersion_args args = new getCSServiceVersion_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public String getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getCSServiceVersion(); - } - } - - public void addSSHCredential(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - addSSHCredential_call method_call = new addSSHCredential_call(sshCredential, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class addSSHCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential; - public addSSHCredential_call(org.apache.airavata.credential.store.datamodel.SSHCredential sshCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.sshCredential = sshCredential; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addSSHCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - addSSHCredential_args args = new addSSHCredential_args(); - args.setSshCredential(sshCredential); - args.write(prot); - prot.writeMessageEnd(); - } - - public String getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_addSSHCredential(); - } - } - - public void addCertificateCredential(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - addCertificateCredential_call method_call = new addCertificateCredential_call(certificateCredential, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class addCertificateCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential; - public addCertificateCredential_call(org.apache.airavata.credential.store.datamodel.CertificateCredential certificateCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.certificateCredential = certificateCredential; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addCertificateCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - addCertificateCredential_args args = new addCertificateCredential_args(); - args.setCertificateCredential(certificateCredential); - args.write(prot); - prot.writeMessageEnd(); - } - - public String getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_addCertificateCredential(); - } - } - - public void addPasswordCredential(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - addPasswordCredential_call method_call = new addPasswordCredential_call(passwordCredential, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class addPasswordCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential; - public addPasswordCredential_call(org.apache.airavata.credential.store.datamodel.PasswordCredential passwordCredential, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.passwordCredential = passwordCredential; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addPasswordCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - addPasswordCredential_args args = new addPasswordCredential_args(); - args.setPasswordCredential(passwordCredential); - args.write(prot); - prot.writeMessageEnd(); - } - - public String getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_addPasswordCredential(); - } - } - - public void getSSHCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getSSHCredential_call method_call = new getSSHCredential_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getSSHCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public getSSHCredential_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSSHCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getSSHCredential_args args = new getSSHCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredential getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getSSHCredential(); - } - } - - public void getSSHCredentialSummary(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getSSHCredentialSummary_call method_call = new getSSHCredentialSummary_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getSSHCredentialSummary_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public getSSHCredentialSummary_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSSHCredentialSummary", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getSSHCredentialSummary_args args = new getSSHCredentialSummary_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.credential.store.datamodel.SSHCredentialSummary getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getSSHCredentialSummary(); - } - } - - public void getCertificateCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getCertificateCredential_call method_call = new getCertificateCredential_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getCertificateCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public getCertificateCredential_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getCertificateCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getCertificateCredential_args args = new getCertificateCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.credential.store.datamodel.CertificateCredential getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getCertificateCredential(); - } - } - - public void getPasswordCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getPasswordCredential_call method_call = new getPasswordCredential_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getPasswordCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public getPasswordCredential_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getPasswordCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getPasswordCredential_args args = new getPasswordCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.credential.store.datamodel.PasswordCredential getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getPasswordCredential(); - } - } - - public void getAllSSHKeysForUser(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllSSHKeysForUser_call method_call = new getAllSSHKeysForUser_call(username, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllSSHKeysForUser_call extends org.apache.thrift.async.TAsyncMethodCall { - private String username; - public getAllSSHKeysForUser_call(String username, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.username = username; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllSSHKeysForUser", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllSSHKeysForUser_args args = new getAllSSHKeysForUser_args(); - args.setUsername(username); - args.write(prot); - prot.writeMessageEnd(); - } - - public Map<String,String> getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllSSHKeysForUser(); - } - } - - public void getAllSSHKeysForGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllSSHKeysForGateway_call method_call = new getAllSSHKeysForGateway_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllSSHKeysForGateway_call extends org.apache.thrift.async.TAsyncMethodCall { - private String gatewayId; - public getAllSSHKeysForGateway_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllSSHKeysForGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllSSHKeysForGateway_args args = new getAllSSHKeysForGateway_args(); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public Map<String,String> getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllSSHKeysForGateway(); - } - } - - public void getAllGatewaySSHCredentialSummary(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllGatewaySSHCredentialSummary_call method_call = new getAllGatewaySSHCredentialSummary_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllGatewaySSHCredentialSummary_call extends org.apache.thrift.async.TAsyncMethodCall { - private String gatewayId; - public getAllGatewaySSHCredentialSummary_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllGatewaySSHCredentialSummary", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllGatewaySSHCredentialSummary_args args = new getAllGatewaySSHCredentialSummary_args(); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllGatewaySSHCredentialSummary(); - } - } - - public void getAllSSHCredentialSummaryForUserInGateway(String gatewayId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllSSHCredentialSummaryForUserInGateway_call method_call = new getAllSSHCredentialSummaryForUserInGateway_call(gatewayId, userId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllSSHCredentialSummaryForUserInGateway_call extends org.apache.thrift.async.TAsyncMethodCall { - private String gatewayId; - private String userId; - public getAllSSHCredentialSummaryForUserInGateway_call(String gatewayId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.gatewayId = gatewayId; - this.userId = userId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllSSHCredentialSummaryForUserInGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllSSHCredentialSummaryForUserInGateway_args args = new getAllSSHCredentialSummaryForUserInGateway_args(); - args.setGatewayId(gatewayId); - args.setUserId(userId); - args.write(prot); - prot.writeMessageEnd(); - } - - public List<org.apache.airavata.credential.store.datamodel.SSHCredentialSummary> getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllSSHCredentialSummaryForUserInGateway(); - } - } - - public void getAllPWDCredentialsForGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllPWDCredentialsForGateway_call method_call = new getAllPWDCredentialsForGateway_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllPWDCredentialsForGateway_call extends org.apache.thrift.async.TAsyncMethodCall { - private String gatewayId; - public getAllPWDCredentialsForGateway_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllPWDCredentialsForGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllPWDCredentialsForGateway_args args = new getAllPWDCredentialsForGateway_args(); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public Map<String,String> getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllPWDCredentialsForGateway(); - } - } - - public void deleteSSHCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - deleteSSHCredential_call method_call = new deleteSSHCredential_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class deleteSSHCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public deleteSSHCredential_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteSSHCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - deleteSSHCredential_args args = new deleteSSHCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public boolean getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_deleteSSHCredential(); - } - } - - public void deletePWDCredential(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - deletePWDCredential_call method_call = new deletePWDCredential_call(tokenId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class deletePWDCredential_call extends org.apache.thrift.async.TAsyncMethodCall { - private String tokenId; - private String gatewayId; - public deletePWDCredential_call(String tokenId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.tokenId = tokenId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deletePWDCredential", org.apache.thrift.protocol.TMessageType.CALL, 0)); - deletePWDCredential_args args = new deletePWDCredential_args(); - args.setTokenId(tokenId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public boolean getResult() throws org.apache.airavata.credential.store.exception.CredentialStoreException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_deletePWDCredential(); - } - } - - } - - public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { - private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); - } - - protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - processMap.put("getCSServiceVersion", new getCSServiceVersion()); - processMap.put("addSSHCredential", new addSSHCredential()); - processMap.put("addCertificateCredential", new addCertificateCredential()); - processMap.put("addPasswordCredential", new addPasswordCredential()); - processMap.put("getSSHCredential", new getSSHCredential()); - processMap.put("getSSHCredentialSummary", new getSSHCredentialSummary()); - processMap.put("getCertificateCredential", new getCertificateCredential()); - processMap.put("getPasswordCredential", new getPasswordCredential()); - processMap.put("getAllSSHKeysForUser", new getAllSSHKeysForUser()); - processMap.put("getAllSSHKeysForGateway", new getAllSSHKeysForGateway()); - processMap.put("getAllGatewaySSHCredentialSummary", new getAllGatewaySSHCredentialSummary()); - processMap.put("getAllSSHCredentialSummaryForUserInGateway", new getAllSSHCredentialSummaryForUserInGateway()); - processMap.put("getAllPWDCredentialsForGateway", new getAllPWDCredentialsForGateway()); - processMap.put("deleteSSHCredential", new deleteSSHCredential()); - processMap.put("deletePWDCredential", new deletePWDCredential()); - return processMap; - } - - public static class getCSServiceVersion<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getCSServiceVersion_args> { - public getCSServiceVersion() { - super("getCSServiceVersion"); - } - - public getCSServiceVersion_args getEmptyArgsInstance() { - return new getCSServiceVersion_args(); - } - - protected boolean isOneway() { - return false; - } - - public getCSServiceVersion_result getResult(I iface, getCSServiceVersion_args args) throws org.apache.thrift.TException { - getCSServiceVersion_result result = new getCSServiceVersion_result(); - result.success = iface.getCSServiceVersion(); - return result; - } - } - - public static class addSSHCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addSSHCredential_args> { - public addSSHCredential() { - super("addSSHCredential"); - } - - public addSSHCredential_args getEmptyArgsInstance() { - return new addSSHCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public addSSHCredential_result getResult(I iface, addSSHCredential_args args) throws org.apache.thrift.TException { - addSSHCredential_result result = new addSSHCredential_result(); - try { - result.success = iface.addSSHCredential(args.sshCredential); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class addCertificateCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addCertificateCredential_args> { - public addCertificateCredential() { - super("addCertificateCredential"); - } - - public addCertificateCredential_args getEmptyArgsInstance() { - return new addCertificateCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public addCertificateCredential_result getResult(I iface, addCertificateCredential_args args) throws org.apache.thrift.TException { - addCertificateCredential_result result = new addCertificateCredential_result(); - try { - result.success = iface.addCertificateCredential(args.certificateCredential); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class addPasswordCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addPasswordCredential_args> { - public addPasswordCredential() { - super("addPasswordCredential"); - } - - public addPasswordCredential_args getEmptyArgsInstance() { - return new addPasswordCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public addPasswordCredential_result getResult(I iface, addPasswordCredential_args args) throws org.apache.thrift.TException { - addPasswordCredential_result result = new addPasswordCredential_result(); - try { - result.success = iface.addPasswordCredential(args.passwordCredential); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getSSHCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHCredential_args> { - public getSSHCredential() { - super("getSSHCredential"); - } - - public getSSHCredential_args getEmptyArgsInstance() { - return new getSSHCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public getSSHCredential_result getResult(I iface, getSSHCredential_args args) throws org.apache.thrift.TException { - getSSHCredential_result result = new getSSHCredential_result(); - try { - result.success = iface.getSSHCredential(args.tokenId, args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getSSHCredentialSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSSHCredentialSummary_args> { - public getSSHCredentialSummary() { - super("getSSHCredentialSummary"); - } - - public getSSHCredentialSummary_args getEmptyArgsInstance() { - return new getSSHCredentialSummary_args(); - } - - protected boolean isOneway() { - return false; - } - - public getSSHCredentialSummary_result getResult(I iface, getSSHCredentialSummary_args args) throws org.apache.thrift.TException { - getSSHCredentialSummary_result result = new getSSHCredentialSummary_result(); - try { - result.success = iface.getSSHCredentialSummary(args.tokenId, args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getCertificateCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getCertificateCredential_args> { - public getCertificateCredential() { - super("getCertificateCredential"); - } - - public getCertificateCredential_args getEmptyArgsInstance() { - return new getCertificateCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public getCertificateCredential_result getResult(I iface, getCertificateCredential_args args) throws org.apache.thrift.TException { - getCertificateCredential_result result = new getCertificateCredential_result(); - try { - result.success = iface.getCertificateCredential(args.tokenId, args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getPasswordCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getPasswordCredential_args> { - public getPasswordCredential() { - super("getPasswordCredential"); - } - - public getPasswordCredential_args getEmptyArgsInstance() { - return new getPasswordCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public getPasswordCredential_result getResult(I iface, getPasswordCredential_args args) throws org.apache.thrift.TException { - getPasswordCredential_result result = new getPasswordCredential_result(); - try { - result.success = iface.getPasswordCredential(args.tokenId, args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getAllSSHKeysForUser<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllSSHKeysForUser_args> { - public getAllSSHKeysForUser() { - super("getAllSSHKeysForUser"); - } - - public getAllSSHKeysForUser_args getEmptyArgsInstance() { - return new getAllSSHKeysForUser_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllSSHKeysForUser_result getResult(I iface, getAllSSHKeysForUser_args args) throws org.apache.thrift.TException { - getAllSSHKeysForUser_result result = new getAllSSHKeysForUser_result(); - try { - result.success = iface.getAllSSHKeysForUser(args.username); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getAllSSHKeysForGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllSSHKeysForGateway_args> { - public getAllSSHKeysForGateway() { - super("getAllSSHKeysForGateway"); - } - - public getAllSSHKeysForGateway_args getEmptyArgsInstance() { - return new getAllSSHKeysForGateway_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllSSHKeysForGateway_result getResult(I iface, getAllSSHKeysForGateway_args args) throws org.apache.thrift.TException { - getAllSSHKeysForGateway_result result = new getAllSSHKeysForGateway_result(); - try { - result.success = iface.getAllSSHKeysForGateway(args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getAllGatewaySSHCredentialSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewaySSHCredentialSummary_args> { - public getAllGatewaySSHCredentialSummary() { - super("getAllGatewaySSHCredentialSummary"); - } - - public getAllGatewaySSHCredentialSummary_args getEmptyArgsInstance() { - return new getAllGatewaySSHCredentialSummary_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllGatewaySSHCredentialSummary_result getResult(I iface, getAllGatewaySSHCredentialSummary_args args) throws org.apache.thrift.TException { - getAllGatewaySSHCredentialSummary_result result = new getAllGatewaySSHCredentialSummary_result(); - try { - result.success = iface.getAllGatewaySSHCredentialSummary(args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getAllSSHCredentialSummaryForUserInGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllSSHCredentialSummaryForUserInGateway_args> { - public getAllSSHCredentialSummaryForUserInGateway() { - super("getAllSSHCredentialSummaryForUserInGateway"); - } - - public getAllSSHCredentialSummaryForUserInGateway_args getEmptyArgsInstance() { - return new getAllSSHCredentialSummaryForUserInGateway_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllSSHCredentialSummaryForUserInGateway_result getResult(I iface, getAllSSHCredentialSummaryForUserInGateway_args args) throws org.apache.thrift.TException { - getAllSSHCredentialSummaryForUserInGateway_result result = new getAllSSHCredentialSummaryForUserInGateway_result(); - try { - result.success = iface.getAllSSHCredentialSummaryForUserInGateway(args.gatewayId, args.userId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class getAllPWDCredentialsForGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllPWDCredentialsForGateway_args> { - public getAllPWDCredentialsForGateway() { - super("getAllPWDCredentialsForGateway"); - } - - public getAllPWDCredentialsForGateway_args getEmptyArgsInstance() { - return new getAllPWDCredentialsForGateway_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllPWDCredentialsForGateway_result getResult(I iface, getAllPWDCredentialsForGateway_args args) throws org.apache.thrift.TException { - getAllPWDCredentialsForGateway_result result = new getAllPWDCredentialsForGateway_result(); - try { - result.success = iface.getAllPWDCredentialsForGateway(args.gatewayId); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class deleteSSHCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteSSHCredential_args> { - public deleteSSHCredential() { - super("deleteSSHCredential"); - } - - public deleteSSHCredential_args getEmptyArgsInstance() { - return new deleteSSHCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public deleteSSHCredential_result getResult(I iface, deleteSSHCredential_args args) throws org.apache.thrift.TException { - deleteSSHCredential_result result = new deleteSSHCredential_result(); - try { - result.success = iface.deleteSSHCredential(args.tokenId, args.gatewayId); - result.setSuccessIsSet(true); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - public static class deletePWDCredential<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deletePWDCredential_args> { - public deletePWDCredential() { - super("deletePWDCredential"); - } - - public deletePWDCredential_args getEmptyArgsInstance() { - return new deletePWDCredential_args(); - } - - protected boolean isOneway() { - return false; - } - - public deletePWDCredential_result getResult(I iface, deletePWDCredential_args args) throws org.apache.thrift.TException { - deletePWDCredential_result result = new deletePWDCredential_result(); - try { - result.success = iface.deletePWDCredential(args.tokenId, args.gatewayId); - result.setSuccessIsSet(true); - } catch (org.apache.airavata.credential.store.exception.CredentialStoreException csException) { - result.csException = csException; - } - return result; - } - } - - } - - public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> { - private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName()); - public AsyncProcessor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); - } - - protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - processMap.put("getCSServiceVersion", new getCSServiceVersion()); - processMap.put("addSSHCredential", new addSSHCredential()); - processMap.put("addCertificateCredential", new addCertificateCredential()); - processMap.put("addPasswordCredential", new addPasswordCredential()); - processMap.put("getSSHCredential", new getSSHCredential()); - processMap.put("getSSHCredentialSummary", new getSSHCredentialSummary()); - processMap.put("getCertificateCredential", new getCertificateCredential()); - processMap.put("getPasswordCredential", new getPasswordCredential()); - processMap.put("getAllSSHKeysForUser", new getAllSSHKeysForUser()); - processMap.put("getAllSSHKeysForGateway", new getAllSSHKeysForGateway()); - processMap.put("getAllGatewaySSHCredentialSummary", new getAllGatewaySSHCredentialSummary()); - processMap.put("getAllSSHCredentialSummaryForUserInGateway", new getAllSSHCredentialSummaryForUserInGateway()); - processMap.put("getAllPWDCredentialsForGateway", new getAllPWDCredentialsForGateway()); - processMap.put("deleteSSHCredential", new deleteSSHCredential()); - processMap.put("deletePWDCredential", new deletePWDCredential()); - return processMap; - } - - public static class getCSServiceVersion<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getCSServiceVersion_args, String> { - public getCSServiceVersion() { - super("getCSServiceVersion"); - } - - public getCSServiceVersion_args getEmptyArgsInstance() { - return new getCSServiceVersion_args(); - } - - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - getCSServiceVersion_result result = new getCSServiceVersion_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - getCSServiceVersion_result result = new getCSServiceVersion_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, getCSServiceVersion_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.getCSServiceVersion(resultHandler); - } - } - - public static class addSSHCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHCredential_args, String> { - public addSSHCredential() { - super("addSSHCredential"); - } - - public addSSHCredential_args getEmptyArgsInstance() { - return new addSSHCredential_args(); - } - - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addSSHCredential_result result = new addSSHCredential_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - addSSHCredential_result result = new addSSHCredential_result(); - if (e instanceof org.apache.airavata.credential.store.exception.CredentialStoreException) { - result.csException = (org.apache.airavata.credential.store.exception.CredentialStoreException) e; - result.setCsExceptionIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, addSSHCredential_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addSSHCredential(args.sshCredential,resultHandler); - } - } - - public static class addCertificateCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addCertificateCredential_args, String> { - public addCertificateCredential() { - super("addCertificateCredential"); - } - - public addCertificateCredential_args getEmptyArgsInstance() { - return new addCertificateCredential_args(); - } - - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addCertificateCredential_result result = new addCertificateCredential_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - addCertificateCredential_result result = new addCertificateCredential_result(); - if (e instanceof org.apache.airavata.credential.store.exception.CredentialStoreException) { - result.csException = (org.apache.airavata.credential.store.exception.CredentialStoreException) e; - result.setCsExceptionIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol
<TRUNCATED>
