本文整理了Java中io.fabric8.kubernetes.api.model.EndpointAddress.getIp()
方法的一些代码示例,展示了EndpointAddress.getIp()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。EndpointAddress.getIp()
方法的具体详情如下:
包路径:io.fabric8.kubernetes.api.model.EndpointAddress
类名称:EndpointAddress
方法名:getIp
EndpointAddress.getIp介绍
暂无
代码示例
代码示例来源:origin: spring-cloud/spring-cloud-kubernetes
@Override
public String getHost() {
return endpointAddress.getIp();
}
代码示例来源:origin: spring-cloud/spring-cloud-kubernetes
EndpointPort port = subset.getPorts().get(FIRST);
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
|| portName.endsWith(port.getName())) {
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
代码示例来源:origin: fabric8io/spring-cloud-kubernetes
@Override
public String getHost() {
return endpointAddress.getIp();
}
代码示例来源:origin: fabric8io/spring-cloud-kubernetes
EndpointPort port = subset.getPorts().get(FIRST);
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
if (Utils.isNullOrEmpty(portName) || portName.endsWith(port.getName())) {
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
代码示例来源:origin: io.fabric8/spring-cloud-kubernetes-discovery
@Override
public String getHost() {
return endpointAddress.getIp();
}
代码示例来源:origin: io.fabric8/sping-cloud-kubernetes-discovery
@Override
public String getHost() {
if (subset.getAddresses().isEmpty()) {
throw new IllegalStateException("Endpoint subset has no addresses.");
}
return subset.getAddresses().get(0).getIp();
}
代码示例来源:origin: org.apache.camel/camel-kubernetes
protected void addServers(String name, List servers, EndpointPort port, EndpointSubset subset) {
final List addresses = subset.getAddresses();
final int size = addresses.size();
for (int i = 0; i servers.add(new DefaultServiceDefinition(name, addresses.get(i).getIp(), port.getPort()));
}
}
代码示例来源:origin: io.fabric8/sping-cloud-kubernetes-discovery
@Override
public ServiceInstance getLocalServiceInstance() {
String podName = System.getenv(HOSTNAME);
return client.endpoints().withName(localServiceId).get().getSubsets()
.stream()
.filter(s -> s.getAddresses().iterator().next().getIp().equals(podName))
.map(s -> new KubernetesServiceInstance(localServiceId, s.getPorts().iterator().next().getName(), s, false))
.findFirst().get();
}
代码示例来源:origin: io.fabric8.schemagenerator/kubernetes-model
public EndpointAddressBuilder( EndpointAddress instance ){
this.fluent = this; this.withIp(instance.getIp()); this.withTargetRef(instance.getTargetRef());
}
代码示例来源:origin: io.fabric8.kubeflix/kubeflix-discovery
private static List toInstances(Endpoints e) {
List result = new ArrayList();
for (EndpointSubset subset : e.getSubsets()) {
String clusterName = e.getMetadata().getLabels().containsKey(HYSTRIX_CLUSTER) ?
e.getMetadata().getLabels().get(HYSTRIX_CLUSTER) :
DEFAULT;
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Instance(address.getIp(), clusterName, true));
}
}
return result;
}
}
代码示例来源:origin: io.fabric8.schemagenerator/kubernetes-model
public EndpointAddressBuilder( EndpointAddressFluent> fluent , EndpointAddress instance ){
this.fluent = fluent; fluent.withIp(instance.getIp()); fluent.withTargetRef(instance.getTargetRef());
}
public EndpointAddressBuilder( EndpointAddress instance ){
代码示例来源:origin: fabric8io/elasticsearch-cloud-kubernetes
String ip = address.getIp();
try {
InetAddress endpointAddress = InetAddress.getByName(ip);
代码示例来源:origin: org.domeos/kubernetes-model
public EndpointAddressBuilder(EndpointAddress instance,Boolean validationEnabled){
this.fluent = this;
this.withHostname(instance.getHostname());
this.withIp(instance.getIp());
this.withTargetRef(instance.getTargetRef());
this.validatiOnEnabled= validationEnabled;
}
代码示例来源:origin: org.domeos/kubernetes-model
public EndpointAddressBuilder(EndpointAddressFluent> fluent,EndpointAddress instance,Boolean validationEnabled){
this.fluent = fluent;
fluent.withHostname(instance.getHostname());
fluent.withIp(instance.getIp());
fluent.withTargetRef(instance.getTargetRef());
this.validatiOnEnabled= validationEnabled;
}
public EndpointAddressBuilder(EndpointAddress instance){
代码示例来源:origin: org.domeos/kubernetes-model
public EndpointAddressFluentImpl(EndpointAddress instance){
this.withHostname(instance.getHostname());
this.withIp(instance.getIp());
this.withTargetRef(instance.getTargetRef());
}
代码示例来源:origin: io.fabric8.kubeflix/ribbon-discovery
EndpointPort port = subset.getPorts().get(FIRST);
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
if (Utils.isNullOrEmpty(portName) || portName.endsWith(port.getName())) {
for (EndpointAddress address : subset.getAddresses()) {
result.add(new Server(address.getIp(), port.getPort()));
代码示例来源:origin: org.apache.brooklyn/brooklyn-locations-container
String podName = address.getTargetRef().getName();
podNames.add(podName);
String privateIp = address.getIp();
privateIps.add(privateIp);
代码示例来源:origin: io.fabric8/fabric8-arquillian
if (addresses != null) {
for (EndpointAddress address : addresses) {
String ip = address.getIp();
String addr = ip;