gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-13 11:01:22 26 4
gpt4 key购买 nike

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

ZooKeeperOperations.delete介绍

暂无

代码示例

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

operations.add(delete(node));
  operations.add(delete(Paths.configJobHost(job, host)));
  operations.add(delete(s));
operations.add(delete(Paths.configHostJobs(host)));
 operations.add(delete(node));
 operations.add(delete(Paths.configHostPort(host, Integer.valueOf(port))));
operations.add(delete(Paths.configHostPorts(host)));
 operations.add(delete(idPath));
operations.add(delete(Paths.configHost(host)));

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

operations.add(delete(node));
operations.add(delete(Paths.configHostId(host)));
operations.add(create(Paths.configHostId(host), hostId.getBytes(UTF_8)));

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

final UUID jobCreationOperationId = getJobCreation(client, id);
if (jobCreationOperationId != null) {
 operations.add(delete(Paths.configJobCreation(id, jobCreationOperationId)));
operations.add(delete(Paths.configJobHosts(id)),
  delete(Paths.configJobRefShort(id)),
  delete(Paths.configJob(id)),

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

operations.add(delete(Paths.statusDeploymentGroupTasks(deploymentGroup.getName())));
operations.add(set(Paths.statusDeploymentGroup(deploymentGroup.getName()), status));

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

public RollingUpdateOp nextTask(final List<ZooKeeperOperation> operations) {
 final List<ZooKeeperOperation> ops = Lists.newArrayList(operations);
 final List<Map<String, Object>> events = Lists.newArrayList();
 final RolloutTask task = tasks.getRolloutTasks().get(tasks.getTaskIndex());
 // Update the task index, delete tasks if done
 if (tasks.getTaskIndex() + 1 == tasks.getRolloutTasks().size()) {
  final DeploymentGroupStatus status = DeploymentGroupStatus.newBuilder()
    .setState(DONE)
    .build();
  // We are done -> delete tasks & update status
  ops.add(delete(Paths.statusDeploymentGroupTasks(deploymentGroup.getName())));
  ops.add(set(Paths.statusDeploymentGroup(deploymentGroup.getName()),
    status));
  // Emit an event signalling that we're DONE!
  events.add(eventFactory.rollingUpdateDone(deploymentGroup));
 } else {
  ops.add(
    set(Paths.statusDeploymentGroupTasks(deploymentGroup.getName()), tasks.toBuilder()
      .setTaskIndex(tasks.getTaskIndex() + 1)
      .build()));
  // Only emit an event if the task resulted in taking in action. If there are no ZK operations
  // the task was effectively a no-op.
  if (!operations.isEmpty()) {
   events.add(eventFactory.rollingUpdateTaskSucceeded(deploymentGroup, task));
  }
 }
 return new RollingUpdateOp(ImmutableList.copyOf(ops), ImmutableList.copyOf(events));
}

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

return ImmutableList.of(delete(nodes));

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

operations.add(delete(tasksPath));
} else {
 operations.add(delete(tasksPath));

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

client.transaction(delete(nodes));

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

operations.add(delete(path));

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

.setState(DONE)
   .build();
 ops.add(delete(Paths.statusDeploymentGroupTasks(deploymentGroup.getName())));
 events.add(eventFactory.rollingUpdateDone(deploymentGroup));
} else {

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

operations.add(delete(node));
   operations.add(delete(Paths.configJobHost(job, host)));
   operations.add(delete(s));
operations.add(delete(Paths.configHostJobs(host)));
 operations.add(delete(node));
 operations.add(delete(Paths.configHostPort(host, Integer.valueOf(port))));
operations.add(delete(Paths.configHostPorts(host)));
 operations.add(delete(idPath));
operations.add(delete(Paths.configHost(host)));

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

final UUID jobCreationOperationId = getJobCreation(client, id);
if (jobCreationOperationId != null) {
 operations.add(delete(Paths.configJobCreation(id, jobCreationOperationId)));
operations.add(delete(Paths.configJobHosts(id)),
        delete(Paths.configJobRefShort(id)),
        delete(Paths.configJob(id)),

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

private List<ZooKeeperOperation> getUndeployOperations(final ZooKeeperClient client,
                           final String host, final JobId jobId,
                           final String token)
  throws HostNotFoundException, JobNotDeployedException, TokenVerificationException {
 assertHostExists(client, host);
 final Deployment deployment = getDeployment(host, jobId);
 if (deployment == null) {
  throw new JobNotDeployedException(host, jobId);
 }
 final Job job = getJob(client, jobId);
 verifyToken(token, job);
 final String configHostJobPath = Paths.configHostJob(host, jobId);
 try {
  // use listRecursive to remove both job node and its child creation node
  final List<String> nodes = newArrayList(reverse(client.listRecursive(configHostJobPath)));
  nodes.add(Paths.configJobHost(jobId, host));
  final List<Integer> staticPorts = staticPorts(job);
  for (int port : staticPorts) {
   nodes.add(Paths.configHostPort(host, port));
  }
  return ImmutableList.of(delete(nodes));
 } catch (NoNodeException e) {
  // This method is racy since it's possible someone undeployed the job after we called
  // getDeployment and checked the job exists. If we now discover the job is undeployed,
  // throw an exception and handle it the same as if we discovered this earlier.
  throw new JobNotDeployedException(host, jobId);
 } catch (KeeperException e) {
  throw new HeliosRuntimeException("calculating undeploy operations failed", e);
 }
}

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

client.transaction(delete(nodes));

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