http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java new file mode 100644 index 0000000..32bc972 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java @@ -0,0 +1,11272 @@ +/** + * 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.cloud.aurora.client.sdk; + +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)", date = "2016-10-21") +public class ReadOnlyScheduler { + + public interface Iface { + + /** + * Returns a summary of the jobs grouped by role. + */ + public Response getRoleSummary() throws org.apache.thrift.TException; + + /** + * Returns a summary of jobs, optionally only those owned by a specific role. + * + * @param role + */ + public Response getJobSummary(String role) throws org.apache.thrift.TException; + + /** + * Fetches the status of tasks. + * + * @param query + */ + public Response getTasksStatus(TaskQuery query) throws org.apache.thrift.TException; + + /** + * Same as getTaskStatus but without the TaskConfig.ExecutorConfig data set. + * This is an interim solution until we have a better way to query TaskConfigs (AURORA-541). + * + * @param query + */ + public Response getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException; + + /** + * Returns user-friendly reasons (if available) for tasks retained in PENDING state. + * + * @param query + */ + public Response getPendingReason(TaskQuery query) throws org.apache.thrift.TException; + + /** + * Fetches the configuration summary of active tasks for the specified job. + * + * @param job + */ + public Response getConfigSummary(JobKey job) throws org.apache.thrift.TException; + + /** + * Fetches the status of jobs. + * ownerRole is optional, in which case all jobs are returned. + * + * @param ownerRole + */ + public Response getJobs(String ownerRole) throws org.apache.thrift.TException; + + /** + * Fetches the quota allocated for a user. + * + * @param ownerRole + */ + public Response getQuota(String ownerRole) throws org.apache.thrift.TException; + + /** + * Populates fields in a job configuration as though it were about to be run. + * This can be used to diff a configuration running tasks. + * + * @param description + */ + public Response populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException; + + /** + * Gets job update summaries. + * + * @param jobUpdateQuery + */ + public Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException; + + /** + * Gets job update details. + * + * @param key + * @param query + */ + public Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException; + + /** + * Gets the diff between client (desired) and server (current) job states. + * + * @param request + */ + public Response getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException; + + /** + * Gets tier configurations. + */ + public Response getTierConfigs() throws org.apache.thrift.TException; + + } + + public interface AsyncIface { + + public void getRoleSummary(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getJobSummary(String role, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTasksStatus(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTasksWithoutConfigs(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getPendingReason(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getConfigSummary(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getJobs(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getQuota(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void populateJobConfig(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getJobUpdateDiff(JobUpdateRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTierConfigs(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 Response getRoleSummary() throws org.apache.thrift.TException + { + send_getRoleSummary(); + return recv_getRoleSummary(); + } + + public void send_getRoleSummary() throws org.apache.thrift.TException + { + getRoleSummary_args args = new getRoleSummary_args(); + sendBase("getRoleSummary", args); + } + + public Response recv_getRoleSummary() throws org.apache.thrift.TException + { + getRoleSummary_result result = new getRoleSummary_result(); + receiveBase(result, "getRoleSummary"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRoleSummary failed: unknown result"); + } + + public Response getJobSummary(String role) throws org.apache.thrift.TException + { + send_getJobSummary(role); + return recv_getJobSummary(); + } + + public void send_getJobSummary(String role) throws org.apache.thrift.TException + { + getJobSummary_args args = new getJobSummary_args(); + args.setRole(role); + sendBase("getJobSummary", args); + } + + public Response recv_getJobSummary() throws org.apache.thrift.TException + { + getJobSummary_result result = new getJobSummary_result(); + receiveBase(result, "getJobSummary"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobSummary failed: unknown result"); + } + + public Response getTasksStatus(TaskQuery query) throws org.apache.thrift.TException + { + send_getTasksStatus(query); + return recv_getTasksStatus(); + } + + public void send_getTasksStatus(TaskQuery query) throws org.apache.thrift.TException + { + getTasksStatus_args args = new getTasksStatus_args(); + args.setQuery(query); + sendBase("getTasksStatus", args); + } + + public Response recv_getTasksStatus() throws org.apache.thrift.TException + { + getTasksStatus_result result = new getTasksStatus_result(); + receiveBase(result, "getTasksStatus"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTasksStatus failed: unknown result"); + } + + public Response getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException + { + send_getTasksWithoutConfigs(query); + return recv_getTasksWithoutConfigs(); + } + + public void send_getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException + { + getTasksWithoutConfigs_args args = new getTasksWithoutConfigs_args(); + args.setQuery(query); + sendBase("getTasksWithoutConfigs", args); + } + + public Response recv_getTasksWithoutConfigs() throws org.apache.thrift.TException + { + getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_result(); + receiveBase(result, "getTasksWithoutConfigs"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTasksWithoutConfigs failed: unknown result"); + } + + public Response getPendingReason(TaskQuery query) throws org.apache.thrift.TException + { + send_getPendingReason(query); + return recv_getPendingReason(); + } + + public void send_getPendingReason(TaskQuery query) throws org.apache.thrift.TException + { + getPendingReason_args args = new getPendingReason_args(); + args.setQuery(query); + sendBase("getPendingReason", args); + } + + public Response recv_getPendingReason() throws org.apache.thrift.TException + { + getPendingReason_result result = new getPendingReason_result(); + receiveBase(result, "getPendingReason"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPendingReason failed: unknown result"); + } + + public Response getConfigSummary(JobKey job) throws org.apache.thrift.TException + { + send_getConfigSummary(job); + return recv_getConfigSummary(); + } + + public void send_getConfigSummary(JobKey job) throws org.apache.thrift.TException + { + getConfigSummary_args args = new getConfigSummary_args(); + args.setJob(job); + sendBase("getConfigSummary", args); + } + + public Response recv_getConfigSummary() throws org.apache.thrift.TException + { + getConfigSummary_result result = new getConfigSummary_result(); + receiveBase(result, "getConfigSummary"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getConfigSummary failed: unknown result"); + } + + public Response getJobs(String ownerRole) throws org.apache.thrift.TException + { + send_getJobs(ownerRole); + return recv_getJobs(); + } + + public void send_getJobs(String ownerRole) throws org.apache.thrift.TException + { + getJobs_args args = new getJobs_args(); + args.setOwnerRole(ownerRole); + sendBase("getJobs", args); + } + + public Response recv_getJobs() throws org.apache.thrift.TException + { + getJobs_result result = new getJobs_result(); + receiveBase(result, "getJobs"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobs failed: unknown result"); + } + + public Response getQuota(String ownerRole) throws org.apache.thrift.TException + { + send_getQuota(ownerRole); + return recv_getQuota(); + } + + public void send_getQuota(String ownerRole) throws org.apache.thrift.TException + { + getQuota_args args = new getQuota_args(); + args.setOwnerRole(ownerRole); + sendBase("getQuota", args); + } + + public Response recv_getQuota() throws org.apache.thrift.TException + { + getQuota_result result = new getQuota_result(); + receiveBase(result, "getQuota"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getQuota failed: unknown result"); + } + + public Response populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException + { + send_populateJobConfig(description); + return recv_populateJobConfig(); + } + + public void send_populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException + { + populateJobConfig_args args = new populateJobConfig_args(); + args.setDescription(description); + sendBase("populateJobConfig", args); + } + + public Response recv_populateJobConfig() throws org.apache.thrift.TException + { + populateJobConfig_result result = new populateJobConfig_result(); + receiveBase(result, "populateJobConfig"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "populateJobConfig failed: unknown result"); + } + + public Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException + { + send_getJobUpdateSummaries(jobUpdateQuery); + return recv_getJobUpdateSummaries(); + } + + public void send_getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException + { + getJobUpdateSummaries_args args = new getJobUpdateSummaries_args(); + args.setJobUpdateQuery(jobUpdateQuery); + sendBase("getJobUpdateSummaries", args); + } + + public Response recv_getJobUpdateSummaries() throws org.apache.thrift.TException + { + getJobUpdateSummaries_result result = new getJobUpdateSummaries_result(); + receiveBase(result, "getJobUpdateSummaries"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateSummaries failed: unknown result"); + } + + public Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException + { + send_getJobUpdateDetails(key, query); + return recv_getJobUpdateDetails(); + } + + public void send_getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException + { + getJobUpdateDetails_args args = new getJobUpdateDetails_args(); + args.setKey(key); + args.setQuery(query); + sendBase("getJobUpdateDetails", args); + } + + public Response recv_getJobUpdateDetails() throws org.apache.thrift.TException + { + getJobUpdateDetails_result result = new getJobUpdateDetails_result(); + receiveBase(result, "getJobUpdateDetails"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateDetails failed: unknown result"); + } + + public Response getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException + { + send_getJobUpdateDiff(request); + return recv_getJobUpdateDiff(); + } + + public void send_getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException + { + getJobUpdateDiff_args args = new getJobUpdateDiff_args(); + args.setRequest(request); + sendBase("getJobUpdateDiff", args); + } + + public Response recv_getJobUpdateDiff() throws org.apache.thrift.TException + { + getJobUpdateDiff_result result = new getJobUpdateDiff_result(); + receiveBase(result, "getJobUpdateDiff"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateDiff failed: unknown result"); + } + + public Response getTierConfigs() throws org.apache.thrift.TException + { + send_getTierConfigs(); + return recv_getTierConfigs(); + } + + public void send_getTierConfigs() throws org.apache.thrift.TException + { + getTierConfigs_args args = new getTierConfigs_args(); + sendBase("getTierConfigs", args); + } + + public Response recv_getTierConfigs() throws org.apache.thrift.TException + { + getTierConfigs_result result = new getTierConfigs_result(); + receiveBase(result, "getTierConfigs"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTierConfigs 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 getRoleSummary(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getRoleSummary_call method_call = new getRoleSummary_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getRoleSummary_call extends org.apache.thrift.async.TAsyncMethodCall { + public getRoleSummary_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("getRoleSummary", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getRoleSummary_args args = new getRoleSummary_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getRoleSummary(); + } + } + + public void getJobSummary(String role, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getJobSummary_call method_call = new getJobSummary_call(role, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getJobSummary_call extends org.apache.thrift.async.TAsyncMethodCall { + private String role; + public getJobSummary_call(String role, 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.role = role; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobSummary", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getJobSummary_args args = new getJobSummary_args(); + args.setRole(role); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getJobSummary(); + } + } + + public void getTasksStatus(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTasksStatus_call method_call = new getTasksStatus_call(query, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getTasksStatus_call extends org.apache.thrift.async.TAsyncMethodCall { + private TaskQuery query; + public getTasksStatus_call(TaskQuery query, 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.query = query; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTasksStatus", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTasksStatus_args args = new getTasksStatus_args(); + args.setQuery(query); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getTasksStatus(); + } + } + + public void getTasksWithoutConfigs(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTasksWithoutConfigs_call method_call = new getTasksWithoutConfigs_call(query, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getTasksWithoutConfigs_call extends org.apache.thrift.async.TAsyncMethodCall { + private TaskQuery query; + public getTasksWithoutConfigs_call(TaskQuery query, 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.query = query; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTasksWithoutConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTasksWithoutConfigs_args args = new getTasksWithoutConfigs_args(); + args.setQuery(query); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getTasksWithoutConfigs(); + } + } + + public void getPendingReason(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getPendingReason_call method_call = new getPendingReason_call(query, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getPendingReason_call extends org.apache.thrift.async.TAsyncMethodCall { + private TaskQuery query; + public getPendingReason_call(TaskQuery query, 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.query = query; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getPendingReason", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getPendingReason_args args = new getPendingReason_args(); + args.setQuery(query); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getPendingReason(); + } + } + + public void getConfigSummary(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getConfigSummary_call method_call = new getConfigSummary_call(job, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getConfigSummary_call extends org.apache.thrift.async.TAsyncMethodCall { + private JobKey job; + public getConfigSummary_call(JobKey job, 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.job = job; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getConfigSummary", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getConfigSummary_args args = new getConfigSummary_args(); + args.setJob(job); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getConfigSummary(); + } + } + + public void getJobs(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getJobs_call method_call = new getJobs_call(ownerRole, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getJobs_call extends org.apache.thrift.async.TAsyncMethodCall { + private String ownerRole; + public getJobs_call(String ownerRole, 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.ownerRole = ownerRole; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobs", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getJobs_args args = new getJobs_args(); + args.setOwnerRole(ownerRole); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getJobs(); + } + } + + public void getQuota(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getQuota_call method_call = new getQuota_call(ownerRole, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getQuota_call extends org.apache.thrift.async.TAsyncMethodCall { + private String ownerRole; + public getQuota_call(String ownerRole, 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.ownerRole = ownerRole; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getQuota", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getQuota_args args = new getQuota_args(); + args.setOwnerRole(ownerRole); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getQuota(); + } + } + + public void populateJobConfig(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + populateJobConfig_call method_call = new populateJobConfig_call(description, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class populateJobConfig_call extends org.apache.thrift.async.TAsyncMethodCall { + private JobConfiguration description; + public populateJobConfig_call(JobConfiguration description, 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.description = description; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("populateJobConfig", org.apache.thrift.protocol.TMessageType.CALL, 0)); + populateJobConfig_args args = new populateJobConfig_args(); + args.setDescription(description); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_populateJobConfig(); + } + } + + public void getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getJobUpdateSummaries_call method_call = new getJobUpdateSummaries_call(jobUpdateQuery, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getJobUpdateSummaries_call extends org.apache.thrift.async.TAsyncMethodCall { + private JobUpdateQuery jobUpdateQuery; + public getJobUpdateSummaries_call(JobUpdateQuery jobUpdateQuery, 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.jobUpdateQuery = jobUpdateQuery; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobUpdateSummaries", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getJobUpdateSummaries_args args = new getJobUpdateSummaries_args(); + args.setJobUpdateQuery(jobUpdateQuery); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getJobUpdateSummaries(); + } + } + + public void getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getJobUpdateDetails_call method_call = new getJobUpdateDetails_call(key, query, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getJobUpdateDetails_call extends org.apache.thrift.async.TAsyncMethodCall { + private JobUpdateKey key; + private JobUpdateQuery query; + public getJobUpdateDetails_call(JobUpdateKey key, JobUpdateQuery query, 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.key = key; + this.query = query; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobUpdateDetails", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getJobUpdateDetails_args args = new getJobUpdateDetails_args(); + args.setKey(key); + args.setQuery(query); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getJobUpdateDetails(); + } + } + + public void getJobUpdateDiff(JobUpdateRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getJobUpdateDiff_call method_call = new getJobUpdateDiff_call(request, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getJobUpdateDiff_call extends org.apache.thrift.async.TAsyncMethodCall { + private JobUpdateRequest request; + public getJobUpdateDiff_call(JobUpdateRequest request, 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.request = request; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobUpdateDiff", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getJobUpdateDiff_args args = new getJobUpdateDiff_args(); + args.setRequest(request); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getJobUpdateDiff(); + } + } + + public void getTierConfigs(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTierConfigs_call method_call = new getTierConfigs_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getTierConfigs_call extends org.apache.thrift.async.TAsyncMethodCall { + public getTierConfigs_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("getTierConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTierConfigs_args args = new getTierConfigs_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response 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_getTierConfigs(); + } + } + + } + + 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("getRoleSummary", new getRoleSummary()); + processMap.put("getJobSummary", new getJobSummary()); + processMap.put("getTasksStatus", new getTasksStatus()); + processMap.put("getTasksWithoutConfigs", new getTasksWithoutConfigs()); + processMap.put("getPendingReason", new getPendingReason()); + processMap.put("getConfigSummary", new getConfigSummary()); + processMap.put("getJobs", new getJobs()); + processMap.put("getQuota", new getQuota()); + processMap.put("populateJobConfig", new populateJobConfig()); + processMap.put("getJobUpdateSummaries", new getJobUpdateSummaries()); + processMap.put("getJobUpdateDetails", new getJobUpdateDetails()); + processMap.put("getJobUpdateDiff", new getJobUpdateDiff()); + processMap.put("getTierConfigs", new getTierConfigs()); + return processMap; + } + + public static class getRoleSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRoleSummary_args> { + public getRoleSummary() { + super("getRoleSummary"); + } + + public getRoleSummary_args getEmptyArgsInstance() { + return new getRoleSummary_args(); + } + + protected boolean isOneway() { + return false; + } + + public getRoleSummary_result getResult(I iface, getRoleSummary_args args) throws org.apache.thrift.TException { + getRoleSummary_result result = new getRoleSummary_result(); + result.success = iface.getRoleSummary(); + return result; + } + } + + public static class getJobSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobSummary_args> { + public getJobSummary() { + super("getJobSummary"); + } + + public getJobSummary_args getEmptyArgsInstance() { + return new getJobSummary_args(); + } + + protected boolean isOneway() { + return false; + } + + public getJobSummary_result getResult(I iface, getJobSummary_args args) throws org.apache.thrift.TException { + getJobSummary_result result = new getJobSummary_result(); + result.success = iface.getJobSummary(args.role); + return result; + } + } + + public static class getTasksStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTasksStatus_args> { + public getTasksStatus() { + super("getTasksStatus"); + } + + public getTasksStatus_args getEmptyArgsInstance() { + return new getTasksStatus_args(); + } + + protected boolean isOneway() { + return false; + } + + public getTasksStatus_result getResult(I iface, getTasksStatus_args args) throws org.apache.thrift.TException { + getTasksStatus_result result = new getTasksStatus_result(); + result.success = iface.getTasksStatus(args.query); + return result; + } + } + + public static class getTasksWithoutConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTasksWithoutConfigs_args> { + public getTasksWithoutConfigs() { + super("getTasksWithoutConfigs"); + } + + public getTasksWithoutConfigs_args getEmptyArgsInstance() { + return new getTasksWithoutConfigs_args(); + } + + protected boolean isOneway() { + return false; + } + + public getTasksWithoutConfigs_result getResult(I iface, getTasksWithoutConfigs_args args) throws org.apache.thrift.TException { + getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_result(); + result.success = iface.getTasksWithoutConfigs(args.query); + return result; + } + } + + public static class getPendingReason<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getPendingReason_args> { + public getPendingReason() { + super("getPendingReason"); + } + + public getPendingReason_args getEmptyArgsInstance() { + return new getPendingReason_args(); + } + + protected boolean isOneway() { + return false; + } + + public getPendingReason_result getResult(I iface, getPendingReason_args args) throws org.apache.thrift.TException { + getPendingReason_result result = new getPendingReason_result(); + result.success = iface.getPendingReason(args.query); + return result; + } + } + + public static class getConfigSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getConfigSummary_args> { + public getConfigSummary() { + super("getConfigSummary"); + } + + public getConfigSummary_args getEmptyArgsInstance() { + return new getConfigSummary_args(); + } + + protected boolean isOneway() { + return false; + } + + public getConfigSummary_result getResult(I iface, getConfigSummary_args args) throws org.apache.thrift.TException { + getConfigSummary_result result = new getConfigSummary_result(); + result.success = iface.getConfigSummary(args.job); + return result; + } + } + + public static class getJobs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobs_args> { + public getJobs() { + super("getJobs"); + } + + public getJobs_args getEmptyArgsInstance() { + return new getJobs_args(); + } + + protected boolean isOneway() { + return false; + } + + public getJobs_result getResult(I iface, getJobs_args args) throws org.apache.thrift.TException { + getJobs_result result = new getJobs_result(); + result.success = iface.getJobs(args.ownerRole); + return result; + } + } + + public static class getQuota<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getQuota_args> { + public getQuota() { + super("getQuota"); + } + + public getQuota_args getEmptyArgsInstance() { + return new getQuota_args(); + } + + protected boolean isOneway() { + return false; + } + + public getQuota_result getResult(I iface, getQuota_args args) throws org.apache.thrift.TException { + getQuota_result result = new getQuota_result(); + result.success = iface.getQuota(args.ownerRole); + return result; + } + } + + public static class populateJobConfig<I extends Iface> extends org.apache.thrift.ProcessFunction<I, populateJobConfig_args> { + public populateJobConfig() { + super("populateJobConfig"); + } + + public populateJobConfig_args getEmptyArgsInstance() { + return new populateJobConfig_args(); + } + + protected boolean isOneway() { + return false; + } + + public populateJobConfig_result getResult(I iface, populateJobConfig_args args) throws org.apache.thrift.TException { + populateJobConfig_result result = new populateJobConfig_result(); + result.success = iface.populateJobConfig(args.description); + return result; + } + } + + public static class getJobUpdateSummaries<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateSummaries_args> { + public getJobUpdateSummaries() { + super("getJobUpdateSummaries"); + } + + public getJobUpdateSummaries_args getEmptyArgsInstance() { + return new getJobUpdateSummaries_args(); + } + + protected boolean isOneway() { + return false; + } + + public getJobUpdateSummaries_result getResult(I iface, getJobUpdateSummaries_args args) throws org.apache.thrift.TException { + getJobUpdateSummaries_result result = new getJobUpdateSummaries_result(); + result.success = iface.getJobUpdateSummaries(args.jobUpdateQuery); + return result; + } + } + + public static class getJobUpdateDetails<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateDetails_args> { + public getJobUpdateDetails() { + super("getJobUpdateDetails"); + } + + public getJobUpdateDetails_args getEmptyArgsInstance() { + return new getJobUpdateDetails_args(); + } + + protected boolean isOneway() { + return false; + } + + public getJobUpdateDetails_result getResult(I iface, getJobUpdateDetails_args args) throws org.apache.thrift.TException { + getJobUpdateDetails_result result = new getJobUpdateDetails_result(); + result.success = iface.getJobUpdateDetails(args.key, args.query); + return result; + } + } + + public static class getJobUpdateDiff<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateDiff_args> { + public getJobUpdateDiff() { + super("getJobUpdateDiff"); + } + + public getJobUpdateDiff_args getEmptyArgsInstance() { + return new getJobUpdateDiff_args(); + } + + protected boolean isOneway() { + return false; + } + + public getJobUpdateDiff_result getResult(I iface, getJobUpdateDiff_args args) throws org.apache.thrift.TException { + getJobUpdateDiff_result result = new getJobUpdateDiff_result(); + result.success = iface.getJobUpdateDiff(args.request); + return result; + } + } + + public static class getTierConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTierConfigs_args> { + public getTierConfigs() { + super("getTierConfigs"); + } + + public getTierConfigs_args getEmptyArgsInstance() { + return new getTierConfigs_args(); + } + + protected boolean isOneway() { + return false; + } + + public getTierConfigs_result getResult(I iface, getTierConfigs_args args) throws org.apache.thrift.TException { + getTierConfigs_result result = new getTierConfigs_result(); + result.success = iface.getTierConfigs(); + 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("getRoleSummary", new getRoleSummary()); + processMap.put("getJobSummary", new getJobSummary()); + processMap.put("getTasksStatus", new getTasksStatus()); + processMap.put("getTasksWithoutConfigs", new getTasksWithoutConfigs()); + processMap.put("getPendingReason", new getPendingReason()); + processMap.put("getConfigSummary", new getConfigSummary()); + processMap.put("getJobs", new getJobs()); + processMap.put("getQuota", new getQuota()); + processMap.put("populateJobConfig", new populateJobConfig()); + processMap.put("getJobUpdateSummaries", new getJobUpdateSummaries()); + processMap.put("getJobUpdateDetails", new getJobUpdateDetails()); + processMap.put("getJobUpdateDiff", new getJobUpdateDiff()); + processMap.put("getTierConfigs", new getTierConfigs()); + return processMap; + } + + public static class getRoleSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getRoleSummary_args, Response> { + public getRoleSummary() { + super("getRoleSummary"); + } + + public getRoleSummary_args getEmptyArgsInstance() { + return new getRoleSummary_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getRoleSummary_result result = new getRoleSummary_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; + getRoleSummary_result result = new getRoleSummary_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, getRoleSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getRoleSummary(resultHandler); + } + } + + public static class getJobSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobSummary_args, Response> { + public getJobSummary() { + super("getJobSummary"); + } + + public getJobSummary_args getEmptyArgsInstance() { + return new getJobSummary_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getJobSummary_result result = new getJobSummary_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; + getJobSummary_result result = new getJobSummary_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, getJobSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getJobSummary(args.role,resultHandler); + } + } + + public static class getTasksStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTasksStatus_args, Response> { + public getTasksStatus() { + super("getTasksStatus"); + } + + public getTasksStatus_args getEmptyArgsInstance() { + return new getTasksStatus_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getTasksStatus_result result = new getTasksStatus_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; + getTasksStatus_result result = new getTasksStatus_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, getTasksStatus_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getTasksStatus(args.query,resultHandler); + } + } + + public static class getTasksWithoutConfigs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTasksWithoutConfigs_args, Response> { + public getTasksWithoutConfigs() { + super("getTasksWithoutConfigs"); + } + + public getTasksWithoutConfigs_args getEmptyArgsInstance() { + return new getTasksWithoutConfigs_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_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; + getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_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, getTasksWithoutConfigs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getTasksWithoutConfigs(args.query,resultHandler); + } + } + + public static class getPendingReason<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPendingReason_args, Response> { + public getPendingReason() { + super("getPendingReason"); + } + + public getPendingReason_args getEmptyArgsInstance() { + return new getPendingReason_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getPendingReason_result result = new getPendingReason_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; + getPendingReason_result result = new getPendingReason_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, getPendingReason_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getPendingReason(args.query,resultHandler); + } + } + + public static class getConfigSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getConfigSummary_args, Response> { + public getConfigSummary() { + super("getConfigSummary"); + } + + public getConfigSummary_args getEmptyArgsInstance() { + return new getConfigSummary_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getConfigSummary_result result = new getConfigSummary_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; + getConfigSummary_result result = new getConfigSummary_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, getConfigSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getConfigSummary(args.job,resultHandler); + } + } + + public static class getJobs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobs_args, Response> { + public getJobs() { + super("getJobs"); + } + + public getJobs_args getEmptyArgsInstance() { + return new getJobs_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getJobs_result result = new getJobs_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; + getJobs_result result = new getJobs_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, getJobs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getJobs(args.ownerRole,resultHandler); + } + } + + public static class getQuota<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getQuota_args, Response> { + public getQuota() { + super("getQuota"); + } + + public getQuota_args getEmptyArgsInstance() { + return new getQuota_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getQuota_result result = new getQuota_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; + getQuota_result result = new getQuota_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, getQuota_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getQuota(args.ownerRole,resultHandler); + } + } + + public static class populateJobConfig<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, populateJobConfig_args, Response> { + public populateJobConfig() { + super("populateJobConfig"); + } + + public populateJobConfig_args getEmptyArgsInstance() { + return new populateJobConfig_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + populateJobConfig_result result = new populateJobConfig_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; + populateJobConfig_result result = new populateJobConfig_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, populateJobConfig_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.populateJobConfig(args.description,resultHandler); + } + } + + public static class getJobUpdateSummaries<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateSummaries_args, Response> { + public getJobUpdateSummaries() { + super("getJobUpdateSummaries"); + } + + public getJobUpdateSummaries_args getEmptyArgsInstance() { + return new getJobUpdateSummaries_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getJobUpdateSummaries_result result = new getJobUpdateSummaries_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; + getJobUpdateSummaries_result result = new getJobUpdateSummaries_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, getJobUpdateSummaries_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getJobUpdateSummaries(args.jobUpdateQuery,resultHandler); + } + } + + public static class getJobUpdateDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateDetails_args, Response> { + public getJobUpdateDetails() { + super("getJobUpdateDetails"); + } + + public getJobUpdateDetails_args getEmptyArgsInstance() { + return new getJobUpdateDetails_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getJobUpdateDetails_result result = new getJobUpdateDetails_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; + getJobUpdateDetails_result result = new getJobUpdateDetails_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, getJobUpdateDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getJobUpdateDetails(args.key, args.query,resultHandler); + } + } + + public static class getJobUpdateDiff<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateDiff_args, Response> { + public getJobUpdateDiff() { + super("getJobUpdateDiff"); + } + + public getJobUpdateDiff_args getEmptyArgsInstance() { + return new getJobUpdateDiff_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getJobUpdateDiff_result result = new getJobUpdateDiff_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; + getJobUpdateDiff_result result = new getJobUpdateDiff_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, getJobUpdateDiff_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getJobUpdateDiff(args.request,resultHandler); + } + } + + public static class getTierConfigs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTierConfigs_args, Response> { + public getTierConfigs() { + super("getTierConfigs"); + } + + public getTierConfigs_args getEmptyArgsInstance() { + return new getTierConfigs_args(); + } + + public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Response>() { + public void onComplete(Response o) { + getTierConfigs_result result = new getTierConfigs_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; + getTierConfigs_result result = new getTierConfigs_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, getTierConfigs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { + iface.getTierConfigs(resultHandler); + } + } + + } + + public static class getRoleSummary_args implements org.apache.thrift.TBase<getRoleSummary_args, getRoleSummary_args._Fields>, java.io.Serializable, Cloneable, Comparable<getRoleSummary_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRoleSummary_args"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new getRoleSummary_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getRoleSummary_argsTupleSchemeFactory()); + } + + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { +; + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRoleSummary_args.class, metaDataMap); + } + + public getRoleSummary_args() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public getRoleSummary_args(getRoleSummary_args other) { + } + + public getRoleSummary_args deepCopy() { + return new getRoleSummary_args(this); + } + + @Override + public void clear() { + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + } + throw new Ill
<TRUNCATED>
