- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.delete()
方法的一些代码示例,展示了ZooKeeperOperations.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperOperations.delete()
方法的具体详情如下:
包路径:com.spotify.helios.servicescommon.coordination.ZooKeeperOperations
类名称: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));
本文整理了Java中org.apache.zookeeper.recipes.lock.ZooKeeperOperation.execute()方法的一些代码示例,展示了ZooKeeperOperat
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperOperation.execute()方法的一些代码示例,展示了ZooKeeperOperation.
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.set()方法的一些代码示例,展示了ZooKe
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.check()方法的一些代码示例,展示了Zoo
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.create()方法的一些代码示例,展示了Zo
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.delete()方法的一些代码示例,展示了Zo
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperation.register()方法的一些代码示例,展示了Z
我是一名优秀的程序员,十分优秀!