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

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

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

Node介绍

暂无

代码示例

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

/**
  * Returns the ready condition of the node.
  * 
  * @param node The target node.
  * @return The {@link NodeCondition} or null if not found.
  */
 private static NodeCondition getNodeReadyCondition(Node node) {
  Utils.checkNotNull(node, "Node can't be null.");

  if (node.getStatus() == null || node.getStatus().getConditions() == null) {
   return null;
  }

  for (NodeCondition condition : node.getStatus().getConditions()) {
   if (NODE_READY.equals(condition.getType())) {
    return condition;
   }
  }
  return null;
 }
}

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

public NodeBuilder(){
  this(new Node());
}
public NodeBuilder( NodeFluent<?> fluent ){

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

public NodeFluentImpl(Node instance){
    this.withApiVersion(instance.getApiVersion()); 
    this.withKind(instance.getKind()); 
    this.withMetadata(instance.getMetadata()); 
    this.withSpec(instance.getSpec()); 
    this.withStatus(instance.getStatus()); 
}

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

public void scanNode(Node node) {
  ObjectNode n = mapper.createObjectNode();
  ObjectMeta meta = node.getMetadata();
  n.put("nodeUid", meta.getUid());
  n.put("resourceVersion", meta.getResourceVersion());
  n.put("name", meta.getName());
  n.put("namespace", meta.getNamespace());
  
  
  n.put("clusterName", meta.getClusterName());
  n.put("generateName", meta.getGenerateName());
  n.put("creationTimestamp", meta.getCreationTimestamp());
  n.put("deletionTimestamp", meta.getDeletionTimestamp());
  n.put("deletionGracePeriod", meta.getDeletionGracePeriodSeconds());
  n.put("selfLink", meta.getSelfLink());
  NodeStatus ns = node.getStatus();
  NodeSpec nodeSpec = node.getSpec();
  n.put("externalId", nodeSpec.getExternalID());
  n.put("unschedulable", nodeSpec.getUnschedulable());
  n.put("podCIDR", nodeSpec.getPodCIDR());
  n.put("providerId", nodeSpec.getProviderID());
  n.put("clusterId", clusterId);
  getNeoRxClient().execCypher("merge (n:KubeNode {nodeUid:{nodeUid}}) set n.clusterId={clusterId}, n+={props}",
      "nodeUid", meta.getUid(), "props", n, "clusterId", clusterId);
}

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

if (items != null) {
  for (Node item : items) {
    NodeStatus status = item.getStatus();
    if (!found && status != null) {
      List<NodeAddress> addresses = status.getAddresses();
      NodeSpec spec = item.getSpec();
      if (spec != null) {
        clusterIP = spec.getExternalID();

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

/**
 * Write the rack-id
 *
 * @return if the operation was executed successfully
 */
public boolean writeRack() {
  Map<String, String> nodeLabels = client.nodes().withName(config.getNodeName()).get().getMetadata().getLabels();
  log.info("NodeLabels = {}", nodeLabels);
  String rackId = nodeLabels.get(config.getRackTopologyKey());
  log.info("Rack: {} = {}", config.getRackTopologyKey(), rackId);
  if (rackId == null) {
    log.error("Node {} doesn't have the label {} for getting the rackid",
        config.getNodeName(), config.getRackTopologyKey());
    return false;
  }
  return write(FILE_RACK_ID, rackId);
}

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

@Override
public NodeList getNodes() {
  // TODO we should replace HostNode with Node...
  NodeList answer = new NodeList();
  List<Node> items = new ArrayList<>();
  answer.setItems(items);
  Collection<HostNode> values = getHostNodes().values();
  for (HostNode value : values) {
    Node minion = new Node();
    NodeSpec nodeSpec = new NodeSpec();
    minion.setSpec(nodeSpec);
    ObjectMeta metadata = new ObjectMeta();
    metadata.setName(value.getId());
    minion.setMetadata(metadata);
    // TODO no hostName on a minion
    //minion.setHostIP(value.getHostName());
    items.add(minion);
  }
  return answer;
}

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

open XML  
while xml source has next  
 {  
 add next node to allNodes, key = node.uniqueId, Val = node  
 if next node.kind not in uniqueKinds, add node.kind to uniqueKinds  
 }


ClassNodeImporter method makeFilteredeMap:  

  private boolean makeFilteredeMap() {
    if (uniqueKinds.isEmpty()) {
      return false;
    } else {
      for (String k : uniqueKinds) {
        HashMap<String, Node> aMap = new HashMap<String, Node>();
        for (Node n : allNodes) {
          if (n.getKind().equals(k)) {
            aMap.put(n.getCode(), n);
          }
        }
        filteredNodes.put(k, aMap);
      }
      return true;
    }
  }

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

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

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

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

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

public NodeBuilder(Node instance,Boolean validationEnabled){
    this.fluent = this; 
    this.withApiVersion(instance.getApiVersion()); 
    this.withKind(instance.getKind()); 
    this.withMetadata(instance.getMetadata()); 
    this.withSpec(instance.getSpec()); 
    this.withStatus(instance.getStatus()); 
    this.validationEnabled = validationEnabled; 
}

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

public String getURL(Service service, String portName, String namespace, KubernetesClient client) {
 ServicePort port = URLFromServiceUtil.getServicePortByName(service, portName);
 String serviceProto = port.getProtocol();
 NodePortUrlComponents urlComponents = null;
 Integer nodePort = port.getNodePort();
 if(nodePort != null) {
  try {
   NodeList nodeList = client.nodes().list();
   if(nodeList != null && nodeList.getItems() != null) {
    for(Node item : nodeList.getItems()) {
     urlComponents = getUrlComponentsFromNodeList(item.getStatus(), nodePort);
     if(urlComponents != null) {
      break;
     }
    }
   }
  } catch (KubernetesClientException exception) {
   logger.warn("Could not find a node! " + exception);
  }
 }
 return urlComponents != null ? (serviceProto + "://" + urlComponents.getClusterIP() + ":" + urlComponents.getPortNumber()).toLowerCase() : null;
}

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

public NodeBuilder( NodeFluent<?> fluent ){
  this(fluent, new Node());
}
public NodeBuilder( NodeFluent<?> fluent , Node instance ){

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

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

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

/**
 * Write the external address of this node
 *
 * @return if the operation was executed successfully
 */
public boolean writeExternalAddress() {
  List<NodeAddress> addresses = client.nodes().withName(config.getNodeName()).get().getStatus().getAddresses();
  log.info("NodeLabels = {}", addresses);
  String externalAddress = findAddress(addresses);
  if (externalAddress == null) {
    log.error("External address nto found");
    return false;
  } else  {
    log.info("External address found {}", externalAddress);
  }
  return write(FILE_EXTERNAL_ADDRESS, externalAddress);
}

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

public NodeBuilder(NodeFluent<?> fluent,Boolean validationEnabled){
    this(fluent, new Node(), validationEnabled);
}
public NodeBuilder(NodeFluent<?> fluent,Node instance){

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

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

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

public NodeBuilder(){
  this(new Node());
}
public NodeBuilder( NodeFluent<?> fluent ){

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

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

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

public NodeBuilder( NodeFluent<?> fluent ){
  this(fluent, new Node());
}
public NodeBuilder( NodeFluent<?> fluent , Node instance ){

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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