个人中心
gpt4 book ai didi

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

转载 作者：知者 更新时间：2024-03-19 03:51:31 27 4
gpt4 key购买 nike

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

ZooKeeperClient.persistentEphemeralNode介绍

暂无

代码示例

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

@Override
public PersistentEphemeralNode persistentEphemeralNode(final String path,
                            final PersistentEphemeralNode.Mode mode,
                            final byte[] data) {
 return client.persistentEphemeralNode(path, mode, data);
}

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

log.debug("Creating up node: {}", upPath);
client.ensurePath(upPath, true);
upNode = client.persistentEphemeralNode(upPath, EPHEMERAL, EMPTY_BYTES);
upNode.start();

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

@Override
 public boolean tryToRegister(final ZooKeeperClient client) throws KeeperException {

  client.ensurePath(Paths.configHosts());
  client.ensurePath(Paths.configJobs());
  client.ensurePath(Paths.configJobRefs());
  client.ensurePath(Paths.statusHosts());
  client.ensurePath(Paths.statusMasters());
  client.ensurePath(Paths.historyJobs());
  client.ensurePath(Paths.configDeploymentGroups());
  client.ensurePath(Paths.statusDeploymentGroups());

  if (upNode == null) {
   final String upPath = Paths.statusMasterUp(name);
   client.ensurePath(upPath, true);
   upNode = client.persistentEphemeralNode(upPath, Mode.EPHEMERAL, new byte[]{});
   upNode.start();
  }

  log.info("ZooKeeper registration complete");
  return true;
 }
}

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

@Override
public PersistentEphemeralNode persistentEphemeralNode(final String path,
                            final PersistentEphemeralNode.Mode mode,
                            final byte[] data) {
 return client.persistentEphemeralNode(path, mode, data);
}

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

final String upPath = Paths.statusHostUp(name);
log.debug("Creating up node: {}", upPath);
upNode = client.persistentEphemeralNode(upPath, EPHEMERAL, EMPTY_BYTES);
upNode.start();

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

@Override
 public void tryToRegister(final ZooKeeperClient client) throws KeeperException {

  client.ensurePath(Paths.configHosts());
  client.ensurePath(Paths.configJobs());
  client.ensurePath(Paths.configJobRefs());
  client.ensurePath(Paths.statusHosts());
  client.ensurePath(Paths.statusMasters());
  client.ensurePath(Paths.historyJobs());
  client.ensurePath(Paths.configDeploymentGroups());
  client.ensurePath(Paths.statusDeploymentGroups());

  if (upNode == null) {
   final String upPath = Paths.statusMasterUp(name);
   upNode = client.persistentEphemeralNode(upPath, Mode.EPHEMERAL, new byte[]{});
   upNode.start();
  }

  log.info("ZooKeeper registration complete");
 }
}

27 4 0
文章推荐： org.jooq.tools.json.Yytoken类的使用及代码示例
文章推荐： org.jooq.tools.json.Yylex.yycharat()方法的使用及代码示例
文章推荐： com.spotify.helios.servicescommon.coordination.ZooKeeperClient.listRecursive()方法的使用及代码示例
文章推荐： com.spotify.helios.servicescommon.coordination.ZooKeeperClient.getChildren()方法的使用及代码示例
知者
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com