org.apache.solr.common.cloud
Class ZkCmdExecutor

java.lang.Object
  extended by org.apache.solr.common.cloud.ZkCmdExecutor

public class ZkCmdExecutor
extends Object


Constructor Summary
ZkCmdExecutor(int timeoutms)
          TODO: At this point, this should probably take a SolrZkClient in it's constructor.
 
Method Summary
 void ensureExists(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, SolrZkClient zkClient)
           
 void ensureExists(String path, SolrZkClient zkClient)
           
 List<org.apache.zookeeper.data.ACL> getAcl()
           
 long getRetryDelay()
           
protected  void retryDelay(int attemptCount)
          Performs a retry delay if this is not the first attempt
<T> T
retryOperation(ZkOperation operation)
          Perform the given operation, retrying if the connection fails
 void setAcl(List<org.apache.zookeeper.data.ACL> acl)
           
 void setRetryDelay(long retryDelay)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZkCmdExecutor

public ZkCmdExecutor(int timeoutms)
TODO: At this point, this should probably take a SolrZkClient in it's constructor.

Parameters:
timeoutms - the client timeout for the ZooKeeper clients that will be used with this class.
Method Detail

getAcl

public List<org.apache.zookeeper.data.ACL> getAcl()

setAcl

public void setAcl(List<org.apache.zookeeper.data.ACL> acl)

getRetryDelay

public long getRetryDelay()

setRetryDelay

public void setRetryDelay(long retryDelay)

retryOperation

public <T> T retryOperation(ZkOperation operation)
                 throws org.apache.zookeeper.KeeperException,
                        InterruptedException
Perform the given operation, retrying if the connection fails

Throws:
org.apache.zookeeper.KeeperException
InterruptedException

ensureExists

public void ensureExists(String path,
                         SolrZkClient zkClient)
                  throws org.apache.zookeeper.KeeperException,
                         InterruptedException
Throws:
org.apache.zookeeper.KeeperException
InterruptedException

ensureExists

public void ensureExists(String path,
                         byte[] data,
                         org.apache.zookeeper.CreateMode createMode,
                         SolrZkClient zkClient)
                  throws org.apache.zookeeper.KeeperException,
                         InterruptedException
Throws:
org.apache.zookeeper.KeeperException
InterruptedException

retryDelay

protected void retryDelay(int attemptCount)
                   throws InterruptedException
Performs a retry delay if this is not the first attempt

Parameters:
attemptCount - the number of the attempts performed so far
Throws:
InterruptedException


Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.