More consistent logging.
This commit is contained in:
parent
8bc413b2da
commit
197c21bc32
4 changed files with 6 additions and 4 deletions
|
|
@ -220,6 +220,9 @@ public abstract class AbstractMonitor<O extends KubernetesObject,
|
||||||
new K8sObserver<>(objectClass, objectListClass, client,
|
new K8sObserver<>(objectClass, objectListClass, client,
|
||||||
K8s.preferred(context, version), namespace, options)
|
K8s.preferred(context, version), namespace, options)
|
||||||
.handler((c, r) -> {
|
.handler((c, r) -> {
|
||||||
|
logger.fine(() -> "Resource " + context.getKind()
|
||||||
|
+ "/" + r.object.getMetadata().getName() + " "
|
||||||
|
+ r.type);
|
||||||
handleChange(c, r);
|
handleChange(c, r);
|
||||||
}).onTerminated((o, t) -> {
|
}).onTerminated((o, t) -> {
|
||||||
if (observerCounter.decrementAndGet() == 0) {
|
if (observerCounter.decrementAndGet() == 0) {
|
||||||
|
|
|
||||||
|
|
@ -91,6 +91,7 @@ import org.yaml.snakeyaml.constructor.SafeConstructor;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create pod. First combine template and data and parse result
|
// Create pod. First combine template and data and parse result
|
||||||
|
logger.fine(() -> "Create/update pod " + podStub.name());
|
||||||
var fmTemplate = fmConfig.getTemplate("runnerPod.ftl.yaml");
|
var fmTemplate = fmConfig.getTemplate("runnerPod.ftl.yaml");
|
||||||
StringWriter out = new StringWriter();
|
StringWriter out = new StringWriter();
|
||||||
fmTemplate.process(model, out);
|
fmTemplate.process(model, out);
|
||||||
|
|
|
||||||
|
|
@ -215,8 +215,6 @@ public class Reconciler extends Component {
|
||||||
throws ApiException, TemplateException, IOException {
|
throws ApiException, TemplateException, IOException {
|
||||||
// Ownership relationships takes care of deletions
|
// Ownership relationships takes care of deletions
|
||||||
if (event.type() == K8sObserver.ResponseType.DELETED) {
|
if (event.type() == K8sObserver.ResponseType.DELETED) {
|
||||||
logger.fine(
|
|
||||||
() -> "VM \"" + event.vmDefinition().name() + "\" deleted");
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -205,13 +205,13 @@ public class VmMonitor extends
|
||||||
= K8sV1PodStub.list(client, namespace(), podSearch);
|
= K8sV1PodStub.list(client, namespace(), podSearch);
|
||||||
for (var podStub : podList) {
|
for (var podStub : podList) {
|
||||||
var nodeName = podStub.model().get().getSpec().getNodeName();
|
var nodeName = podStub.model().get().getSpec().getNodeName();
|
||||||
logger.fine(() -> "Adding node name " + nodeName
|
logger.finer(() -> "Adding node name " + nodeName
|
||||||
+ " to VM info for " + vmDef.name());
|
+ " to VM info for " + vmDef.name());
|
||||||
@SuppressWarnings("PMD.AvoidInstantiatingObjectsInLoops")
|
@SuppressWarnings("PMD.AvoidInstantiatingObjectsInLoops")
|
||||||
var addrs = new ArrayList<String>();
|
var addrs = new ArrayList<String>();
|
||||||
podStub.model().get().getStatus().getPodIPs().stream()
|
podStub.model().get().getStatus().getPodIPs().stream()
|
||||||
.map(ip -> ip.getIp()).forEach(addrs::add);
|
.map(ip -> ip.getIp()).forEach(addrs::add);
|
||||||
logger.fine(() -> "Adding node addresses " + addrs
|
logger.finer(() -> "Adding node addresses " + addrs
|
||||||
+ " to VM info for " + vmDef.name());
|
+ " to VM info for " + vmDef.name());
|
||||||
extra.nodeInfo(nodeName, addrs);
|
extra.nodeInfo(nodeName, addrs);
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue