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

ZooKeeperTestingServerManager介绍

[英]A ZooKeeperTestManager that uses the org.apache.curator.test.TestingServerto run an in-process ZooKeeper instance.
[中]使用组织的ZooKeeperTestManager。阿帕奇。馆长测验TestingServer运行进程内ZooKeeper实例。

代码示例

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

public ZooKeeperTestingServerManager() {
 this.dataDir = Files.createTempDir();
 final ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(1000, 3);
 final Builder builder = CuratorFrameworkFactory.builder()
   .connectString(endpoint)
   .retryPolicy(retryPolicy)
   .authorization("digest", (SUPER_USER + ":" + SUPER_PASSWORD).getBytes());
 curator = builder.build();
 log.info("starting CuratorFramework connected to {}", endpoint);
 curator.start();
 start();
}

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

@Override
public void close() throws InterruptedException {
 try {
  server.close();
 } catch (IOException e) {
  throw new RuntimeException(e);
 }
 stop();
 deleteQuietly(dataDir);
}

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

@Override
public void start() {
 log.info("starting zookeeper TestingServer at port={}, dataDir={}", port, dataDir);
 try {
  server = new TestingServer(port, dataDir);
  awaitUp(2, MINUTES);
 } catch (Exception e) {
  Throwables.throwIfUnchecked(e);
  throw new RuntimeException(e);
 }
}

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

@Test
public void verifyAgentReRegistersAfterRestore() throws Exception {
 // Back up zk
 zkc.backup(backupDir);
 // Start agent
 startDefaultAgent(testHost());
 awaitHostStatus(client, testHost(), UP, LONG_WAIT_SECONDS, SECONDS);
 // Restore zk, erasing task state
 zkc.stop();
 zkc.restore(backupDir);
 zkc.start();
 // Wait for agent to reregister
 awaitHostRegistered(client, testHost(), LONG_WAIT_SECONDS, SECONDS);
 awaitHostStatus(client, testHost(), UP, LONG_WAIT_SECONDS, SECONDS);
}

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

@Override
public void awaitUp(long timeout, TimeUnit timeunit) throws TimeoutException {
 Polling.awaitUnchecked(timeout, timeunit, (Callable<Object>) () -> {
  try {
   return curatorWithSuperAuth().usingNamespace(null).getChildren().forPath("/");
  } catch (Exception e) {
   return null;
  }
 });
}

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

protected ZooKeeperTestManager zooKeeperTestManager() {
 return new ZooKeeperTestingServerManager();
}

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

@Override
 public Object call() throws Exception {
  try {
   curator().usingNamespace(null).getChildren().forPath("/");
   return null;
  } catch (KeeperException.ConnectionLossException e) {
   return true;
  } catch (Exception e) {
   return null;
  }
 }
});

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

zkc.backup(backupDir);
zkc.stop();
zkc.restore(backupDir);
zkc.start();
zkc.curatorWithSuperAuth().delete().forPath(Paths.statusHostJob(testHost(), fooJob.getId()));

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

@Override
public void awaitDown(int timeout, TimeUnit timeunit) throws TimeoutException {
 Polling.awaitUnchecked(timeout, timeunit, (Callable<Object>) () -> {
  try {
   curatorWithSuperAuth().usingNamespace(null).getChildren().forPath("/");
   return null;
  } catch (KeeperException.ConnectionLossException e) {
   return true;
  } catch (Exception e) {
   return null;
  }
 });
}

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

@Before
public void setup() throws Exception {
 zk = new ZooKeeperTestingServerManager();
 dueh = Thread.getDefaultUncaughtExceptionHandler();
 Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
  @Override
  public void uncaughtException(final Thread thread, final Throwable th) {}
 });
 stateDir = Files.createTempDirectory("helios-agent-conflict-test");
 first = makeAgent("first");
 second = makeAgent("second");
}

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

@Override
 public Object call() throws Exception {
  try {
   return curator().usingNamespace(null).getChildren().forPath("/");
  } catch (Exception e) {
   return null;
  }
 }
});

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

public ZooKeeperTestingServerManager(final String namespace) {
 this.dataDir = Files.createTempDir();
 final ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(1000, 3);
 Builder builder = CuratorFrameworkFactory.builder()
   .connectString(endpoint)
   .retryPolicy(retryPolicy);
 if (namespace != null) {
  builder = builder.namespace(namespace);
 }
 curator = builder.build();
 curator.start();
 start();
}

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

@Override
public void close() throws InterruptedException {
 try {
  server.close();
 } catch (IOException e) {
  Throwables.propagate(e);
 }
 stop();
 deleteQuietly(dataDir);
}

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

@Override
public void start() {
 try {
  server = new TestingServer(port, dataDir);
  awaitUp(2, MINUTES);
 } catch (Exception e) {
  throw Throwables.propagate(e);
 }
}