Skip to content

Commit 8c3c606

Browse files
committed
add endpoint conditions to node cryostat annotations
1 parent 5bd639f commit 8c3c606

File tree

1 file changed

+21
-4
lines changed

1 file changed

+21
-4
lines changed

src/main/java/io/cryostat/discovery/KubeEndpointSlicesDiscovery.java

+21-4
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
import io.fabric8.kubernetes.api.model.ObjectReference;
4646
import io.fabric8.kubernetes.api.model.OwnerReference;
4747
import io.fabric8.kubernetes.api.model.discovery.v1.Endpoint;
48+
import io.fabric8.kubernetes.api.model.discovery.v1.EndpointConditions;
4849
import io.fabric8.kubernetes.api.model.discovery.v1.EndpointPort;
4950
import io.fabric8.kubernetes.api.model.discovery.v1.EndpointSlice;
5051
import io.fabric8.kubernetes.client.KubernetesClient;
@@ -235,7 +236,8 @@ List<TargetTuple> tuplesFromEndpoints(EndpointSlice slice) {
235236
queryForNode(ref.getNamespace(), ref.getName(), ref.getKind())
236237
.getLeft(),
237238
addr,
238-
port));
239+
port,
240+
endpoint.getConditions()));
239241
}
240242
}
241243
}
@@ -602,12 +604,19 @@ private class TargetTuple {
602604
HasMetadata obj;
603605
String addr;
604606
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) {
607615
this.objRef = objRef;
608616
this.obj = obj;
609617
this.addr = addr;
610618
this.port = port;
619+
this.conditions = conditions;
611620
}
612621

613622
public Target toTarget() {
@@ -640,7 +649,15 @@ public Target toTarget() {
640649
"NAMESPACE",
641650
objRef.getNamespace(),
642651
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()))));
644661

645662
return target;
646663
} catch (Exception e) {

0 commit comments

Comments
 (0)