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

Service.getSpec介绍

暂无

代码示例

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

public static ServicePort getServicePortByName(Service service, String portName) {
  if (portName.isEmpty()) {
   return service.getSpec().getPorts().iterator().next();
  }

  for (ServicePort servicePort : service.getSpec().getPorts()) {
   if (Objects.equals(servicePort.getName(), portName)) {
    return servicePort;
   }
  }
  return null;
 }
}

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

@Override
public String getURL(Service service, String portName, String namespace, KubernetesClient client) {
 String serviceHost     = URLFromServiceUtil.resolveHostFromEnvVarOrSystemProperty(service.getMetadata().getName());
 String servicePort     = URLFromServiceUtil.resolvePortFromEnvVarOrSystemProperty(service.getMetadata().getName(), "");
 String serviceProtocol = URLFromServiceUtil.resolveProtocolFromEnvVarOrSystemProperty(service.getSpec().getPorts().iterator().next().getProtocol(), "");
 if(!serviceHost.isEmpty() && !servicePort.isEmpty() && !serviceProtocol.isEmpty()) {
  return serviceProtocol + "://" + serviceHost + ":" + servicePort;
 } else {
  String answer = URLFromServiceUtil.getOrCreateAnnotations(service).get(ANNOTATION_EXPOSE_URL);
  if(answer != null && !answer.isEmpty()) {
   return answer;
  }
 }
 return null;
}

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

public String getURL(String portName) {
 String clusterIP =  getMandatory().getSpec().getClusterIP();
 if("None".equals(clusterIP)) {
  throw new IllegalStateException("Service: " + getMandatory().getMetadata().getName() + " in namespace " +
   namespace + " is head-less. Search for endpoints instead");
 }
 return getUrlHelper(portName);
}

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

@Override
public Service replace(Service item) {
  try {
   Service old = getMandatory();
   return super.replace(new ServiceBuilder(item)
    .editSpec()
    .withClusterIP(old.getSpec().getClusterIP())
    .endSpec()
    .build());
  } catch (Exception e) {
   throw KubernetesClientException.launderThrowable(forOperationType("replace"), e);
  }
}

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

@Override
public Service patch(Service item) {
  try {
   Service old = getMandatory();
   return super.patch(new ServiceBuilder(item)
    .editSpec()
    .withClusterIP(old.getSpec().getClusterIP())
    .endSpec()
    .build());
  } catch (Exception e) {
   throw KubernetesClientException.launderThrowable(forOperationType("patch"), e);
  }
}

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

private List<ServicePort> tryToFindAtLeastOnePort(List<ServicePort> ports, Service defaultService) {
  List<ServicePort> defaultPorts = defaultService.getSpec().getPorts();
  if (!ports.isEmpty() || defaultPorts == null || defaultPorts.isEmpty()) {
    return ports;
  }
  return Collections.singletonList(defaultPorts.get(0));
}

代码示例来源：origin: io.fabric8/fabric8-maven-enricher-standard

private List<ServicePort> tryToFindAtLeastOnePort(List<ServicePort> ports, Service defaultService) {
  List<ServicePort> defaultPorts = defaultService.getSpec().getPorts();
  if (!ports.isEmpty() || defaultPorts == null || defaultPorts.isEmpty()) {
    return ports;
  }
  return Collections.singletonList(defaultPorts.get(0));
}

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

private static ServicePort findServicePortByName(Service service, String portName) {
  if (StringUtils.isBlank(portName)) {
    return service.getSpec().getPorts().iterator().next();
  }
  for (ServicePort servicePort : service.getSpec().getPorts()) {
    if (Objects.equal(servicePort.getName(), portName)) {
      return servicePort;
    }
  }
  return null;
}

代码示例来源：origin: amoAHCP/vxms

private static String getHostString(
  Service serviceEntry, JsonObject env, Field serviceNameField) {
 final String clusterIP = serviceEntry.getSpec().getClusterIP();
 final List<ServicePort> ports = serviceEntry.getSpec().getPorts();
 return serviceNameField.isAnnotationPresent(PortName.class)
   ? resolveServiceWithPortName(env, serviceNameField, clusterIP, ports)
   : resolveService("", clusterIP, ports);
}

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

public static ServiceSpec getOrCreateSpec(Service entity) {
  ServiceSpec spec = entity.getSpec();
  if (spec == null) {
    spec = new ServiceSpec();
    entity.setSpec(spec);
  }
  return spec;
}

代码示例来源：origin: EnMasseProject/enmasse

private static int getPort(Service service, String portName) {
  List<ServicePort> ports = service.getSpec().getPorts();
  for (ServicePort port : ports) {
    if (port.getName().equals(portName)) {
      return port.getPort();
    }
  }
  throw new IllegalArgumentException(
      "Unable to find port " + portName + " for service " + service.getMetadata().getName());
}

代码示例来源：origin: logzio/apollo

@Override
  public Service transform(Service service, Deployment apolloDeployment, io.logz.apollo.models.Service apolloService, Environment apolloEnvironment, DeployableVersion apolloDeployableVersion) {

    service.getSpec().getPorts().forEach(servicePort -> {
      if (servicePort.getNodePort() != null) {
        servicePort.setNodePort(servicePort.getNodePort() + apolloEnvironment.getServicePortCoefficient());
      }
    });

    return service;
  }
}

代码示例来源：origin: EnMasseProject/enmasse

public Endpoint getEndpoint(String serviceName, String namespace, String port) {
  Service service = client.services().inNamespace(namespace).withName(serviceName).get();
  return new Endpoint(service.getSpec().getClusterIP(), getPort(service, port));
}

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

public ServiceBuilder(ServiceFluent<?> fluent,Service 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 ServiceBuilder(Service instance){

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

public ServiceBuilder(Service 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: org.domeos/kubernetes-model

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

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

@Override
public Service patch(Service item) {
  try {
   Service old = getMandatory();
   return super.patch(new ServiceBuilder(item)
    .editSpec()
    .withClusterIP(old.getSpec().getClusterIP())
    .endSpec()
    .build());
  } catch (Exception e) {
   throw KubernetesClientException.launderThrowable(e);
  }
}

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

public ServiceBuilder( ServiceFluent<?> fluent , Service 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 ServiceBuilder( Service instance ){

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

public ServiceBuilder( ServiceFluent<?> fluent , Service 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 ServiceBuilder( Service instance ){

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

@Override
public Service replace(Service item) {
  try {
   Service old = getMandatory();
   return super.replace(new ServiceBuilder(item)
    .editSpec()
    .withClusterIP(old.getSpec().getClusterIP())
    .endSpec()
    .build());
  } catch (Exception e) {
   throw KubernetesClientException.launderThrowable(e);
  }
}