gpt4 book ai didi

com.spotify.helios.ZooKeeperTestingServerManager.start()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-19 02:43:31 26 4
gpt4 key购买 nike

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

ZooKeeperTestingServerManager.start介绍

暂无

代码示例

代码示例来源: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

@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

zkc.start();

代码示例来源: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();
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com