gpt4 book ai didi

com.spotify.helios.servicescommon.coordination.ZooKeeperClientProvider.()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-20 10:50:31 24 4
gpt4 key购买 nike

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

ZooKeeperClientProvider.<init>介绍

暂无

代码示例

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

@Before
public void setUp() throws Exception {
 // make zookeeper interfaces
 curator = zk().curatorWithSuperAuth();
 final ZooKeeperClientProvider zkcp = new ZooKeeperClientProvider(
   new DefaultZooKeeperClient(curator), ZooKeeperModelReporter.noop());
 final List<EventSender> eventSenders = Collections.emptyList();
 zkMasterModel = new ZooKeeperMasterModel(zkcp, getClass().getName(), eventSenders, "");
 startDefaultMaster();
 agent = startDefaultAgent(TEST_HOST);
 client = defaultClient();
 awaitHostRegistered(client, TEST_HOST, LONG_WAIT_SECONDS, SECONDS);
}

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

final ZooKeeperClientProvider zkClientProvider = new ZooKeeperClientProvider(
  zooKeeperClient, modelReporter);

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

final ZooKeeperModelReporter modelReporter =
  new ZooKeeperModelReporter(metrics.getZooKeeperMetrics());
final ZooKeeperClientProvider zkClientProvider = new ZooKeeperClientProvider(
  zooKeeperClient, modelReporter);

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

@Test
 public void testRemoveJobDeletesHistory() throws Exception {
  startDefaultAgent(testHost());
  awaitHostStatus(testHost(), UP, LONG_WAIT_SECONDS, SECONDS);

  final JobId jobId = createJob(testJobName, testJobVersion, BUSYBOX, IDLE_COMMAND);

  deployJob(jobId, testHost());
  awaitJobState(
    defaultClient(), testHost(), jobId, TaskStatus.State.RUNNING, LONG_WAIT_SECONDS, SECONDS);
  undeployJob(jobId, testHost());
  awaitJobUndeployed(defaultClient(), testHost(), jobId, LONG_WAIT_SECONDS, SECONDS);

  final ZooKeeperClient zkClient = new ZooKeeperClientProvider(
    new DefaultZooKeeperClient(zk().curatorWithSuperAuth()), ZooKeeperModelReporter.noop())
    .get("test-client");

  // Check that there's some history events
  assertNotNull(zkClient.stat(Paths.historyJob(jobId)));

  // Remove job
  final JobDeleteResponse response =
    defaultClient().deleteJob(jobId).get(WAIT_TIMEOUT_SECONDS, SECONDS);
  assertEquals(JobDeleteResponse.Status.OK, response.getStatus());

  // Verify that history is gone
  assertNull(zkClient.stat(Paths.historyJob(jobId)));
 }
}

代码示例来源:origin: at.molindo/helios-services

final ZooKeeperClientProvider zkClientProvider = new ZooKeeperClientProvider(
  zooKeeperClient, modelReporter);
final KafkaClientProvider kafkaClientProvider = new KafkaClientProvider(

代码示例来源:origin: at.molindo/helios-services

final ZooKeeperModelReporter modelReporter = new ZooKeeperModelReporter(
  riemannFacade, metrics.getZooKeeperMetrics());
final ZooKeeperClientProvider zkClientProvider = new ZooKeeperClientProvider(
  zooKeeperClient, modelReporter);
final KafkaClientProvider kafkaClientProvider = new KafkaClientProvider(

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