本文整理了Java中com.spotify.helios.ZooKeeperTestingClusterManager.peerDir()方法的一些代码示例，展示了ZooKeeperTestingClusterManager.peerDir()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperTestingClusterManager.peerDir()方法的具体详情如下：
包路径：com.spotify.helios.ZooKeeperTestingClusterManager
类名称：ZooKeeperTestingClusterManager
方法名：peerDir

ZooKeeperTestingClusterManager.peerDir介绍

暂无

代码示例

代码示例来源：origin: spotify/helios

public void resetPeer(final int id) {
 if (zkServers.get(id).getQuorumPeer().isRunning()) {
  throw new IllegalStateException("peer is still running: " + id);
 }
 final Path peerDir = peerDir(id);
 try {
  // Wipe and recreate the data directory
  FileUtils.deleteDirectory(peerDir.toFile());
  Files.createDirectory(peerDir);
 } catch (IOException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: spotify/helios

private List<InstanceSpec> createPeers(final int numPeers) {
 final ImmutableList.Builder<InstanceSpec> peers = ImmutableList.builder();
 for (int i = 0; i < numPeers; i++) {
  final int port = temporaryPorts.localPort("zk-client" + i);
  final int electionPort = temporaryPorts.localPort("zk-elect" + i);
  final int quorumPort = temporaryPorts.localPort("zk-quorum" + i);
  final Path peerDir = peerDir(i);
  try {
   Files.createDirectory(peerDir);
  } catch (IOException e) {
   throw new RuntimeException(e);
  }
  final InstanceSpec spec = new InstanceSpec(
    peerDir.toFile(),
    port,
    electionPort,
    quorumPort,
    true,
    i);
  peers.add(spec);
 }
 return peers.build();
}

代码示例来源：origin: at.molindo/helios-testing-common

public void resetPeer(final int id) {
 if (zkServers.get(id).getQuorumPeer().isRunning()) {
  throw new IllegalStateException("peer is still running: " + id);
 }
 final Path peerDir = peerDir(id);
 try {
  // Wipe and recreate the data directory
  FileUtils.deleteDirectory(peerDir.toFile());
  Files.createDirectory(peerDir);
 } catch (IOException e) {
  throw Throwables.propagate(e);
 }
}

代码示例来源：origin: at.molindo/helios-testing-common

private List<InstanceSpec> createPeers(final int n) {
 final ImmutableList.Builder<InstanceSpec> peers = ImmutableList.builder();
 for (int i = 0; i < n; i++) {
  final int port = temporaryPorts.localPort("zk-client" + i);
  final int electionPort = temporaryPorts.localPort("zk-elect" + i);
  final int quorumPort = temporaryPorts.localPort("zk-quorum" + i);
  final Path peerDir = peerDir(i);
  try {
   Files.createDirectory(peerDir);
  } catch (IOException e) {
   throw Throwables.propagate(e);
  }
  final InstanceSpec spec = new InstanceSpec(
    peerDir.toFile(),
    port,
    electionPort,
    quorumPort,
    true,
    i);
  peers.add(spec);
 }
 return peers.build();
}