curator-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From randg...@apache.org
Subject [2/7] some more leader methods - start of path children cache
Date Thu, 29 May 2014 20:54:23 GMT
http://git-wip-us.apache.org/repos/asf/curator/blob/41ac42bb/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
----------------------------------------------------------------------
diff --git a/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java b/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
index 38a29cc..aab8a8d 100644
--- a/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
+++ b/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
@@ -52,12 +52,18 @@ public class CuratorService {
 
     public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws org.apache.thrift.TException;
 
+    public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException;
+
+    public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException;
+
     public CuratorProjection newCuratorProjection(String connectionName) throws org.apache.thrift.TException;
 
     public Stat setData(CuratorProjection projection, SetDataSpec spec) throws org.apache.thrift.TException;
 
     public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws org.apache.thrift.TException;
 
+    public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException;
+
   }
 
   public interface AsyncIface {
@@ -78,12 +84,18 @@ public class CuratorService {
 
     public void getData(CuratorProjection projection, GetDataSpec spec, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
 
+    public void getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+    public void isLeader(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
     public void newCuratorProjection(String connectionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
 
     public void setData(CuratorProjection projection, SetDataSpec spec, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
 
     public void startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
 
+    public void startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
   }
 
   public static class Client extends org.apache.thrift.TServiceClient implements Iface {
@@ -292,6 +304,54 @@ public class CuratorService {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getData failed: unknown result");
     }
 
+    public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+    {
+      send_getLeaderParticipants(projection, leaderProjection);
+      return recv_getLeaderParticipants();
+    }
+
+    public void send_getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+    {
+      getLeaderParticipants_args args = new getLeaderParticipants_args();
+      args.setProjection(projection);
+      args.setLeaderProjection(leaderProjection);
+      sendBase("getLeaderParticipants", args);
+    }
+
+    public List<Participant> recv_getLeaderParticipants() throws org.apache.thrift.TException
+    {
+      getLeaderParticipants_result result = new getLeaderParticipants_result();
+      receiveBase(result, "getLeaderParticipants");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLeaderParticipants failed: unknown result");
+    }
+
+    public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+    {
+      send_isLeader(projection, leaderProjection);
+      return recv_isLeader();
+    }
+
+    public void send_isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+    {
+      isLeader_args args = new isLeader_args();
+      args.setProjection(projection);
+      args.setLeaderProjection(leaderProjection);
+      sendBase("isLeader", args);
+    }
+
+    public boolean recv_isLeader() throws org.apache.thrift.TException
+    {
+      isLeader_result result = new isLeader_result();
+      receiveBase(result, "isLeader");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isLeader failed: unknown result");
+    }
+
     public CuratorProjection newCuratorProjection(String connectionName) throws org.apache.thrift.TException
     {
       send_newCuratorProjection(connectionName);
@@ -365,6 +425,33 @@ public class CuratorService {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startLeaderSelector failed: unknown result");
     }
 
+    public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException
+    {
+      send_startPathChildrenCache(projection, path, cacheData, dataIsCompressed, startMode);
+      return recv_startPathChildrenCache();
+    }
+
+    public void send_startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException
+    {
+      startPathChildrenCache_args args = new startPathChildrenCache_args();
+      args.setProjection(projection);
+      args.setPath(path);
+      args.setCacheData(cacheData);
+      args.setDataIsCompressed(dataIsCompressed);
+      args.setStartMode(startMode);
+      sendBase("startPathChildrenCache", args);
+    }
+
+    public PathChildrenCacheProjection recv_startPathChildrenCache() throws org.apache.thrift.TException
+    {
+      startPathChildrenCache_result result = new startPathChildrenCache_result();
+      receiveBase(result, "startPathChildrenCache");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startPathChildrenCache 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> {
@@ -663,6 +750,76 @@ public class CuratorService {
       }
     }
 
+    public void getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+      checkReady();
+      getLeaderParticipants_call method_call = new getLeaderParticipants_call(projection, leaderProjection, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class getLeaderParticipants_call extends org.apache.thrift.async.TAsyncMethodCall {
+      private CuratorProjection projection;
+      private LeaderProjection leaderProjection;
+      public getLeaderParticipants_call(CuratorProjection projection, LeaderProjection leaderProjection, 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.projection = projection;
+        this.leaderProjection = leaderProjection;
+      }
+
+      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLeaderParticipants", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        getLeaderParticipants_args args = new getLeaderParticipants_args();
+        args.setProjection(projection);
+        args.setLeaderProjection(leaderProjection);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public List<Participant> 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_getLeaderParticipants();
+      }
+    }
+
+    public void isLeader(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+      checkReady();
+      isLeader_call method_call = new isLeader_call(projection, leaderProjection, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class isLeader_call extends org.apache.thrift.async.TAsyncMethodCall {
+      private CuratorProjection projection;
+      private LeaderProjection leaderProjection;
+      public isLeader_call(CuratorProjection projection, LeaderProjection leaderProjection, 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.projection = projection;
+        this.leaderProjection = leaderProjection;
+      }
+
+      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isLeader", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        isLeader_args args = new isLeader_args();
+        args.setProjection(projection);
+        args.setLeaderProjection(leaderProjection);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public boolean 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_isLeader();
+      }
+    }
+
     public void newCuratorProjection(String connectionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
       checkReady();
       newCuratorProjection_call method_call = new newCuratorProjection_call(connectionName, resultHandler, this, ___protocolFactory, ___transport);
@@ -771,6 +928,50 @@ public class CuratorService {
       }
     }
 
+    public void startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+      checkReady();
+      startPathChildrenCache_call method_call = new startPathChildrenCache_call(projection, path, cacheData, dataIsCompressed, startMode, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class startPathChildrenCache_call extends org.apache.thrift.async.TAsyncMethodCall {
+      private CuratorProjection projection;
+      private String path;
+      private boolean cacheData;
+      private boolean dataIsCompressed;
+      private PathChildrenCacheStartMode startMode;
+      public startPathChildrenCache_call(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, 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.projection = projection;
+        this.path = path;
+        this.cacheData = cacheData;
+        this.dataIsCompressed = dataIsCompressed;
+        this.startMode = startMode;
+      }
+
+      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startPathChildrenCache", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        startPathChildrenCache_args args = new startPathChildrenCache_args();
+        args.setProjection(projection);
+        args.setPath(path);
+        args.setCacheData(cacheData);
+        args.setDataIsCompressed(dataIsCompressed);
+        args.setStartMode(startMode);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public PathChildrenCacheProjection 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_startPathChildrenCache();
+      }
+    }
+
   }
 
   public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
@@ -792,9 +993,12 @@ public class CuratorService {
       processMap.put("exists", new exists());
       processMap.put("getChildren", new getChildren());
       processMap.put("getData", new getData());
+      processMap.put("getLeaderParticipants", new getLeaderParticipants());
+      processMap.put("isLeader", new isLeader());
       processMap.put("newCuratorProjection", new newCuratorProjection());
       processMap.put("setData", new setData());
       processMap.put("startLeaderSelector", new startLeaderSelector());
+      processMap.put("startPathChildrenCache", new startPathChildrenCache());
       return processMap;
     }
 
@@ -959,6 +1163,47 @@ public class CuratorService {
       }
     }
 
+    public static class getLeaderParticipants<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getLeaderParticipants_args> {
+      public getLeaderParticipants() {
+        super("getLeaderParticipants");
+      }
+
+      public getLeaderParticipants_args getEmptyArgsInstance() {
+        return new getLeaderParticipants_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public getLeaderParticipants_result getResult(I iface, getLeaderParticipants_args args) throws org.apache.thrift.TException {
+        getLeaderParticipants_result result = new getLeaderParticipants_result();
+        result.success = iface.getLeaderParticipants(args.projection, args.leaderProjection);
+        return result;
+      }
+    }
+
+    public static class isLeader<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isLeader_args> {
+      public isLeader() {
+        super("isLeader");
+      }
+
+      public isLeader_args getEmptyArgsInstance() {
+        return new isLeader_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public isLeader_result getResult(I iface, isLeader_args args) throws org.apache.thrift.TException {
+        isLeader_result result = new isLeader_result();
+        result.success = iface.isLeader(args.projection, args.leaderProjection);
+        result.setSuccessIsSet(true);
+        return result;
+      }
+    }
+
     public static class newCuratorProjection<I extends Iface> extends org.apache.thrift.ProcessFunction<I, newCuratorProjection_args> {
       public newCuratorProjection() {
         super("newCuratorProjection");
@@ -1019,6 +1264,26 @@ public class CuratorService {
       }
     }
 
+    public static class startPathChildrenCache<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startPathChildrenCache_args> {
+      public startPathChildrenCache() {
+        super("startPathChildrenCache");
+      }
+
+      public startPathChildrenCache_args getEmptyArgsInstance() {
+        return new startPathChildrenCache_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public startPathChildrenCache_result getResult(I iface, startPathChildrenCache_args args) throws org.apache.thrift.TException {
+        startPathChildrenCache_result result = new startPathChildrenCache_result();
+        result.success = iface.startPathChildrenCache(args.projection, args.path, args.cacheData, args.dataIsCompressed, args.startMode);
+        return result;
+      }
+    }
+
   }
 
   public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> {
@@ -1040,9 +1305,12 @@ public class CuratorService {
       processMap.put("exists", new exists());
       processMap.put("getChildren", new getChildren());
       processMap.put("getData", new getData());
+      processMap.put("getLeaderParticipants", new getLeaderParticipants());
+      processMap.put("isLeader", new isLeader());
       processMap.put("newCuratorProjection", new newCuratorProjection());
       processMap.put("setData", new setData());
       processMap.put("startLeaderSelector", new startLeaderSelector());
+      processMap.put("startPathChildrenCache", new startPathChildrenCache());
       return processMap;
     }
 
@@ -1453,6 +1721,109 @@ public class CuratorService {
       }
     }
 
+    public static class getLeaderParticipants<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLeaderParticipants_args, List<Participant>> {
+      public getLeaderParticipants() {
+        super("getLeaderParticipants");
+      }
+
+      public getLeaderParticipants_args getEmptyArgsInstance() {
+        return new getLeaderParticipants_args();
+      }
+
+      public AsyncMethodCallback<List<Participant>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.thrift.AsyncProcessFunction fcall = this;
+        return new AsyncMethodCallback<List<Participant>>() { 
+          public void onComplete(List<Participant> o) {
+            getLeaderParticipants_result result = new getLeaderParticipants_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;
+            getLeaderParticipants_result result = new getLeaderParticipants_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, getLeaderParticipants_args args, org.apache.thrift.async.AsyncMethodCallback<List<Participant>> resultHandler) throws TException {
+        iface.getLeaderParticipants(args.projection, args.leaderProjection,resultHandler);
+      }
+    }
+
+    public static class isLeader<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isLeader_args, Boolean> {
+      public isLeader() {
+        super("isLeader");
+      }
+
+      public isLeader_args getEmptyArgsInstance() {
+        return new isLeader_args();
+      }
+
+      public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.thrift.AsyncProcessFunction fcall = this;
+        return new AsyncMethodCallback<Boolean>() { 
+          public void onComplete(Boolean o) {
+            isLeader_result result = new isLeader_result();
+            result.success = o;
+            result.setSuccessIsSet(true);
+            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;
+            isLeader_result result = new isLeader_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, isLeader_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+        iface.isLeader(args.projection, args.leaderProjection,resultHandler);
+      }
+    }
+
     public static class newCuratorProjection<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, newCuratorProjection_args, CuratorProjection> {
       public newCuratorProjection() {
         super("newCuratorProjection");
@@ -1606,20 +1977,71 @@ public class CuratorService {
       }
     }
 
-  }
-
-  public static class acquireLock_args implements org.apache.thrift.TBase<acquireLock_args, acquireLock_args._Fields>, java.io.Serializable, Cloneable, Comparable<acquireLock_args>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("acquireLock_args");
-
-    private static final org.apache.thrift.protocol.TField PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("projection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
-    private static final org.apache.thrift.protocol.TField PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)2);
-    private static final org.apache.thrift.protocol.TField MAX_WAIT_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxWaitMs", org.apache.thrift.protocol.TType.I32, (short)3);
+    public static class startPathChildrenCache<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, startPathChildrenCache_args, PathChildrenCacheProjection> {
+      public startPathChildrenCache() {
+        super("startPathChildrenCache");
+      }
 
-    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
-    static {
-      schemes.put(StandardScheme.class, new acquireLock_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new acquireLock_argsTupleSchemeFactory());
-    }
+      public startPathChildrenCache_args getEmptyArgsInstance() {
+        return new startPathChildrenCache_args();
+      }
+
+      public AsyncMethodCallback<PathChildrenCacheProjection> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.thrift.AsyncProcessFunction fcall = this;
+        return new AsyncMethodCallback<PathChildrenCacheProjection>() { 
+          public void onComplete(PathChildrenCacheProjection o) {
+            startPathChildrenCache_result result = new startPathChildrenCache_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;
+            startPathChildrenCache_result result = new startPathChildrenCache_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, startPathChildrenCache_args args, org.apache.thrift.async.AsyncMethodCallback<PathChildrenCacheProjection> resultHandler) throws TException {
+        iface.startPathChildrenCache(args.projection, args.path, args.cacheData, args.dataIsCompressed, args.startMode,resultHandler);
+      }
+    }
+
+  }
+
+  public static class acquireLock_args implements org.apache.thrift.TBase<acquireLock_args, acquireLock_args._Fields>, java.io.Serializable, Cloneable, Comparable<acquireLock_args>   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("acquireLock_args");
+
+    private static final org.apache.thrift.protocol.TField PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("projection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.thrift.protocol.TField PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)2);
+    private static final org.apache.thrift.protocol.TField MAX_WAIT_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxWaitMs", org.apache.thrift.protocol.TType.I32, (short)3);
+
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new acquireLock_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new acquireLock_argsTupleSchemeFactory());
+    }
 
     public CuratorProjection projection; // required
     public String path; // required
@@ -7955,22 +8377,25 @@ public class CuratorService {
 
   }
 
-  public static class newCuratorProjection_args implements org.apache.thrift.TBase<newCuratorProjection_args, newCuratorProjection_args._Fields>, java.io.Serializable, Cloneable, Comparable<newCuratorProjection_args>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("newCuratorProjection_args");
+  public static class getLeaderParticipants_args implements org.apache.thrift.TBase<getLeaderParticipants_args, getLeaderParticipants_args._Fields>, java.io.Serializable, Cloneable, Comparable<getLeaderParticipants_args>   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLeaderParticipants_args");
 
-    private static final org.apache.thrift.protocol.TField CONNECTION_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("connectionName", org.apache.thrift.protocol.TType.STRING, (short)1);
+    private static final org.apache.thrift.protocol.TField PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("projection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.thrift.protocol.TField LEADER_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("leaderProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new newCuratorProjection_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new newCuratorProjection_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new getLeaderParticipants_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new getLeaderParticipants_argsTupleSchemeFactory());
     }
 
-    public String connectionName; // required
+    public CuratorProjection projection; // required
+    public LeaderProjection leaderProjection; // 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 {
-      CONNECTION_NAME((short)1, "connectionName");
+      PROJECTION((short)1, "projection"),
+      LEADER_PROJECTION((short)2, "leaderProjection");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -7985,8 +8410,10 @@ public class CuratorService {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // CONNECTION_NAME
-            return CONNECTION_NAME;
+          case 1: // PROJECTION
+            return PROJECTION;
+          case 2: // LEADER_PROJECTION
+            return LEADER_PROJECTION;
           default:
             return null;
         }
@@ -8030,71 +8457,111 @@ public class CuratorService {
     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);
-      tmpMap.put(_Fields.CONNECTION_NAME, new org.apache.thrift.meta_data.FieldMetaData("connectionName", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+      tmpMap.put(_Fields.PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("projection", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CuratorProjection.class)));
+      tmpMap.put(_Fields.LEADER_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("leaderProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LeaderProjection.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(newCuratorProjection_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLeaderParticipants_args.class, metaDataMap);
     }
 
-    public newCuratorProjection_args() {
+    public getLeaderParticipants_args() {
     }
 
-    public newCuratorProjection_args(
-      String connectionName)
+    public getLeaderParticipants_args(
+      CuratorProjection projection,
+      LeaderProjection leaderProjection)
     {
       this();
-      this.connectionName = connectionName;
+      this.projection = projection;
+      this.leaderProjection = leaderProjection;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public newCuratorProjection_args(newCuratorProjection_args other) {
-      if (other.isSetConnectionName()) {
-        this.connectionName = other.connectionName;
+    public getLeaderParticipants_args(getLeaderParticipants_args other) {
+      if (other.isSetProjection()) {
+        this.projection = new CuratorProjection(other.projection);
+      }
+      if (other.isSetLeaderProjection()) {
+        this.leaderProjection = new LeaderProjection(other.leaderProjection);
       }
     }
 
-    public newCuratorProjection_args deepCopy() {
-      return new newCuratorProjection_args(this);
+    public getLeaderParticipants_args deepCopy() {
+      return new getLeaderParticipants_args(this);
     }
 
     @Override
     public void clear() {
-      this.connectionName = null;
+      this.projection = null;
+      this.leaderProjection = null;
     }
 
-    public String getConnectionName() {
-      return this.connectionName;
+    public CuratorProjection getProjection() {
+      return this.projection;
     }
 
-    public newCuratorProjection_args setConnectionName(String connectionName) {
-      this.connectionName = connectionName;
+    public getLeaderParticipants_args setProjection(CuratorProjection projection) {
+      this.projection = projection;
       return this;
     }
 
-    public void unsetConnectionName() {
-      this.connectionName = null;
+    public void unsetProjection() {
+      this.projection = null;
     }
 
-    /** Returns true if field connectionName is set (has been assigned a value) and false otherwise */
-    public boolean isSetConnectionName() {
-      return this.connectionName != null;
+    /** Returns true if field projection is set (has been assigned a value) and false otherwise */
+    public boolean isSetProjection() {
+      return this.projection != null;
     }
 
-    public void setConnectionNameIsSet(boolean value) {
+    public void setProjectionIsSet(boolean value) {
       if (!value) {
-        this.connectionName = null;
+        this.projection = null;
+      }
+    }
+
+    public LeaderProjection getLeaderProjection() {
+      return this.leaderProjection;
+    }
+
+    public getLeaderParticipants_args setLeaderProjection(LeaderProjection leaderProjection) {
+      this.leaderProjection = leaderProjection;
+      return this;
+    }
+
+    public void unsetLeaderProjection() {
+      this.leaderProjection = null;
+    }
+
+    /** Returns true if field leaderProjection is set (has been assigned a value) and false otherwise */
+    public boolean isSetLeaderProjection() {
+      return this.leaderProjection != null;
+    }
+
+    public void setLeaderProjectionIsSet(boolean value) {
+      if (!value) {
+        this.leaderProjection = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case CONNECTION_NAME:
+      case PROJECTION:
         if (value == null) {
-          unsetConnectionName();
+          unsetProjection();
         } else {
-          setConnectionName((String)value);
+          setProjection((CuratorProjection)value);
+        }
+        break;
+
+      case LEADER_PROJECTION:
+        if (value == null) {
+          unsetLeaderProjection();
+        } else {
+          setLeaderProjection((LeaderProjection)value);
         }
         break;
 
@@ -8103,8 +8570,11 @@ public class CuratorService {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case CONNECTION_NAME:
-        return getConnectionName();
+      case PROJECTION:
+        return getProjection();
+
+      case LEADER_PROJECTION:
+        return getLeaderProjection();
 
       }
       throw new IllegalStateException();
@@ -8117,8 +8587,10 @@ public class CuratorService {
       }
 
       switch (field) {
-      case CONNECTION_NAME:
-        return isSetConnectionName();
+      case PROJECTION:
+        return isSetProjection();
+      case LEADER_PROJECTION:
+        return isSetLeaderProjection();
       }
       throw new IllegalStateException();
     }
@@ -8127,21 +8599,30 @@ public class CuratorService {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof newCuratorProjection_args)
-        return this.equals((newCuratorProjection_args)that);
+      if (that instanceof getLeaderParticipants_args)
+        return this.equals((getLeaderParticipants_args)that);
       return false;
     }
 
-    public boolean equals(newCuratorProjection_args that) {
+    public boolean equals(getLeaderParticipants_args that) {
       if (that == null)
         return false;
 
-      boolean this_present_connectionName = true && this.isSetConnectionName();
-      boolean that_present_connectionName = true && that.isSetConnectionName();
-      if (this_present_connectionName || that_present_connectionName) {
-        if (!(this_present_connectionName && that_present_connectionName))
+      boolean this_present_projection = true && this.isSetProjection();
+      boolean that_present_projection = true && that.isSetProjection();
+      if (this_present_projection || that_present_projection) {
+        if (!(this_present_projection && that_present_projection))
           return false;
-        if (!this.connectionName.equals(that.connectionName))
+        if (!this.projection.equals(that.projection))
+          return false;
+      }
+
+      boolean this_present_leaderProjection = true && this.isSetLeaderProjection();
+      boolean that_present_leaderProjection = true && that.isSetLeaderProjection();
+      if (this_present_leaderProjection || that_present_leaderProjection) {
+        if (!(this_present_leaderProjection && that_present_leaderProjection))
+          return false;
+        if (!this.leaderProjection.equals(that.leaderProjection))
           return false;
       }
 
@@ -8154,19 +8635,29 @@ public class CuratorService {
     }
 
     @Override
-    public int compareTo(newCuratorProjection_args other) {
+    public int compareTo(getLeaderParticipants_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
 
-      lastComparison = Boolean.valueOf(isSetConnectionName()).compareTo(other.isSetConnectionName());
+      lastComparison = Boolean.valueOf(isSetProjection()).compareTo(other.isSetProjection());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetConnectionName()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.connectionName, other.connectionName);
+      if (isSetProjection()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.projection, other.projection);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetLeaderProjection()).compareTo(other.isSetLeaderProjection());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetLeaderProjection()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.leaderProjection, other.leaderProjection);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -8188,14 +8679,22 @@ public class CuratorService {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("newCuratorProjection_args(");
+      StringBuilder sb = new StringBuilder("getLeaderParticipants_args(");
       boolean first = true;
 
-      sb.append("connectionName:");
-      if (this.connectionName == null) {
+      sb.append("projection:");
+      if (this.projection == null) {
         sb.append("null");
       } else {
-        sb.append(this.connectionName);
+        sb.append(this.projection);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("leaderProjection:");
+      if (this.leaderProjection == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.leaderProjection);
       }
       first = false;
       sb.append(")");
@@ -8205,6 +8704,12 @@ public class CuratorService {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
+      if (projection != null) {
+        projection.validate();
+      }
+      if (leaderProjection != null) {
+        leaderProjection.validate();
+      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -8223,15 +8728,15 @@ public class CuratorService {
       }
     }
 
-    private static class newCuratorProjection_argsStandardSchemeFactory implements SchemeFactory {
-      public newCuratorProjection_argsStandardScheme getScheme() {
-        return new newCuratorProjection_argsStandardScheme();
+    private static class getLeaderParticipants_argsStandardSchemeFactory implements SchemeFactory {
+      public getLeaderParticipants_argsStandardScheme getScheme() {
+        return new getLeaderParticipants_argsStandardScheme();
       }
     }
 
-    private static class newCuratorProjection_argsStandardScheme extends StandardScheme<newCuratorProjection_args> {
+    private static class getLeaderParticipants_argsStandardScheme extends StandardScheme<getLeaderParticipants_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, newCuratorProjection_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, getLeaderParticipants_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -8241,10 +8746,20 @@ public class CuratorService {
             break;
           }
           switch (schemeField.id) {
-            case 1: // CONNECTION_NAME
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
-                struct.connectionName = iprot.readString();
-                struct.setConnectionNameIsSet(true);
+            case 1: // PROJECTION
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.projection = new CuratorProjection();
+                struct.projection.read(iprot);
+                struct.setProjectionIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 2: // LEADER_PROJECTION
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.leaderProjection = new LeaderProjection();
+                struct.leaderProjection.read(iprot);
+                struct.setLeaderProjectionIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -8260,13 +8775,18 @@ public class CuratorService {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, newCuratorProjection_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, getLeaderParticipants_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.connectionName != null) {
-          oprot.writeFieldBegin(CONNECTION_NAME_FIELD_DESC);
-          oprot.writeString(struct.connectionName);
+        if (struct.projection != null) {
+          oprot.writeFieldBegin(PROJECTION_FIELD_DESC);
+          struct.projection.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        if (struct.leaderProjection != null) {
+          oprot.writeFieldBegin(LEADER_PROJECTION_FIELD_DESC);
+          struct.leaderProjection.write(oprot);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -8275,52 +8795,64 @@ public class CuratorService {
 
     }
 
-    private static class newCuratorProjection_argsTupleSchemeFactory implements SchemeFactory {
-      public newCuratorProjection_argsTupleScheme getScheme() {
-        return new newCuratorProjection_argsTupleScheme();
+    private static class getLeaderParticipants_argsTupleSchemeFactory implements SchemeFactory {
+      public getLeaderParticipants_argsTupleScheme getScheme() {
+        return new getLeaderParticipants_argsTupleScheme();
       }
     }
 
-    private static class newCuratorProjection_argsTupleScheme extends TupleScheme<newCuratorProjection_args> {
+    private static class getLeaderParticipants_argsTupleScheme extends TupleScheme<getLeaderParticipants_args> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetConnectionName()) {
+        if (struct.isSetProjection()) {
           optionals.set(0);
         }
-        oprot.writeBitSet(optionals, 1);
-        if (struct.isSetConnectionName()) {
-          oprot.writeString(struct.connectionName);
+        if (struct.isSetLeaderProjection()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetProjection()) {
+          struct.projection.write(oprot);
+        }
+        if (struct.isSetLeaderProjection()) {
+          struct.leaderProjection.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(1);
+        BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
-          struct.connectionName = iprot.readString();
-          struct.setConnectionNameIsSet(true);
+          struct.projection = new CuratorProjection();
+          struct.projection.read(iprot);
+          struct.setProjectionIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.leaderProjection = new LeaderProjection();
+          struct.leaderProjection.read(iprot);
+          struct.setLeaderProjectionIsSet(true);
         }
       }
     }
 
   }
 
-  public static class newCuratorProjection_result implements org.apache.thrift.TBase<newCuratorProjection_result, newCuratorProjection_result._Fields>, java.io.Serializable, Cloneable, Comparable<newCuratorProjection_result>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("newCuratorProjection_result");
+  public static class getLeaderParticipants_result implements org.apache.thrift.TBase<getLeaderParticipants_result, getLeaderParticipants_result._Fields>, java.io.Serializable, Cloneable, Comparable<getLeaderParticipants_result>   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLeaderParticipants_result");
 
-    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
+    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new newCuratorProjection_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new newCuratorProjection_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new getLeaderParticipants_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new getLeaderParticipants_resultTupleSchemeFactory());
     }
 
-    public CuratorProjection success; // required
+    public List<Participant> success; // 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 {
@@ -8385,16 +8917,17 @@ public class CuratorService {
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CuratorProjection.class)));
+          new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Participant.class))));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(newCuratorProjection_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLeaderParticipants_result.class, metaDataMap);
     }
 
-    public newCuratorProjection_result() {
+    public getLeaderParticipants_result() {
     }
 
-    public newCuratorProjection_result(
-      CuratorProjection success)
+    public getLeaderParticipants_result(
+      List<Participant> success)
     {
       this();
       this.success = success;
@@ -8403,14 +8936,18 @@ public class CuratorService {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public newCuratorProjection_result(newCuratorProjection_result other) {
+    public getLeaderParticipants_result(getLeaderParticipants_result other) {
       if (other.isSetSuccess()) {
-        this.success = new CuratorProjection(other.success);
+        List<Participant> __this__success = new ArrayList<Participant>(other.success.size());
+        for (Participant other_element : other.success) {
+          __this__success.add(new Participant(other_element));
+        }
+        this.success = __this__success;
       }
     }
 
-    public newCuratorProjection_result deepCopy() {
-      return new newCuratorProjection_result(this);
+    public getLeaderParticipants_result deepCopy() {
+      return new getLeaderParticipants_result(this);
     }
 
     @Override
@@ -8418,11 +8955,26 @@ public class CuratorService {
       this.success = null;
     }
 
-    public CuratorProjection getSuccess() {
+    public int getSuccessSize() {
+      return (this.success == null) ? 0 : this.success.size();
+    }
+
+    public java.util.Iterator<Participant> getSuccessIterator() {
+      return (this.success == null) ? null : this.success.iterator();
+    }
+
+    public void addToSuccess(Participant elem) {
+      if (this.success == null) {
+        this.success = new ArrayList<Participant>();
+      }
+      this.success.add(elem);
+    }
+
+    public List<Participant> getSuccess() {
       return this.success;
     }
 
-    public newCuratorProjection_result setSuccess(CuratorProjection success) {
+    public getLeaderParticipants_result setSuccess(List<Participant> success) {
       this.success = success;
       return this;
     }
@@ -8448,7 +9000,7 @@ public class CuratorService {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((CuratorProjection)value);
+          setSuccess((List<Participant>)value);
         }
         break;
 
@@ -8481,12 +9033,12 @@ public class CuratorService {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof newCuratorProjection_result)
-        return this.equals((newCuratorProjection_result)that);
+      if (that instanceof getLeaderParticipants_result)
+        return this.equals((getLeaderParticipants_result)that);
       return false;
     }
 
-    public boolean equals(newCuratorProjection_result that) {
+    public boolean equals(getLeaderParticipants_result that) {
       if (that == null)
         return false;
 
@@ -8508,7 +9060,7 @@ public class CuratorService {
     }
 
     @Override
-    public int compareTo(newCuratorProjection_result other) {
+    public int compareTo(getLeaderParticipants_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
@@ -8542,7 +9094,7 @@ public class CuratorService {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("newCuratorProjection_result(");
+      StringBuilder sb = new StringBuilder("getLeaderParticipants_result(");
       boolean first = true;
 
       sb.append("success:");
@@ -8559,9 +9111,6 @@ public class CuratorService {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (success != null) {
-        success.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -8580,15 +9129,15 @@ public class CuratorService {
       }
     }
 
-    private static class newCuratorProjection_resultStandardSchemeFactory implements SchemeFactory {
-      public newCuratorProjection_resultStandardScheme getScheme() {
-        return new newCuratorProjection_resultStandardScheme();
+    private static class getLeaderParticipants_resultStandardSchemeFactory implements SchemeFactory {
+      public getLeaderParticipants_resultStandardScheme getScheme() {
+        return new getLeaderParticipants_resultStandardScheme();
       }
     }
 
-    private static class newCuratorProjection_resultStandardScheme extends StandardScheme<newCuratorProjection_result> {
+    private static class getLeaderParticipants_resultStandardScheme extends StandardScheme<getLeaderParticipants_result> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, newCuratorProjection_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, getLeaderParticipants_result struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -8599,9 +9148,19 @@ public class CuratorService {
           }
           switch (schemeField.id) {
             case 0: // SUCCESS
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.success = new CuratorProjection();
-                struct.success.read(iprot);
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list24 = iprot.readListBegin();
+                  struct.success = new ArrayList<Participant>(_list24.size);
+                  for (int _i25 = 0; _i25 < _list24.size; ++_i25)
+                  {
+                    Participant _elem26;
+                    _elem26 = new Participant();
+                    _elem26.read(iprot);
+                    struct.success.add(_elem26);
+                  }
+                  iprot.readListEnd();
+                }
                 struct.setSuccessIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
@@ -8618,13 +9177,20 @@ public class CuratorService {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, newCuratorProjection_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, getLeaderParticipants_result struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
         if (struct.success != null) {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          struct.success.write(oprot);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
+            for (Participant _iter27 : struct.success)
+            {
+              _iter27.write(oprot);
+            }
+            oprot.writeListEnd();
+          }
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -8633,16 +9199,16 @@ public class CuratorService {
 
     }
 
-    private static class newCuratorProjection_resultTupleSchemeFactory implements SchemeFactory {
-      public newCuratorProjection_resultTupleScheme getScheme() {
-        return new newCuratorProjection_resultTupleScheme();
+    private static class getLeaderParticipants_resultTupleSchemeFactory implements SchemeFactory {
+      public getLeaderParticipants_resultTupleScheme getScheme() {
+        return new getLeaderParticipants_resultTupleScheme();
       }
     }
 
-    private static class newCuratorProjection_resultTupleScheme extends TupleScheme<newCuratorProjection_result> {
+    private static class getLeaderParticipants_resultTupleScheme extends TupleScheme<getLeaderParticipants_result> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_result struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetSuccess()) {
@@ -8650,17 +9216,32 @@ public class CuratorService {
         }
         oprot.writeBitSet(optionals, 1);
         if (struct.isSetSuccess()) {
-          struct.success.write(oprot);
+          {
+            oprot.writeI32(struct.success.size());
+            for (Participant _iter28 : struct.success)
+            {
+              _iter28.write(oprot);
+            }
+          }
         }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_result struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
-          struct.success = new CuratorProjection();
-          struct.success.read(iprot);
+          {
+            org.apache.thrift.protocol.TList _list29 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Participant>(_list29.size);
+            for (int _i30 = 0; _i30 < _list29.size; ++_i30)
+            {
+              Participant _elem31;
+              _elem31 = new Participant();
+              _elem31.read(iprot);
+              struct.success.add(_elem31);
+            }
+          }
           struct.setSuccessIsSet(true);
         }
       }
@@ -8668,25 +9249,25 @@ public class CuratorService {
 
   }
 
-  public static class setData_args implements org.apache.thrift.TBase<setData_args, setData_args._Fields>, java.io.Serializable, Cloneable, Comparable<setData_args>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("setData_args");
+  public static class isLeader_args implements org.apache.thrift.TBase<isLeader_args, isLeader_args._Fields>, java.io.Serializable, Cloneable, Comparable<isLeader_args>   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isLeader_args");
 
     private static final org.apache.thrift.protocol.TField PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("projection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
-    private static final org.apache.thrift.protocol.TField SPEC_FIELD_DESC = new org.apache.thrift.protocol.TField("spec", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+    private static final org.apache.thrift.protocol.TField LEADER_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("leaderProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new setData_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new setData_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new isLeader_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new isLeader_argsTupleSchemeFactory());
     }
 
     public CuratorProjection projection; // required
-    public SetDataSpec spec; // required
+    public LeaderProjection leaderProjection; // 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 {
       PROJECTION((short)1, "projection"),
-      SPEC((short)2, "spec");
+      LEADER_PROJECTION((short)2, "leaderProjection");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -8703,8 +9284,8 @@ public class CuratorService {
         switch(fieldId) {
           case 1: // PROJECTION
             return PROJECTION;
-          case 2: // SPEC
-            return SPEC;
+          case 2: // LEADER_PROJECTION
+            return LEADER_PROJECTION;
           default:
             return null;
         }
@@ -8750,51 +9331,51 @@ public class CuratorService {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("projection", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CuratorProjection.class)));
-      tmpMap.put(_Fields.SPEC, new org.apache.thrift.meta_data.FieldMetaData("spec", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SetDataSpec.class)));
+      tmpMap.put(_Fields.LEADER_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("leaderProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LeaderProjection.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(setData_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_args.class, metaDataMap);
     }
 
-    public setData_args() {
+    public isLeader_args() {
     }
 
-    public setData_args(
+    public isLeader_args(
       CuratorProjection projection,
-      SetDataSpec spec)
+      LeaderProjection leaderProjection)
     {
       this();
       this.projection = projection;
-      this.spec = spec;
+      this.leaderProjection = leaderProjection;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public setData_args(setData_args other) {
+    public isLeader_args(isLeader_args other) {
       if (other.isSetProjection()) {
         this.projection = new CuratorProjection(other.projection);
       }
-      if (other.isSetSpec()) {
-        this.spec = new SetDataSpec(other.spec);
+      if (other.isSetLeaderProjection()) {
+        this.leaderProjection = new LeaderProjection(other.leaderProjection);
       }
     }
 
-    public setData_args deepCopy() {
-      return new setData_args(this);
+    public isLeader_args deepCopy() {
+      return new isLeader_args(this);
     }
 
     @Override
     public void clear() {
       this.projection = null;
-      this.spec = null;
+      this.leaderProjection = null;
     }
 
     public CuratorProjection getProjection() {
       return this.projection;
     }
 
-    public setData_args setProjection(CuratorProjection projection) {
+    public isLeader_args setProjection(CuratorProjection projection) {
       this.projection = projection;
       return this;
     }
@@ -8814,27 +9395,27 @@ public class CuratorService {
       }
     }
 
-    public SetDataSpec getSpec() {
-      return this.spec;
+    public LeaderProjection getLeaderProjection() {
+      return this.leaderProjection;
     }
 
-    public setData_args setSpec(SetDataSpec spec) {
-      this.spec = spec;
+    public isLeader_args setLeaderProjection(LeaderProjection leaderProjection) {
+      this.leaderProjection = leaderProjection;
       return this;
     }
 
-    public void unsetSpec() {
-      this.spec = null;
+    public void unsetLeaderProjection() {
+      this.leaderProjection = null;
     }
 
-    /** Returns true if field spec is set (has been assigned a value) and false otherwise */
-    public boolean isSetSpec() {
-      return this.spec != null;
+    /** Returns true if field leaderProjection is set (has been assigned a value) and false otherwise */
+    public boolean isSetLeaderProjection() {
+      return this.leaderProjection != null;
     }
 
-    public void setSpecIsSet(boolean value) {
+    public void setLeaderProjectionIsSet(boolean value) {
       if (!value) {
-        this.spec = null;
+        this.leaderProjection = null;
       }
     }
 
@@ -8848,11 +9429,11 @@ public class CuratorService {
         }
         break;
 
-      case SPEC:
+      case LEADER_PROJECTION:
         if (value == null) {
-          unsetSpec();
+          unsetLeaderProjection();
         } else {
-          setSpec((SetDataSpec)value);
+          setLeaderProjection((LeaderProjection)value);
         }
         break;
 
@@ -8864,8 +9445,8 @@ public class CuratorService {
       case PROJECTION:
         return getProjection();
 
-      case SPEC:
-        return getSpec();
+      case LEADER_PROJECTION:
+        return getLeaderProjection();
 
       }
       throw new IllegalStateException();
@@ -8880,8 +9461,8 @@ public class CuratorService {
       switch (field) {
       case PROJECTION:
         return isSetProjection();
-      case SPEC:
-        return isSetSpec();
+      case LEADER_PROJECTION:
+        return isSetLeaderProjection();
       }
       throw new IllegalStateException();
     }
@@ -8890,12 +9471,12 @@ public class CuratorService {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof setData_args)
-        return this.equals((setData_args)that);
+      if (that instanceof isLeader_args)
+        return this.equals((isLeader_args)that);
       return false;
     }
 
-    public boolean equals(setData_args that) {
+    public boolean equals(isLeader_args that) {
       if (that == null)
         return false;
 
@@ -8908,12 +9489,12 @@ public class CuratorService {
           return false;
       }
 
-      boolean this_present_spec = true && this.isSetSpec();
-      boolean that_present_spec = true && that.isSetSpec();
-      if (this_present_spec || that_present_spec) {
-        if (!(this_present_spec && that_present_spec))
+      boolean this_present_leaderProjection = true && this.isSetLeaderProjection();
+      boolean that_present_leaderProjection = true && that.isSetLeaderProjection();
+      if (this_present_leaderProjection || that_present_leaderProjection) {
+        if (!(this_present_leaderProjection && that_present_leaderProjection))
           return false;
-        if (!this.spec.equals(that.spec))
+        if (!this.leaderProjection.equals(that.leaderProjection))
           return false;
       }
 
@@ -8926,7 +9507,7 @@ public class CuratorService {
     }
 
     @Override
-    public int compareTo(setData_args other) {
+    public int compareTo(isLeader_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
@@ -8943,12 +9524,12 @@ public class CuratorService {
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetSpec()).compareTo(other.isSetSpec());
+      lastComparison = Boolean.valueOf(isSetLeaderProjection()).compareTo(other.isSetLeaderProjection());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSpec()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.spec, other.spec);
+      if (isSetLeaderProjection()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.leaderProjection, other.leaderProjection);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -8970,7 +9551,7 @@ public class CuratorService {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("setData_args(");
+      StringBuilder sb = new StringBuilder("isLeader_args(");
       boolean first = true;
 
       sb.append("projection:");
@@ -8981,11 +9562,11 @@ public class CuratorService {
       }
       first = false;
       if (!first) sb.append(", ");
-      sb.append("spec:");
-      if (this.spec == null) {
+      sb.append("leaderProjection:");
+      if (this.leaderProjection == null) {
         sb.append("null");
       } else {
-        sb.append(this.spec);
+        sb.append(this.leaderProjection);
       }
       first = false;
       sb.append(")");
@@ -8998,8 +9579,8 @@ public class CuratorService {
       if (projection != null) {
         projection.validate();
       }
-      if (spec != null) {
-        spec.validate();
+      if (leaderProjection != null) {
+        leaderProjection.validate();
       }
     }
 
@@ -9019,15 +9600,15 @@ public class CuratorService {
       }
     }
 
-    private static class setData_argsStandardSchemeFactory implements SchemeFactory {
-      public setData_argsStandardScheme getScheme() {
-        return new setData_argsStandardScheme();
+    private static class isLeader_argsStandardSchemeFactory implements SchemeFactory {
+      public isLeader_argsStandardScheme getScheme() {
+        return new isLeader_argsStandardScheme();
       }
     }
 
-    private static class setData_argsStandardScheme extends StandardScheme<setData_args> {
+    private static class isLeader_argsStandardScheme extends StandardScheme<isLeader_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, setData_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -9046,11 +9627,11 @@ public class CuratorService {
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 2: // SPEC
+            case 2: // LEADER_PROJECTION
               if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.spec = new SetDataSpec();
-                struct.spec.read(iprot);
-                struct.setSpecIsSet(true);
+                struct.leaderProjection = new LeaderProjection();
+                struct.leaderProjection.read(iprot);
+                struct.setLeaderProjectionIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -9066,7 +9647,7 @@ public class CuratorService {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, setData_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -9075,9 +9656,9 @@ public class CuratorService {
           struct.projection.write(oprot);
           oprot.writeFieldEnd();
         }
-        if (struct.spec != null) {
-          oprot.writeFieldBegin(SPEC_FIELD_DESC);
-          struct.spec.write(oprot);
+        if (struct.leaderProjection != null) {
+          oprot.writeFieldBegin(LEADER_PROJECTION_FIELD_DESC);
+          struct.leaderProjection.write(oprot);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -9086,35 +9667,35 @@ public class CuratorService {
 
     }
 
-    private static class setData_argsTupleSchemeFactory implements SchemeFactory {
-      public setData_argsTupleScheme getScheme() {
-        return new setData_argsTupleScheme();
+    private static class isLeader_argsTupleSchemeFactory implements SchemeFactory {
+      public isLeader_argsTupleScheme getScheme() {
+        return new isLeader_argsTupleScheme();
       }
     }
 
-    private static class setData_argsTupleScheme extends TupleScheme<setData_args> {
+    private static class isLeader_argsTupleScheme extends TupleScheme<isLeader_args> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, setData_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetProjection()) {
           optionals.set(0);
         }
-        if (struct.isSetSpec()) {
+        if (struct.isSetLeaderProjection()) {
           optionals.set(1);
         }
         oprot.writeBitSet(optionals, 2);
         if (struct.isSetProjection()) {
           struct.projection.write(oprot);
         }
-        if (struct.isSetSpec()) {
-          struct.spec.write(oprot);
+        if (struct.isSetLeaderProjection()) {
+          struct.leaderProjection.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, setData_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
@@ -9123,27 +9704,27 @@ public class CuratorService {
           struct.setProjectionIsSet(true);
         }
         if (incoming.get(1)) {
-          struct.spec = new SetDataSpec();
-          struct.spec.read(iprot);
-          struct.setSpecIsSet(true);
+          struct.leaderProjection = new LeaderProjection();
+          struct.leaderProjection.read(iprot);
+          struct.setLeaderProjectionIsSet(true);
         }
       }
     }
 
   }
 
-  public static class setData_result implements org.apache.thrift.TBase<setData_result, setData_result._Fields>, java.io.Serializable, Cloneable, Comparable<setData_result>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("setData_result");
+  public static class isLeader_result implements org.apache.thrift.TBase<isLeader_result, isLeader_result._Fields>, java.io.Serializable, Cloneable, Comparable<isLeader_result>   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isLeader_result");
 
-    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
+    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL, (short)0);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new setData_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new setData_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new isLeader_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new isLeader_resultTupleSchemeFactory());
     }
 
-    public Stat success; // required
+    public boolean success; // 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 {
@@ -9204,65 +9785,67 @@ public class CuratorService {
     }
 
     // isset id assignments
+    private static final int __SUCCESS_ISSET_ID = 0;
+    private byte __isset_bitfield = 0;
     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);
       tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Stat.class)));
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(setData_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_result.class, metaDataMap);
     }
 
-    public setData_result() {
+    public isLeader_result() {
     }
 
-    public setData_result(
-      Stat success)
+    public isLeader_result(
+      boolean success)
     {
       this();
       this.success = success;
+      setSuccessIsSet(true);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public setData_result(setData_result other) {
-      if (other.isSetSuccess()) {
-        this.success = new Stat(other.success);
-      }
+    public isLeader_result(isLeader_result other) {
+      __isset_bitfield = other.__isset_bitfield;
+      this.success = other.success;
     }
 
-    public setData_result deepCopy() {
-      return new setData_result(this);
+    public isLeader_result deepCopy() {
+      return new isLeader_result(this);
     }
 
     @Override
     public void clear() {
-      this.success = null;
+      setSuccessIsSet(false);
+      this.success = false;
     }
 
-    public Stat getSuccess() {
+    public boolean isSuccess() {
       return this.success;
     }
 
-    public setData_result setSuccess(Stat success) {
+    public isLeader_result setSuccess(boolean success) {
       this.success = success;
+      setSuccessIsSet(true);
       return this;
     }
 
     public void unsetSuccess() {
-      this.success = null;
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
     }
 
     /** Returns true if field success is set (has been assigned a value) and false otherwise */
     public boolean isSetSuccess() {
-      return this.success != null;
+      return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
     }
 
     public void setSuccessIsSet(boolean value) {
-      if (!value) {
-        this.success = null;
-      }
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
     }
 
     public void setFieldValue(_Fields field, Object value) {
@@ -9271,7 +9854,7 @@ public class CuratorService {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((Stat)value);
+          setSuccess((Boolean)value);
         }
         break;
 
@@ -9281,7 +9864,7 @@ public class CuratorService {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return getSuccess();
+        return Boolean.valueOf(isSuccess());
 
       }
       throw new IllegalStateException();
@@ -9304,21 +9887,21 @@ public class CuratorService {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof setData_result)
-        return this.equals((setData_result)that);
+      if (that instanceof isLeader_result)
+        return this.equals((isLeader_result)that);
       return false;
     }
 
-    public boolean equals(setData_result that) {
+    public boolean equals(isLeader_result that) {
       if (that == null)
         return false;
 
-      boolean this_present_success = true && this.isSetSuccess();
-      boolean that_present_success = true && that.isSetSuccess();
+      boolean this_present_success = true;
+      boolean that_present_success = true;
       if (this_present_success || that_present_success) {
         if (!(this_present_success && that_present_success))
           return false;
-        if (!this.success.equals(that.success))
+        if (this.success != that.success)
           return false;
       }
 
@@ -9331,7 +9914,7 @@ public class CuratorService {
     }
 
     @Override
-    public int compareTo(setData_result other) {
+    public int compareTo(isLeader_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
@@ -9365,15 +9948,11 @@ public class CuratorService {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("setData_result(");
+      StringBuilder sb = new StringBuilder("isLeader_result(");
       boolean first = true;
 
       sb.append("success:");
-      if (this.success == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.success);
-      }
+      sb.append(this.success);
       first = false;
       sb.append(")");
       return sb.toString();
@@ -9382,9 +9961,6 @@ public class CuratorService {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (success != null) {
-        success.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -9397,21 +9973,23 @@ public class CuratorService {
 
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
+        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+        __isset_bitfield = 0;
         read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
       } catch (org.apache.thrift.TException te) {
         throw new java.io.IOException(te);
       }
     }
 
-    private static class setData_resultStandardSchemeFactory implements SchemeFactory {
-      public setData_resultStandardScheme getScheme() {
-        return new setData_resultStandardScheme();
+    private static class isLeader_resultStandardSchemeFactory implements SchemeFactory {
+      public isLeader_resultStandardScheme getScheme() {
+        return new isLeader_resultStandardScheme();
       }
     }
 
-    private static class setData_resultStandardScheme extends StandardScheme<setData_result> {
+    private static class isLeader_resultStandardScheme extends StandardScheme<isLeader_result> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, setData_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_result struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -9422,9 +10000,8 @@ public class CuratorService {
           }
           switch (schemeField.id) {
             case 0: // SUCCESS
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.success = new Stat();
-                struct.success.read(iprot);
+              if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+                struct.success = iprot.readBool();
                 struct.setSuccessIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
@@ -9441,13 +10018,13 @@ public class CuratorService {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, setData_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_result struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.success != null) {
+        if (struct.isSetSuccess()) {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          struct.success.write(oprot);
+          oprot.writeBool(struct.success);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -9456,16 +10033,16 @@ public class CuratorService {
 
     }
 
-    private static class setData_resultTupleSchemeFactory implements SchemeFactory {
-      public setData_resultTupleScheme getScheme() {
-        return new setData_resultTupleScheme();
+    private static class isLeader_resultTupleSchemeFactory implements SchemeFactory {
+      public isLeader_resultTupleScheme getScheme() {
+        return new isLeader_resultTupleScheme();
       }
     }
 
-    private static class setData_resultTupleScheme extends TupleScheme<setData_result> {
+    private static class isLeader_resultTupleScheme extends TupleScheme<isLeader_result> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, setData_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_result struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetSuccess()) {
@@ -9473,17 +10050,16 @@ public class CuratorService {
         }
         oprot.writeBitSet(optionals, 1);
         if (struct.isSetSuccess()) {
-          struct.success.write(oprot);
+          oprot.write

<TRUNCATED>

Mime
View raw message