diff --git a/dev/index.html b/dev/index.html
index aa9ef7f73..992933453 100644
--- a/dev/index.html
+++ b/dev/index.html
@@ -155,19 +155,29 @@
}
function setQueryLog() {
- vg.coordinator().manager.logQueries(qlogToggle.checked);
+ const bus = coordinator().eventBus;
+
+ bus.observe("query-start", (event) =>
+ console.info("Query started:", event),
+ );
+ bus.observe("query-end", (event) => console.info("Query ended:", event));
+ bus.observe("client-connect", (event) =>
+ console.info("Client connected:", event),
+ );
+ bus.observe("warning", (event) => console.warn("Warning:", event));
+ bus.observe("error", (event) => console.error("Error:", event));
}
function setCache() {
- vg.coordinator().manager.cache(cacheToggle.checked);
+ coordinator().manager.cache(cacheToggle.checked);
}
function setConsolidate() {
- vg.coordinator().manager.consolidate(consolidateToggle.checked);
+ coordinator().manager.consolidate(consolidateToggle.checked);
}
function setPreAggregate() {
- vg.coordinator().preaggregator.enabled = preaggToggle.checked;
+ coordinator().preaggregator.enabled = preaggToggle.checked;
}
function reload() {
diff --git a/dev/query/index.html b/dev/query/index.html
index 1d8e523ca..9b22a82c0 100644
--- a/dev/query/index.html
+++ b/dev/query/index.html
@@ -73,6 +73,22 @@
}
enable();
});
+
+ function setQueryLog() {
+ const bus = vg.coordinator().eventBus;
+
+ bus.observe("query-start", (event) =>
+ console.info("Query started:", event),
+ );
+ bus.observe("query-end", (event) => console.info("Query ended:", event));
+ bus.observe("client-connect", (event) =>
+ console.info("Client connected:", event),
+ );
+ bus.observe("warning", (event) => console.warn("Warning:", event));
+ bus.observe("error", (event) => console.error("Error:", event));
+ }
+
+ setQueryLog()