ZkCmdExecutor (Solr 9.11.0 solrj-zookeeper API)

java.lang.Object

org.apache.solr.common.cloud.ZkCmdExecutor

public class ZkCmdExecutor extends Object

Constructor Summary

Constructors

Constructor

Description

ZkCmdExecutor(int timeoutms)

ZkCmdExecutor(int timeoutms, ConnectionManager.IsClosed isClosed)

TODO: At this point, this should probably take a SolrZkClient in its constructor.
Method Summary

Modifier and Type

Method

Description

long

getRetryDelay()

protected void

retryDelay(int attemptCount)

Performs a retry delay if this is not the first attempt

<T> T

retryOperation(ZkOperation<T> operation)

Perform the given operation, retrying if the connection fails

void

setRetryDelay(long retryDelay)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ZkCmdExecutor
  
  public ZkCmdExecutor(int timeoutms)
- ZkCmdExecutor
  
  public ZkCmdExecutor(int timeoutms, ConnectionManager.IsClosed isClosed)
  
  TODO: At this point, this should probably take a SolrZkClient in its constructor.
  
  Parameters:
  
  timeoutms - the client timeout for the ZooKeeper clients that will be used with this class.
Method Details
- getRetryDelay
  
  public long getRetryDelay()
- setRetryDelay
  
  public void setRetryDelay(long retryDelay)
- retryOperation
  
  public <T> T retryOperation(ZkOperation<T> operation) throws org.apache.zookeeper.KeeperException, InterruptedException
  
  Perform the given operation, retrying if the connection fails
  
  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