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

ZooKeeperClientProvider介绍

暂无

代码示例

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

private ZooKeeperClient client(final String tag) {
 return provider.get("persistent_directory_" + tag);
}

代码示例来源：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: spotify/helios

final ZooKeeperModelReporter modelReporter =
  new ZooKeeperModelReporter(metrics.getZooKeeperMetrics());
final ZooKeeperClientProvider zkClientProvider = new ZooKeeperClientProvider(
  zooKeeperClient, modelReporter);
   new JobHistoryReaper(model, zkClientProvider.get("jobHistoryReaper")));
} else {
 log.info("Reaping of orphaned jobs disabled");

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

/**
 * Returns the job configuration for the job specified by {@code id} as a
 * {@link Job} object. A return value of null indicates the job doesn't exist.
 */
@Override
public Job getJob(final JobId id) {
 log.debug("getting job: {}", id);
 final ZooKeeperClient client = provider.get("getJobId");
 return getJob(client, id);
}

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

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

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

@Override
public AgentInfo getAgentInfo(final String host) {
 return getAgentInfo(provider.get("getAgentInfo"), host);
}

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

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

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

/**
 * Undoes the effect of {@link ZooKeeperMasterModel#registerHost(String, String)}.  Cleans up
 * any leftover host-related things.
 */
@Override
public void deregisterHost(final String host)
  throws HostNotFoundException, HostStillInUseException {
 final ZooKeeperClient client = provider.get("deregisterHost");
 ZooKeeperRegistrarUtil.deregisterHost(client, host);
}

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

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

/**
 * Creates a config entry within the specified agent to un/deploy a job, or more generally, change
 * the deployment status according to the {@code Goal} value in {@link Deployment}.
 */
@Override
public void deployJob(final String host, final Deployment deployment, final String token)
  throws JobDoesNotExistException, JobAlreadyDeployedException, HostNotFoundException,
      JobPortAllocationConflictException, TokenVerificationException {
 final ZooKeeperClient client = provider.get("deployJob");
 deployJobRetry(client, host, deployment, 0, token);
}

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

@Override
public DeploymentGroup getDeploymentGroup(final String name)
  throws DeploymentGroupDoesNotExistException {
 log.debug("getting deployment-group: {}", name);
 final ZooKeeperClient client = provider.get("getDeploymentGroup");
 return getDeploymentGroup(client, name);
}

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

@Override
public Map<String, String> getHostLabels(final String host) {
 final ZooKeeperClient client = provider.get("getHostStatus");
 if (!ZooKeeperRegistrarUtil.isHostRegistered(client, host)) {
  return emptyMap();
 }
 final Map<String, String> labels = getLabels(client, host);
 return labels == null ? emptyMap() : labels;
}

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

@Override
public boolean isHostUp(final String host) {
 final ZooKeeperClient client = provider.get("isHostUp");
 return ZooKeeperRegistrarUtil.isHostRegistered(client, host) && checkHostUp(client, host);
}

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

/**
 * Returns a list of the hosts/agents that have been registered.
 */
@Override
public List<String> listHosts() {
 try {
  // TODO (dano): only return hosts whose agents completed registration (i.e. has id nodes)
  return provider.get("listHosts").getChildren(Paths.configHosts());
 } catch (KeeperException.NoNodeException e) {
  return emptyList();
 } catch (KeeperException e) {
  throw new HeliosRuntimeException("listing hosts failed", e);
 }
}

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

@Override
public List<String> getDeploymentGroupHosts(final String name)
  throws DeploymentGroupDoesNotExistException {
 log.debug("getting deployment group hosts: {}", name);
 final ZooKeeperClient client = provider.get("getDeploymentGroupHosts");
 final DeploymentGroup deploymentGroup = getDeploymentGroup(client, name);
 if (deploymentGroup == null) {
  throw new DeploymentGroupDoesNotExistException(name);
 }
 return getHosts(client, Paths.statusDeploymentGroupHosts(name));
}

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

/**
 * Registers a host into ZooKeeper.  The {@code id} is initially generated randomly by the Agent
 * and persisted on disk.  This way, in the event that you have two agents attempting to register
 * with the same value of @{code host}, the first one will win.
 */
@Override
public void registerHost(final String host, final String id) {
 final ZooKeeperClient client = provider.get("registerHost");
 try {
  ZooKeeperRegistrarUtil.registerHost(client, Paths.configHostId(host), host, id);
 } catch (Exception e) {
  throw new HeliosRuntimeException("registering host " + host + " failed", e);
 }
}

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

/**
 * Returns a list of the host names of the currently running masters.
 */
@Override
public List<String> getRunningMasters() {
 final ZooKeeperClient client = provider.get("getRunningMasters");
 try {
  final List<String> masters = client.getChildren(Paths.statusMaster());
  final ImmutableList.Builder<String> upMasters = ImmutableList.builder();
  for (final String master : masters) {
   if (client.exists(Paths.statusMasterUp(master)) != null) {
    upMasters.add(master);
   }
  }
  return upMasters.build();
 } catch (KeeperException e) {
  throw new HeliosRuntimeException("listing masters failed", e);
 }
}

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

throw new JobDoesNotExistException(jobId);
final ZooKeeperClient client = provider.get("getJobHistory");
final List<String> hosts;

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

log.debug("getting deployment groups");
final String folder = Paths.configDeploymentGroups();
final ZooKeeperClient client = provider.get("getDeploymentGroups");
try {
 final List<String> names;