io.fabric8.kubernetes.api.model.Node类的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.4k)|赞(0)|评价(0)|浏览(500)

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

Node介绍

暂无

代码示例

代码示例来源：origin: fabric8io/kubernetes-client

  1. /**
  2.   * Returns the ready condition of the node.
  3.   * 
  4.   * @param node The target node.
  5.   * @return The {@link NodeCondition} or null if not found.
  6.   */
  7.  private static NodeCondition getNodeReadyCondition(Node node) {
  8.   Utils.checkNotNull(node, "Node can't be null.");
  10.   if (node.getStatus() == null || node.getStatus().getConditions() == null) {
  11.    return null;
  12.   }
  14.   for (NodeCondition condition : node.getStatus().getConditions()) {
  15.    if (NODE_READY.equals(condition.getType())) {
  16.     return condition;
  17.    }
  18.   }
  19.   return null;
  20.  }
  21. }

代码示例来源：origin: io.fabric8.schemagenerator/kubernetes-model

  1. public NodeBuilder(){
  2.   this(new Node());
  3. }
  4. public NodeBuilder( NodeFluent<?> fluent ){

代码示例来源：origin: org.domeos/kubernetes-model

  1. public NodeFluentImpl(Node instance){
  2.     this.withApiVersion(instance.getApiVersion()); 
  3.     this.withKind(instance.getKind()); 
  4.     this.withMetadata(instance.getMetadata()); 
  5.     this.withSpec(instance.getSpec()); 
  6.     this.withStatus(instance.getStatus()); 
  7. }

代码示例来源：origin: LendingClub/mercator

  1. public void scanNode(Node node) {
  2.   ObjectNode n = mapper.createObjectNode();
  3.   ObjectMeta meta = node.getMetadata();
  4.   n.put("nodeUid", meta.getUid());
  5.   n.put("resourceVersion", meta.getResourceVersion());
  6.   n.put("name", meta.getName());
  7.   n.put("namespace", meta.getNamespace());
  8.   
  9.   
  10.   n.put("clusterName", meta.getClusterName());
  11.   n.put("generateName", meta.getGenerateName());
  12.   n.put("creationTimestamp", meta.getCreationTimestamp());
  13.   n.put("deletionTimestamp", meta.getDeletionTimestamp());
  14.   n.put("deletionGracePeriod", meta.getDeletionGracePeriodSeconds());
  15.   n.put("selfLink", meta.getSelfLink());
  16.   NodeStatus ns = node.getStatus();
  17.   NodeSpec nodeSpec = node.getSpec();
  18.   n.put("externalId", nodeSpec.getExternalID());
  19.   n.put("unschedulable", nodeSpec.getUnschedulable());
  20.   n.put("podCIDR", nodeSpec.getPodCIDR());
  21.   n.put("providerId", nodeSpec.getProviderID());
  22.   n.put("clusterId", clusterId);
  23.   getNeoRxClient().execCypher("merge (n:KubeNode {nodeUid:{nodeUid}}) set n.clusterId={clusterId}, n+={props}",
  24.       "nodeUid", meta.getUid(), "props", n, "clusterId", clusterId);
  25. }

代码示例来源：origin: fabric8io/fabric8-maven-plugin

  1. if (items != null) {
  2.   for (Node item : items) {
  3.     NodeStatus status = item.getStatus();
  4.     if (!found && status != null) {
  5.       List<NodeAddress> addresses = status.getAddresses();
  6.       NodeSpec spec = item.getSpec();
  7.       if (spec != null) {
  8.         clusterIP = spec.getExternalID();

代码示例来源：origin: strimzi/strimzi-kafka-operator

  1. /**
  2.  * Write the rack-id
  3.  *
  4.  * @return if the operation was executed successfully
  5.  */
  6. public boolean writeRack() {
  7.   Map<String, String> nodeLabels = client.nodes().withName(config.getNodeName()).get().getMetadata().getLabels();
  8.   log.info("NodeLabels = {}", nodeLabels);
  9.   String rackId = nodeLabels.get(config.getRackTopologyKey());
  10.   log.info("Rack: {} = {}", config.getRackTopologyKey(), rackId);
  11.   if (rackId == null) {
  12.     log.error("Node {} doesn't have the label {} for getting the rackid",
  13.         config.getNodeName(), config.getRackTopologyKey());
  14.     return false;
  15.   }
  16.   return write(FILE_RACK_ID, rackId);
  17. }

代码示例来源：origin: fabric8io/jube

  1. @Override
  2. public NodeList getNodes() {
  3.   // TODO we should replace HostNode with Node...
  4.   NodeList answer = new NodeList();
  5.   List<Node> items = new ArrayList<>();
  6.   answer.setItems(items);
  7.   Collection<HostNode> values = getHostNodes().values();
  8.   for (HostNode value : values) {
  9.     Node minion = new Node();
  10.     NodeSpec nodeSpec = new NodeSpec();
  11.     minion.setSpec(nodeSpec);
  12.     ObjectMeta metadata = new ObjectMeta();
  13.     metadata.setName(value.getId());
  14.     minion.setMetadata(metadata);
  15.     // TODO no hostName on a minion
  16.     //minion.setHostIP(value.getHostName());
  17.     items.add(minion);
  18.   }
  19.   return answer;
  20. }

代码示例来源：origin: stackoverflow.com

  1. open XML  
  2. while xml source has next  
  3.  {  
  4.  add next node to allNodes, key = node.uniqueId, Val = node  
  5.  if next node.kind not in uniqueKinds, add node.kind to uniqueKinds  
  6.  }
  9. ClassNodeImporter method makeFilteredeMap:  
  11.   private boolean makeFilteredeMap() {
  12.     if (uniqueKinds.isEmpty()) {
  13.       return false;
  14.     } else {
  15.       for (String k : uniqueKinds) {
  16.         HashMap<String, Node> aMap = new HashMap<String, Node>();
  17.         for (Node n : allNodes) {
  18.           if (n.getKind().equals(k)) {
  19.             aMap.put(n.getCode(), n);
  20.           }
  21.         }
  22.         filteredNodes.put(k, aMap);
  23.       }
  24.       return true;
  25.     }
  26.   }

代码示例来源：origin: org.domeos/kubernetes-model

  1. public NodeBuilder(NodeFluent<?> fluent,Node instance,Boolean validationEnabled){
  2.     this.fluent = fluent; 
  3.     fluent.withApiVersion(instance.getApiVersion()); 
  4.     fluent.withKind(instance.getKind()); 
  5.     fluent.withMetadata(instance.getMetadata()); 
  6.     fluent.withSpec(instance.getSpec()); 
  7.     fluent.withStatus(instance.getStatus()); 
  8.     this.validationEnabled = validationEnabled; 
  9. }
  10. public NodeBuilder(Node instance){

代码示例来源：origin: jenkinsci/kubernetes-pipeline-plugin

  1. .endMetadata()
  2. .withNewSpec()
  3.   .withNodeSelector(node != null ? node.getMetadata().getLabels() : new HashMap<String, String>())
  4.   .withVolumes(volumes)
  5.   .withContainers(containers)

代码示例来源：origin: org.domeos/kubernetes-model

  1. public NodeBuilder(Node instance,Boolean validationEnabled){
  2.     this.fluent = this; 
  3.     this.withApiVersion(instance.getApiVersion()); 
  4.     this.withKind(instance.getKind()); 
  5.     this.withMetadata(instance.getMetadata()); 
  6.     this.withSpec(instance.getSpec()); 
  7.     this.withStatus(instance.getStatus()); 
  8.     this.validationEnabled = validationEnabled; 
  9. }

代码示例来源：origin: fabric8io/kubernetes-client

  1. public String getURL(Service service, String portName, String namespace, KubernetesClient client) {
  2.  ServicePort port = URLFromServiceUtil.getServicePortByName(service, portName);
  3.  String serviceProto = port.getProtocol();
  4.  NodePortUrlComponents urlComponents = null;
  5.  Integer nodePort = port.getNodePort();
  6.  if(nodePort != null) {
  7.   try {
  8.    NodeList nodeList = client.nodes().list();
  9.    if(nodeList != null && nodeList.getItems() != null) {
  10.     for(Node item : nodeList.getItems()) {
  11.      urlComponents = getUrlComponentsFromNodeList(item.getStatus(), nodePort);
  12.      if(urlComponents != null) {
  13.       break;
  14.      }
  15.     }
  16.    }
  17.   } catch (KubernetesClientException exception) {
  18.    logger.warn("Could not find a node! " + exception);
  19.   }
  20.  }
  21.  return urlComponents != null ? (serviceProto + "://" + urlComponents.getClusterIP() + ":" + urlComponents.getPortNumber()).toLowerCase() : null;
  22. }

代码示例来源：origin: io.fabric8.schemagenerator/kubernetes-model

  1. public NodeBuilder( NodeFluent<?> fluent ){
  2.   this(fluent, new Node());
  3. }
  4. public NodeBuilder( NodeFluent<?> fluent , Node instance ){

代码示例来源：origin: io.fabric8.schemagenerator/kubernetes-model

  1. public NodeBuilder( NodeFluent<?> fluent , Node instance ){
  2.   this.fluent = fluent; fluent.withApiVersion(instance.getApiVersion()); fluent.withKind(instance.getKind()); fluent.withMetadata(instance.getMetadata()); fluent.withSpec(instance.getSpec()); fluent.withStatus(instance.getStatus()); 
  3. }
  4. public NodeBuilder( Node instance ){

代码示例来源：origin: strimzi/strimzi-kafka-operator

  1. /**
  2.  * Write the external address of this node
  3.  *
  4.  * @return if the operation was executed successfully
  5.  */
  6. public boolean writeExternalAddress() {
  7.   List<NodeAddress> addresses = client.nodes().withName(config.getNodeName()).get().getStatus().getAddresses();
  8.   log.info("NodeLabels = {}", addresses);
  9.   String externalAddress = findAddress(addresses);
  10.   if (externalAddress == null) {
  11.     log.error("External address nto found");
  12.     return false;
  13.   } else  {
  14.     log.info("External address found {}", externalAddress);
  15.   }
  16.   return write(FILE_EXTERNAL_ADDRESS, externalAddress);
  17. }

代码示例来源：origin: org.domeos/kubernetes-model

  1. public NodeBuilder(NodeFluent<?> fluent,Boolean validationEnabled){
  2.     this(fluent, new Node(), validationEnabled);
  3. }
  4. public NodeBuilder(NodeFluent<?> fluent,Node instance){

代码示例来源：origin: org.apache.stratos/kubernetes-model

  1. public NodeBuilder( NodeFluent<?> fluent , Node instance ){
  2.   this.fluent = fluent; fluent.withApiVersion(instance.getApiVersion()); fluent.withKind(instance.getKind()); fluent.withMetadata(instance.getMetadata()); fluent.withSpec(instance.getSpec()); fluent.withStatus(instance.getStatus()); 
  3. }
  4. public NodeBuilder( Node instance ){

代码示例来源：origin: org.apache.stratos/kubernetes-model

  1. public NodeBuilder(){
  2.   this(new Node());
  3. }
  4. public NodeBuilder( NodeFluent<?> fluent ){

代码示例来源：origin: io.fabric8.schemagenerator/kubernetes-model

  1. public NodeBuilder( Node instance ){
  2.   this.fluent = this; this.withApiVersion(instance.getApiVersion()); this.withKind(instance.getKind()); this.withMetadata(instance.getMetadata()); this.withSpec(instance.getSpec()); this.withStatus(instance.getStatus()); 
  3. }

代码示例来源：origin: org.apache.stratos/kubernetes-model

  1. public NodeBuilder( NodeFluent<?> fluent ){
  2.   this(fluent, new Node());
  3. }
  4. public NodeBuilder( NodeFluent<?> fluent , Node instance ){

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com