Skip to content

Commit c126aef

Browse files
committed
feat: runtime info for health probes (#1594)
1 parent 6e9c531 commit c126aef

File tree

2 files changed

+21
-0
lines changed

2 files changed

+21
-0
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import java.util.Objects;
77
import java.util.Set;
88
import java.util.function.Function;
9+
import java.util.*;
910
import java.util.stream.Collectors;
1011
import java.util.stream.Stream;
1112

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerWrapper.java

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -180,4 +180,24 @@ public boolean isRunning() {
180180
public String getTargetNamespace() {
181181
return namespaceIdentifier;
182182
}
183+
184+
@Override
185+
public boolean hasSynced() {
186+
return informer.hasSynced();
187+
}
188+
189+
@Override
190+
public boolean isWatching() {
191+
return informer.isWatching();
192+
}
193+
194+
@Override
195+
public boolean isRunning() {
196+
return informer.isRunning();
197+
}
198+
199+
@Override
200+
public String getTargetNamespace() {
201+
return namespaceIdentifier;
202+
}
183203
}

0 commit comments

Comments
 (0)