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

ZNode.child介绍

暂无

代码示例

代码示例来源：origin: griddynamics/jagger

private ZNode lockDir() {
  return node.child(lockPath);
}

代码示例来源：origin: griddynamics/jagger

@Override
public Set<NodeId> getAvailableNodes(NodeType type) {
  Set<NodeId> result = Sets.newHashSet();
  ZNode typeNode = rootNode.child(CoordinationUtil.nodeNameOf(type));
  for (ZNode node : typeNode.children()) {
    if (node.hasChild(CoordinationUtil.AVAILABLE_NODE_NAME)) {
      result.add(NodeId.of(type, node.getShortPath()));
    }
  }
  return result;
}

代码示例来源：origin: griddynamics/jagger

@Override
public void terminate() {
  log.debug("termination signal received");
  if(zooKeeperServer != null) {
    try {
      if (zoo != null) {
        zoo.root().child(rootNode).removeWithChildren();
      }
      zooKeeperServer.shutdown();
    } catch (Exception e) {
      log.warn("Error during zookeeper termination. Message: {}", e.getMessage());
    }
  }
}

代码示例来源：origin: griddynamics/jagger

log.info("Going to register node {} with {} workers", nodeContext.getId(), workers.size());
ZNode typeNode = rootNode.child(CoordinationUtil.nodeNameOf(nodeContext.getId().getType()));
if (typeNode.hasChild(nodeContext.getId().getIdentifier())) {
  typeNode.child(nodeContext.getId().getIdentifier()).removeWithChildren();
ZNode statuses = rootNode.child(CoordinationUtil.STATUSES_NODE_NAME);

代码示例来源：origin: griddynamics/jagger

@Override
public <C extends Command<R>, R extends Serializable> void run(final C command, final NodeCommandExecutionListener<C> listener, final AsyncCallback<R> callback) {
  ZNode commandNode = rootNode.child(nodeId.getType().name().toLowerCase()).child(nodeId.getIdentifier()).child(command.getClass().getName());
  ZNode queueNode = commandNode.child("queue");
  ZNode resultNode = commandNode.child("result");

代码示例来源：origin: griddynamics/jagger

@Override
public boolean canExecuteCommands(NodeId nodeId, Set<Qualifier<?>> qualifiers) {
  ZNode typeNode = rootNode.child(CoordinationUtil.nodeNameOf(nodeId.getType()));
  String identifier = nodeId.getIdentifier();
  if (!typeNode.hasChild(identifier)) {
    throw new CoordinatorException("Node with id " + nodeId + " is not found");
  }
  ZNode node = typeNode.child(identifier);
  if (!node.hasChild(CoordinationUtil.AVAILABLE_NODE_NAME)) {
    return false;
  }
  for (Qualifier<?> qualifier : qualifiers) {
    if (!node.hasChild(nodeNameOf(qualifier))) {
      return false;
    }
  }
  return true;
}

代码示例来源：origin: griddynamics/jagger

private static <C extends Command<R>, R extends Serializable> void executeCommand(CommandExecutor<C, R> executor, ZNode executorNode, final QueueEntry<C, R> entry, final NodeContext nodeContext) {
  String relativePath = entry.getResultPath().substring(executorNode.getPath().length() + 1);
  final ZNode output = executorNode.child(relativePath);
  final NodeCommandExecutionListener<C> listener = entry.getListener();
  try {
    C command = entry.getCommand();
    listener.onCommandExecutionStarted(command, nodeContext);
    R result = executor.execute(command, nodeContext);
    log.debug("Command {} executed", command);
    listener.onCommandExecuted(command);
    output.setObject(CommandExecutionResult.success(result));
  } catch (Throwable throwable) {
    // todo add fail event
    log.error("error during task execution", throwable);
    output.setObject(CommandExecutionResult.fail(throwable));
  }
}

代码示例来源：origin: griddynamics/jagger

public void initialize() {
  ZooKeeperFactory zooKeeperFactory = new ZooKeeperFactory();
  zooKeeperFactory.setConnectString(endpoint);
  zooKeeperFactory.setSessionTimeout(sessionTimeout);
  log.info("Connect to {} endpoint with timeout {}", endpoint, sessionTimeout);
  IZookeeper zooKeeper = null;
  try {
    zooKeeper = zooKeeperFactory.create();
    zoo = new Zoo(zooKeeperFactory.create());
    // TODO: timeout only 40000. svi.
    if (zoo.root().hasChild(rootNode)) {
      log.info("ZNode [" + rootNode + "] was found.");
      zoo.root().child(rootNode).removeWithChildren();
      log.info("ZNode [" + rootNode + "] with children nodes were removed.");
    }
    zoo.root().createChild(znode().withPath(rootNode));
    log.info("ZNode [" + rootNode + "] was created.");
  } finally {
    if (zooKeeper != null) {
      try {
        zooKeeper.close();
      } catch (InterruptedException e) {
        // do nothing
      }
    }
  }
}