|
45 | 45 | import io.fabric8.kubernetes.api.model.ObjectReference; |
46 | 46 | import io.fabric8.kubernetes.api.model.OwnerReference; |
47 | 47 | import io.fabric8.kubernetes.api.model.discovery.v1.Endpoint; |
| 48 | +import io.fabric8.kubernetes.api.model.discovery.v1.EndpointConditions; |
48 | 49 | import io.fabric8.kubernetes.api.model.discovery.v1.EndpointPort; |
49 | 50 | import io.fabric8.kubernetes.api.model.discovery.v1.EndpointSlice; |
50 | 51 | import io.fabric8.kubernetes.client.KubernetesClient; |
@@ -235,7 +236,8 @@ List<TargetTuple> tuplesFromEndpoints(EndpointSlice slice) { |
235 | 236 | queryForNode(ref.getNamespace(), ref.getName(), ref.getKind()) |
236 | 237 | .getLeft(), |
237 | 238 | addr, |
238 | | - port)); |
| 239 | + port, |
| 240 | + endpoint.getConditions())); |
239 | 241 | } |
240 | 242 | } |
241 | 243 | } |
@@ -602,12 +604,19 @@ private class TargetTuple { |
602 | 604 | HasMetadata obj; |
603 | 605 | String addr; |
604 | 606 | EndpointPort port; |
605 | | - |
606 | | - TargetTuple(ObjectReference objRef, HasMetadata obj, String addr, EndpointPort port) { |
| 607 | + EndpointConditions conditions; |
| 608 | + |
| 609 | + TargetTuple( |
| 610 | + ObjectReference objRef, |
| 611 | + HasMetadata obj, |
| 612 | + String addr, |
| 613 | + EndpointPort port, |
| 614 | + EndpointConditions conditions) { |
607 | 615 | this.objRef = objRef; |
608 | 616 | this.obj = obj; |
609 | 617 | this.addr = addr; |
610 | 618 | this.port = port; |
| 619 | + this.conditions = conditions; |
611 | 620 | } |
612 | 621 |
|
613 | 622 | public Target toTarget() { |
@@ -640,7 +649,15 @@ public Target toTarget() { |
640 | 649 | "NAMESPACE", |
641 | 650 | objRef.getNamespace(), |
642 | 651 | isPod ? "POD_NAME" : "OBJECT_NAME", |
643 | | - objRef.getName())); |
| 652 | + objRef.getName(), |
| 653 | + "CONDITION_READY", |
| 654 | + String.valueOf(Boolean.TRUE.equals(conditions.getReady())), |
| 655 | + "CONDITION_SERVING", |
| 656 | + String.valueOf( |
| 657 | + Boolean.TRUE.equals(conditions.getServing())), |
| 658 | + "CONDITION_TERMINATING", |
| 659 | + String.valueOf( |
| 660 | + Boolean.TRUE.equals(conditions.getTerminating())))); |
644 | 661 |
|
645 | 662 | return target; |
646 | 663 | } catch (Exception e) { |
|
0 commit comments