You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/05/21 18:07:04 UTC
[09/14] STORM-216: Added Authentication and Authorization.
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/fe5f41aa/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
index e84e12d..7d04901 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
@@ -42,41 +42,43 @@ public class Nimbus {
public interface Iface {
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException;
+ public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException;
+ public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void killTopology(String name) throws NotAliveException, org.apache.thrift.TException;
+ public void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException;
+ public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void activate(String name) throws NotAliveException, org.apache.thrift.TException;
+ public void activate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void deactivate(String name) throws NotAliveException, org.apache.thrift.TException;
+ public void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException;
+ public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public String beginFileUpload() throws org.apache.thrift.TException;
+ public void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException;
+ public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException;
- public void finishFileUpload(String location) throws org.apache.thrift.TException;
+ public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
- public String beginFileDownload(String file) throws org.apache.thrift.TException;
+ public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException;
- public ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException;
+ public String beginFileDownload(String file) throws AuthorizationException, org.apache.thrift.TException;
- public String getNimbusConf() throws org.apache.thrift.TException;
+ public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.thrift.TException;
- public ClusterSummary getClusterInfo() throws org.apache.thrift.TException;
+ public String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException;
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException;
+ public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException;
- public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException;
+ public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException;
+ public String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException;
+ public StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+
+ public StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
}
@@ -96,6 +98,8 @@ public class Nimbus {
public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.rebalance_call> resultHandler) throws org.apache.thrift.TException;
+ public void uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.uploadNewCredentials_call> resultHandler) throws org.apache.thrift.TException;
+
public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.beginFileUpload_call> resultHandler) throws org.apache.thrift.TException;
public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.uploadChunk_call> resultHandler) throws org.apache.thrift.TException;
@@ -140,7 +144,7 @@ public class Nimbus {
super(iprot, oprot);
}
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_submitTopology(name, uploadedJarLocation, jsonConf, topology);
recv_submitTopology();
@@ -156,7 +160,7 @@ public class Nimbus {
sendBase("submitTopology", args);
}
- public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
submitTopology_result result = new submitTopology_result();
receiveBase(result, "submitTopology");
@@ -166,10 +170,13 @@ public class Nimbus {
if (result.ite != null) {
throw result.ite;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_submitTopologyWithOpts(name, uploadedJarLocation, jsonConf, topology, options);
recv_submitTopologyWithOpts();
@@ -186,7 +193,7 @@ public class Nimbus {
sendBase("submitTopologyWithOpts", args);
}
- public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
submitTopologyWithOpts_result result = new submitTopologyWithOpts_result();
receiveBase(result, "submitTopologyWithOpts");
@@ -196,10 +203,13 @@ public class Nimbus {
if (result.ite != null) {
throw result.ite;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void killTopology(String name) throws NotAliveException, org.apache.thrift.TException
+ public void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_killTopology(name);
recv_killTopology();
@@ -212,17 +222,20 @@ public class Nimbus {
sendBase("killTopology", args);
}
- public void recv_killTopology() throws NotAliveException, org.apache.thrift.TException
+ public void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
killTopology_result result = new killTopology_result();
receiveBase(result, "killTopology");
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException
+ public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_killTopologyWithOpts(name, options);
recv_killTopologyWithOpts();
@@ -236,17 +249,20 @@ public class Nimbus {
sendBase("killTopologyWithOpts", args);
}
- public void recv_killTopologyWithOpts() throws NotAliveException, org.apache.thrift.TException
+ public void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
killTopologyWithOpts_result result = new killTopologyWithOpts_result();
receiveBase(result, "killTopologyWithOpts");
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void activate(String name) throws NotAliveException, org.apache.thrift.TException
+ public void activate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_activate(name);
recv_activate();
@@ -259,17 +275,20 @@ public class Nimbus {
sendBase("activate", args);
}
- public void recv_activate() throws NotAliveException, org.apache.thrift.TException
+ public void recv_activate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
activate_result result = new activate_result();
receiveBase(result, "activate");
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void deactivate(String name) throws NotAliveException, org.apache.thrift.TException
+ public void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_deactivate(name);
recv_deactivate();
@@ -282,17 +301,20 @@ public class Nimbus {
sendBase("deactivate", args);
}
- public void recv_deactivate() throws NotAliveException, org.apache.thrift.TException
+ public void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
deactivate_result result = new deactivate_result();
receiveBase(result, "deactivate");
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_rebalance(name, options);
recv_rebalance();
@@ -306,7 +328,7 @@ public class Nimbus {
sendBase("rebalance", args);
}
- public void recv_rebalance() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException
+ public void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
rebalance_result result = new rebalance_result();
receiveBase(result, "rebalance");
@@ -316,10 +338,43 @@ public class Nimbus {
if (result.ite != null) {
throw result.ite;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
+ return;
+ }
+
+ public void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ {
+ send_uploadNewCredentials(name, creds);
+ recv_uploadNewCredentials();
+ }
+
+ public void send_uploadNewCredentials(String name, Credentials creds) throws org.apache.thrift.TException
+ {
+ uploadNewCredentials_args args = new uploadNewCredentials_args();
+ args.set_name(name);
+ args.set_creds(creds);
+ sendBase("uploadNewCredentials", args);
+ }
+
+ public void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ {
+ uploadNewCredentials_result result = new uploadNewCredentials_result();
+ receiveBase(result, "uploadNewCredentials");
+ if (result.e != null) {
+ throw result.e;
+ }
+ if (result.ite != null) {
+ throw result.ite;
+ }
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public String beginFileUpload() throws org.apache.thrift.TException
+ public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
{
send_beginFileUpload();
return recv_beginFileUpload();
@@ -331,17 +386,20 @@ public class Nimbus {
sendBase("beginFileUpload", args);
}
- public String recv_beginFileUpload() throws org.apache.thrift.TException
+ public String recv_beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
{
beginFileUpload_result result = new beginFileUpload_result();
receiveBase(result, "beginFileUpload");
if (result.is_set_success()) {
return result.success;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
}
- public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException
+ public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
{
send_uploadChunk(location, chunk);
recv_uploadChunk();
@@ -355,14 +413,17 @@ public class Nimbus {
sendBase("uploadChunk", args);
}
- public void recv_uploadChunk() throws org.apache.thrift.TException
+ public void recv_uploadChunk() throws AuthorizationException, org.apache.thrift.TException
{
uploadChunk_result result = new uploadChunk_result();
receiveBase(result, "uploadChunk");
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public void finishFileUpload(String location) throws org.apache.thrift.TException
+ public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException
{
send_finishFileUpload(location);
recv_finishFileUpload();
@@ -375,14 +436,17 @@ public class Nimbus {
sendBase("finishFileUpload", args);
}
- public void recv_finishFileUpload() throws org.apache.thrift.TException
+ public void recv_finishFileUpload() throws AuthorizationException, org.apache.thrift.TException
{
finishFileUpload_result result = new finishFileUpload_result();
receiveBase(result, "finishFileUpload");
+ if (result.aze != null) {
+ throw result.aze;
+ }
return;
}
- public String beginFileDownload(String file) throws org.apache.thrift.TException
+ public String beginFileDownload(String file) throws AuthorizationException, org.apache.thrift.TException
{
send_beginFileDownload(file);
return recv_beginFileDownload();
@@ -395,17 +459,20 @@ public class Nimbus {
sendBase("beginFileDownload", args);
}
- public String recv_beginFileDownload() throws org.apache.thrift.TException
+ public String recv_beginFileDownload() throws AuthorizationException, org.apache.thrift.TException
{
beginFileDownload_result result = new beginFileDownload_result();
receiveBase(result, "beginFileDownload");
if (result.is_set_success()) {
return result.success;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
}
- public ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException
+ public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.thrift.TException
{
send_downloadChunk(id);
return recv_downloadChunk();
@@ -418,17 +485,20 @@ public class Nimbus {
sendBase("downloadChunk", args);
}
- public ByteBuffer recv_downloadChunk() throws org.apache.thrift.TException
+ public ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.thrift.TException
{
downloadChunk_result result = new downloadChunk_result();
receiveBase(result, "downloadChunk");
if (result.is_set_success()) {
return result.success;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
}
- public String getNimbusConf() throws org.apache.thrift.TException
+ public String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
{
send_getNimbusConf();
return recv_getNimbusConf();
@@ -440,17 +510,20 @@ public class Nimbus {
sendBase("getNimbusConf", args);
}
- public String recv_getNimbusConf() throws org.apache.thrift.TException
+ public String recv_getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
{
getNimbusConf_result result = new getNimbusConf_result();
receiveBase(result, "getNimbusConf");
if (result.is_set_success()) {
return result.success;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result");
}
- public ClusterSummary getClusterInfo() throws org.apache.thrift.TException
+ public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException
{
send_getClusterInfo();
return recv_getClusterInfo();
@@ -462,17 +535,20 @@ public class Nimbus {
sendBase("getClusterInfo", args);
}
- public ClusterSummary recv_getClusterInfo() throws org.apache.thrift.TException
+ public ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.thrift.TException
{
getClusterInfo_result result = new getClusterInfo_result();
receiveBase(result, "getClusterInfo");
if (result.is_set_success()) {
return result.success;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result");
}
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException
+ public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyInfo(id);
return recv_getTopologyInfo();
@@ -485,7 +561,7 @@ public class Nimbus {
sendBase("getTopologyInfo", args);
}
- public TopologyInfo recv_getTopologyInfo() throws NotAliveException, org.apache.thrift.TException
+ public TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
getTopologyInfo_result result = new getTopologyInfo_result();
receiveBase(result, "getTopologyInfo");
@@ -495,10 +571,13 @@ public class Nimbus {
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
}
- public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException
+ public String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyConf(id);
return recv_getTopologyConf();
@@ -511,7 +590,7 @@ public class Nimbus {
sendBase("getTopologyConf", args);
}
- public String recv_getTopologyConf() throws NotAliveException, org.apache.thrift.TException
+ public String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
getTopologyConf_result result = new getTopologyConf_result();
receiveBase(result, "getTopologyConf");
@@ -521,10 +600,13 @@ public class Nimbus {
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result");
}
- public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException
+ public StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopology(id);
return recv_getTopology();
@@ -537,7 +619,7 @@ public class Nimbus {
sendBase("getTopology", args);
}
- public StormTopology recv_getTopology() throws NotAliveException, org.apache.thrift.TException
+ public StormTopology recv_getTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
getTopology_result result = new getTopology_result();
receiveBase(result, "getTopology");
@@ -547,10 +629,13 @@ public class Nimbus {
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopology failed: unknown result");
}
- public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException
+ public StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getUserTopology(id);
return recv_getUserTopology();
@@ -563,7 +648,7 @@ public class Nimbus {
sendBase("getUserTopology", args);
}
- public StormTopology recv_getUserTopology() throws NotAliveException, org.apache.thrift.TException
+ public StormTopology recv_getUserTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
getUserTopology_result result = new getUserTopology_result();
receiveBase(result, "getUserTopology");
@@ -573,6 +658,9 @@ public class Nimbus {
if (result.e != null) {
throw result.e;
}
+ if (result.aze != null) {
+ throw result.aze;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result");
}
@@ -625,7 +713,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException {
+ public void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -669,7 +757,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException {
+ public void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -701,7 +789,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, org.apache.thrift.TException {
+ public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -736,7 +824,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, org.apache.thrift.TException {
+ public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -768,7 +856,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, org.apache.thrift.TException {
+ public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -800,7 +888,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, org.apache.thrift.TException {
+ public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -835,7 +923,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException {
+ public void getResult() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -845,6 +933,41 @@ public class Nimbus {
}
}
+ public void uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback<uploadNewCredentials_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ uploadNewCredentials_call method_call = new uploadNewCredentials_call(name, creds, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class uploadNewCredentials_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String name;
+ private Credentials creds;
+ public uploadNewCredentials_call(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback<uploadNewCredentials_call> 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.name = name;
+ this.creds = creds;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("uploadNewCredentials", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ uploadNewCredentials_args args = new uploadNewCredentials_args();
+ args.set_name(name);
+ args.set_creds(creds);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws NotAliveException, InvalidTopologyException, AuthorizationException, 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);
+ (new Client(prot)).recv_uploadNewCredentials();
+ }
+ }
+
public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<beginFileUpload_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
beginFileUpload_call method_call = new beginFileUpload_call(resultHandler, this, ___protocolFactory, ___transport);
@@ -864,7 +987,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public String getResult() throws org.apache.thrift.TException {
+ public String getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -899,7 +1022,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.thrift.TException {
+ public void getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -931,7 +1054,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.thrift.TException {
+ public void getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -963,7 +1086,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public String getResult() throws org.apache.thrift.TException {
+ public String getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -995,7 +1118,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public ByteBuffer getResult() throws org.apache.thrift.TException {
+ public ByteBuffer getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1024,7 +1147,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public String getResult() throws org.apache.thrift.TException {
+ public String getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1053,7 +1176,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public ClusterSummary getResult() throws org.apache.thrift.TException {
+ public ClusterSummary getResult() throws AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1085,7 +1208,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public TopologyInfo getResult() throws NotAliveException, org.apache.thrift.TException {
+ public TopologyInfo getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1117,7 +1240,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public String getResult() throws NotAliveException, org.apache.thrift.TException {
+ public String getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1149,7 +1272,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public StormTopology getResult() throws NotAliveException, org.apache.thrift.TException {
+ public StormTopology getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1181,7 +1304,7 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public StormTopology getResult() throws NotAliveException, org.apache.thrift.TException {
+ public StormTopology getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1211,6 +1334,7 @@ public class Nimbus {
processMap.put("activate", new activate());
processMap.put("deactivate", new deactivate());
processMap.put("rebalance", new rebalance());
+ processMap.put("uploadNewCredentials", new uploadNewCredentials());
processMap.put("beginFileUpload", new beginFileUpload());
processMap.put("uploadChunk", new uploadChunk());
processMap.put("finishFileUpload", new finishFileUpload());
@@ -1242,6 +1366,8 @@ public class Nimbus {
result.e = e;
} catch (InvalidTopologyException ite) {
result.ite = ite;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1264,6 +1390,8 @@ public class Nimbus {
result.e = e;
} catch (InvalidTopologyException ite) {
result.ite = ite;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1284,6 +1412,8 @@ public class Nimbus {
iface.killTopology(args.name);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1304,6 +1434,8 @@ public class Nimbus {
iface.killTopologyWithOpts(args.name, args.options);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1324,6 +1456,8 @@ public class Nimbus {
iface.activate(args.name);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1344,6 +1478,8 @@ public class Nimbus {
iface.deactivate(args.name);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1366,6 +1502,32 @@ public class Nimbus {
result.e = e;
} catch (InvalidTopologyException ite) {
result.ite = ite;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
+ return result;
+ }
+ }
+
+ private static class uploadNewCredentials<I extends Iface> extends org.apache.thrift.ProcessFunction<I, uploadNewCredentials_args> {
+ public uploadNewCredentials() {
+ super("uploadNewCredentials");
+ }
+
+ protected uploadNewCredentials_args getEmptyArgsInstance() {
+ return new uploadNewCredentials_args();
+ }
+
+ protected uploadNewCredentials_result getResult(I iface, uploadNewCredentials_args args) throws org.apache.thrift.TException {
+ uploadNewCredentials_result result = new uploadNewCredentials_result();
+ try {
+ iface.uploadNewCredentials(args.name, args.creds);
+ } catch (NotAliveException e) {
+ result.e = e;
+ } catch (InvalidTopologyException ite) {
+ result.ite = ite;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1382,7 +1544,11 @@ public class Nimbus {
protected beginFileUpload_result getResult(I iface, beginFileUpload_args args) throws org.apache.thrift.TException {
beginFileUpload_result result = new beginFileUpload_result();
- result.success = iface.beginFileUpload();
+ try {
+ result.success = iface.beginFileUpload();
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1398,7 +1564,11 @@ public class Nimbus {
protected uploadChunk_result getResult(I iface, uploadChunk_args args) throws org.apache.thrift.TException {
uploadChunk_result result = new uploadChunk_result();
- iface.uploadChunk(args.location, args.chunk);
+ try {
+ iface.uploadChunk(args.location, args.chunk);
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1414,7 +1584,11 @@ public class Nimbus {
protected finishFileUpload_result getResult(I iface, finishFileUpload_args args) throws org.apache.thrift.TException {
finishFileUpload_result result = new finishFileUpload_result();
- iface.finishFileUpload(args.location);
+ try {
+ iface.finishFileUpload(args.location);
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1430,7 +1604,11 @@ public class Nimbus {
protected beginFileDownload_result getResult(I iface, beginFileDownload_args args) throws org.apache.thrift.TException {
beginFileDownload_result result = new beginFileDownload_result();
- result.success = iface.beginFileDownload(args.file);
+ try {
+ result.success = iface.beginFileDownload(args.file);
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1446,7 +1624,11 @@ public class Nimbus {
protected downloadChunk_result getResult(I iface, downloadChunk_args args) throws org.apache.thrift.TException {
downloadChunk_result result = new downloadChunk_result();
- result.success = iface.downloadChunk(args.id);
+ try {
+ result.success = iface.downloadChunk(args.id);
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1462,7 +1644,11 @@ public class Nimbus {
protected getNimbusConf_result getResult(I iface, getNimbusConf_args args) throws org.apache.thrift.TException {
getNimbusConf_result result = new getNimbusConf_result();
- result.success = iface.getNimbusConf();
+ try {
+ result.success = iface.getNimbusConf();
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1478,7 +1664,11 @@ public class Nimbus {
protected getClusterInfo_result getResult(I iface, getClusterInfo_args args) throws org.apache.thrift.TException {
getClusterInfo_result result = new getClusterInfo_result();
- result.success = iface.getClusterInfo();
+ try {
+ result.success = iface.getClusterInfo();
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
+ }
return result;
}
}
@@ -1498,6 +1688,8 @@ public class Nimbus {
result.success = iface.getTopologyInfo(args.id);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1518,6 +1710,8 @@ public class Nimbus {
result.success = iface.getTopologyConf(args.id);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1538,6 +1732,8 @@ public class Nimbus {
result.success = iface.getTopology(args.id);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -1558,6 +1754,8 @@ public class Nimbus {
result.success = iface.getUserTopology(args.id);
} catch (NotAliveException e) {
result.e = e;
+ } catch (AuthorizationException aze) {
+ result.aze = aze;
}
return result;
}
@@ -2151,14 +2349,17 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ITE_FIELD_DESC = new org.apache.thrift.protocol.TField("ite", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private AlreadyAliveException e; // required
private InvalidTopologyException ite; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
E((short)1, "e"),
- ITE((short)2, "ite");
+ ITE((short)2, "ite"),
+ AZE((short)3, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -2177,6 +2378,8 @@ public class Nimbus {
return E;
case 2: // ITE
return ITE;
+ case 3: // AZE
+ return AZE;
default:
return null;
}
@@ -2225,6 +2428,8 @@ public class Nimbus {
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ITE, new org.apache.thrift.meta_data.FieldMetaData("ite", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(submitTopology_result.class, metaDataMap);
}
@@ -2234,11 +2439,13 @@ public class Nimbus {
public submitTopology_result(
AlreadyAliveException e,
- InvalidTopologyException ite)
+ InvalidTopologyException ite,
+ AuthorizationException aze)
{
this();
this.e = e;
this.ite = ite;
+ this.aze = aze;
}
/**
@@ -2251,6 +2458,9 @@ public class Nimbus {
if (other.is_set_ite()) {
this.ite = new InvalidTopologyException(other.ite);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public submitTopology_result deepCopy() {
@@ -2261,6 +2471,7 @@ public class Nimbus {
public void clear() {
this.e = null;
this.ite = null;
+ this.aze = null;
}
public AlreadyAliveException get_e() {
@@ -2309,6 +2520,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -2327,6 +2561,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -2338,6 +2580,9 @@ public class Nimbus {
case ITE:
return get_ite();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -2353,6 +2598,8 @@ public class Nimbus {
return is_set_e();
case ITE:
return is_set_ite();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -2388,6 +2635,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -2405,6 +2661,11 @@ public class Nimbus {
if (present_ite)
builder.append(ite);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -2436,6 +2697,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -2469,6 +2740,14 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
+ case 3: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -2489,6 +2768,10 @@ public class Nimbus {
oprot.writeFieldBegin(ITE_FIELD_DESC);
this.ite.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -2514,6 +2797,14 @@ public class Nimbus {
sb.append(this.ite);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -3220,14 +3511,17 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ITE_FIELD_DESC = new org.apache.thrift.protocol.TField("ite", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private AlreadyAliveException e; // required
private InvalidTopologyException ite; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
E((short)1, "e"),
- ITE((short)2, "ite");
+ ITE((short)2, "ite"),
+ AZE((short)3, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -3246,6 +3540,8 @@ public class Nimbus {
return E;
case 2: // ITE
return ITE;
+ case 3: // AZE
+ return AZE;
default:
return null;
}
@@ -3294,6 +3590,8 @@ public class Nimbus {
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ITE, new org.apache.thrift.meta_data.FieldMetaData("ite", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(submitTopologyWithOpts_result.class, metaDataMap);
}
@@ -3303,11 +3601,13 @@ public class Nimbus {
public submitTopologyWithOpts_result(
AlreadyAliveException e,
- InvalidTopologyException ite)
+ InvalidTopologyException ite,
+ AuthorizationException aze)
{
this();
this.e = e;
this.ite = ite;
+ this.aze = aze;
}
/**
@@ -3320,6 +3620,9 @@ public class Nimbus {
if (other.is_set_ite()) {
this.ite = new InvalidTopologyException(other.ite);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public submitTopologyWithOpts_result deepCopy() {
@@ -3330,6 +3633,7 @@ public class Nimbus {
public void clear() {
this.e = null;
this.ite = null;
+ this.aze = null;
}
public AlreadyAliveException get_e() {
@@ -3378,6 +3682,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -3396,6 +3723,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -3407,6 +3742,9 @@ public class Nimbus {
case ITE:
return get_ite();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -3422,6 +3760,8 @@ public class Nimbus {
return is_set_e();
case ITE:
return is_set_ite();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -3457,6 +3797,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -3474,6 +3823,11 @@ public class Nimbus {
if (present_ite)
builder.append(ite);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -3505,6 +3859,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -3538,6 +3902,14 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
+ case 3: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -3558,6 +3930,10 @@ public class Nimbus {
oprot.writeFieldBegin(ITE_FIELD_DESC);
this.ite.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -3583,6 +3959,14 @@ public class Nimbus {
sb.append(this.ite);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -3914,12 +4298,15 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("killTopology_result");
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private NotAliveException e; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- E((short)1, "e");
+ E((short)1, "e"),
+ AZE((short)2, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -3936,6 +4323,8 @@ public class Nimbus {
switch(fieldId) {
case 1: // E
return E;
+ case 2: // AZE
+ return AZE;
default:
return null;
}
@@ -3982,6 +4371,8 @@ public class Nimbus {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(killTopology_result.class, metaDataMap);
}
@@ -3990,10 +4381,12 @@ public class Nimbus {
}
public killTopology_result(
- NotAliveException e)
+ NotAliveException e,
+ AuthorizationException aze)
{
this();
this.e = e;
+ this.aze = aze;
}
/**
@@ -4003,6 +4396,9 @@ public class Nimbus {
if (other.is_set_e()) {
this.e = new NotAliveException(other.e);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public killTopology_result deepCopy() {
@@ -4012,6 +4408,7 @@ public class Nimbus {
@Override
public void clear() {
this.e = null;
+ this.aze = null;
}
public NotAliveException get_e() {
@@ -4037,6 +4434,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -4047,6 +4467,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -4055,6 +4483,9 @@ public class Nimbus {
case E:
return get_e();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -4068,6 +4499,8 @@ public class Nimbus {
switch (field) {
case E:
return is_set_e();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -4094,6 +4527,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -4106,6 +4548,11 @@ public class Nimbus {
if (present_e)
builder.append(e);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -4127,6 +4574,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -4152,6 +4609,14 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
+ case 2: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -4168,6 +4633,10 @@ public class Nimbus {
oprot.writeFieldBegin(E_FIELD_DESC);
this.e.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -4185,6 +4654,14 @@ public class Nimbus {
sb.append(this.e);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -4610,12 +5087,15 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("killTopologyWithOpts_result");
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private NotAliveException e; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- E((short)1, "e");
+ E((short)1, "e"),
+ AZE((short)2, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -4632,6 +5112,8 @@ public class Nimbus {
switch(fieldId) {
case 1: // E
return E;
+ case 2: // AZE
+ return AZE;
default:
return null;
}
@@ -4678,6 +5160,8 @@ public class Nimbus {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(killTopologyWithOpts_result.class, metaDataMap);
}
@@ -4686,10 +5170,12 @@ public class Nimbus {
}
public killTopologyWithOpts_result(
- NotAliveException e)
+ NotAliveException e,
+ AuthorizationException aze)
{
this();
this.e = e;
+ this.aze = aze;
}
/**
@@ -4699,6 +5185,9 @@ public class Nimbus {
if (other.is_set_e()) {
this.e = new NotAliveException(other.e);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public killTopologyWithOpts_result deepCopy() {
@@ -4708,6 +5197,7 @@ public class Nimbus {
@Override
public void clear() {
this.e = null;
+ this.aze = null;
}
public NotAliveException get_e() {
@@ -4733,6 +5223,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -4743,6 +5256,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -4751,6 +5272,9 @@ public class Nimbus {
case E:
return get_e();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -4764,6 +5288,8 @@ public class Nimbus {
switch (field) {
case E:
return is_set_e();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -4790,6 +5316,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -4802,6 +5337,11 @@ public class Nimbus {
if (present_e)
builder.append(e);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -4823,6 +5363,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -4848,7 +5398,15 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- default:
+ case 2: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
iprot.readFieldEnd();
@@ -4864,6 +5422,10 @@ public class Nimbus {
oprot.writeFieldBegin(E_FIELD_DESC);
this.e.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -4881,6 +5443,14 @@ public class Nimbus {
sb.append(this.e);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -5212,12 +5782,15 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("activate_result");
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private NotAliveException e; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- E((short)1, "e");
+ E((short)1, "e"),
+ AZE((short)2, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -5234,6 +5807,8 @@ public class Nimbus {
switch(fieldId) {
case 1: // E
return E;
+ case 2: // AZE
+ return AZE;
default:
return null;
}
@@ -5280,6 +5855,8 @@ public class Nimbus {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(activate_result.class, metaDataMap);
}
@@ -5288,10 +5865,12 @@ public class Nimbus {
}
public activate_result(
- NotAliveException e)
+ NotAliveException e,
+ AuthorizationException aze)
{
this();
this.e = e;
+ this.aze = aze;
}
/**
@@ -5301,6 +5880,9 @@ public class Nimbus {
if (other.is_set_e()) {
this.e = new NotAliveException(other.e);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public activate_result deepCopy() {
@@ -5310,6 +5892,7 @@ public class Nimbus {
@Override
public void clear() {
this.e = null;
+ this.aze = null;
}
public NotAliveException get_e() {
@@ -5335,6 +5918,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -5345,6 +5951,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -5353,6 +5967,9 @@ public class Nimbus {
case E:
return get_e();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -5366,6 +5983,8 @@ public class Nimbus {
switch (field) {
case E:
return is_set_e();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -5392,6 +6011,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -5404,6 +6032,11 @@ public class Nimbus {
if (present_e)
builder.append(e);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -5425,6 +6058,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -5450,6 +6093,14 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
+ case 2: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -5466,6 +6117,10 @@ public class Nimbus {
oprot.writeFieldBegin(E_FIELD_DESC);
this.e.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -5483,6 +6138,14 @@ public class Nimbus {
sb.append(this.e);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -5814,12 +6477,15 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("deactivate_result");
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private NotAliveException e; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- E((short)1, "e");
+ E((short)1, "e"),
+ AZE((short)2, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -5836,6 +6502,8 @@ public class Nimbus {
switch(fieldId) {
case 1: // E
return E;
+ case 2: // AZE
+ return AZE;
default:
return null;
}
@@ -5882,6 +6550,8 @@ public class Nimbus {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(deactivate_result.class, metaDataMap);
}
@@ -5890,10 +6560,12 @@ public class Nimbus {
}
public deactivate_result(
- NotAliveException e)
+ NotAliveException e,
+ AuthorizationException aze)
{
this();
this.e = e;
+ this.aze = aze;
}
/**
@@ -5903,6 +6575,9 @@ public class Nimbus {
if (other.is_set_e()) {
this.e = new NotAliveException(other.e);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public deactivate_result deepCopy() {
@@ -5912,6 +6587,7 @@ public class Nimbus {
@Override
public void clear() {
this.e = null;
+ this.aze = null;
}
public NotAliveException get_e() {
@@ -5937,6 +6613,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -5947,6 +6646,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -5955,6 +6662,9 @@ public class Nimbus {
case E:
return get_e();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -5968,6 +6678,8 @@ public class Nimbus {
switch (field) {
case E:
return is_set_e();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -5994,6 +6706,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -6006,6 +6727,11 @@ public class Nimbus {
if (present_e)
builder.append(e);
+ boolean present_aze = true && (is_set_aze());
+ builder.append(present_aze);
+ if (present_aze)
+ builder.append(aze);
+
return builder.toHashCode();
}
@@ -6027,6 +6753,16 @@ public class Nimbus {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_aze()).compareTo(typedOther.is_set_aze());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_aze()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.aze, typedOther.aze);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -6052,6 +6788,14 @@ public class Nimbus {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
+ case 2: // AZE
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.aze = new AuthorizationException();
+ this.aze.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -6068,6 +6812,10 @@ public class Nimbus {
oprot.writeFieldBegin(E_FIELD_DESC);
this.e.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.is_set_aze()) {
+ oprot.writeFieldBegin(AZE_FIELD_DESC);
+ this.aze.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -6085,6 +6833,14 @@ public class Nimbus {
sb.append(this.e);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("aze:");
+ if (this.aze == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.aze);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -6511,14 +7267,17 @@ public class Nimbus {
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ITE_FIELD_DESC = new org.apache.thrift.protocol.TField("ite", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField AZE_FIELD_DESC = new org.apache.thrift.protocol.TField("aze", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private NotAliveException e; // required
private InvalidTopologyException ite; // required
+ private AuthorizationException aze; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
E((short)1, "e"),
- ITE((short)2, "ite");
+ ITE((short)2, "ite"),
+ AZE((short)3, "aze");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -6537,6 +7296,8 @@ public class Nimbus {
return E;
case 2: // ITE
return ITE;
+ case 3: // AZE
+ return AZE;
default:
return null;
}
@@ -6585,6 +7346,8 @@ public class Nimbus {
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ITE, new org.apache.thrift.meta_data.FieldMetaData("ite", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.AZE, new org.apache.thrift.meta_data.FieldMetaData("aze", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(rebalance_result.class, metaDataMap);
}
@@ -6594,11 +7357,13 @@ public class Nimbus {
public rebalance_result(
NotAliveException e,
- InvalidTopologyException ite)
+ InvalidTopologyException ite,
+ AuthorizationException aze)
{
this();
this.e = e;
this.ite = ite;
+ this.aze = aze;
}
/**
@@ -6611,6 +7376,9 @@ public class Nimbus {
if (other.is_set_ite()) {
this.ite = new InvalidTopologyException(other.ite);
}
+ if (other.is_set_aze()) {
+ this.aze = new AuthorizationException(other.aze);
+ }
}
public rebalance_result deepCopy() {
@@ -6621,6 +7389,7 @@ public class Nimbus {
public void clear() {
this.e = null;
this.ite = null;
+ this.aze = null;
}
public NotAliveException get_e() {
@@ -6669,6 +7438,29 @@ public class Nimbus {
}
}
+ public AuthorizationException get_aze() {
+ return this.aze;
+ }
+
+ public void set_aze(AuthorizationException aze) {
+ this.aze = aze;
+ }
+
+ public void unset_aze() {
+ this.aze = null;
+ }
+
+ /** Returns true if field aze is set (has been assigned a value) and false otherwise */
+ public boolean is_set_aze() {
+ return this.aze != null;
+ }
+
+ public void set_aze_isSet(boolean value) {
+ if (!value) {
+ this.aze = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case E:
@@ -6687,6 +7479,14 @@ public class Nimbus {
}
break;
+ case AZE:
+ if (value == null) {
+ unset_aze();
+ } else {
+ set_aze((AuthorizationException)value);
+ }
+ break;
+
}
}
@@ -6698,6 +7498,9 @@ public class Nimbus {
case ITE:
return get_ite();
+ case AZE:
+ return get_aze();
+
}
throw new IllegalStateException();
}
@@ -6713,6 +7516,8 @@ public class Nimbus {
return is_set_e();
case ITE:
return is_set_ite();
+ case AZE:
+ return is_set_aze();
}
throw new IllegalStateException();
}
@@ -6748,6 +7553,15 @@ public class Nimbus {
return false;
}
+ boolean this_present_aze = true && this.is_set_aze();
+ boolean that_present_aze = true && that.is_set_aze();
+ if (this_present_aze || that_present_aze) {
+ if (!(this_present_aze && that_present_aze))
+ return false;
+ if (!this.aze.equals(that.aze))
+ return false;
+ }
+
return true;
}
@@ -6765,6 +7579,11 @@ public class Nimbus {
if (present_ite)
builder.append(ite);
+ boolean present_aze =
<TRUNCATED>