mirrors/dozzle
1
0
Fork 0
mirror of https://github.com/amir20/dozzle.git synced 2025-12-24 06:28:42 +01:00
Code Issues Projects Releases Wiki Activity

Uses .flush()

Browse Source
This commit is contained in:
Amir Raminfar
2020-07-19 17:13:05 -07:00
parent cef015a722
commit cd7ea2f904
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
assets/components/LogEventSource.vue
View File

@@ -25,6 +25,7 @@ export default {
created() { created() {
this.es = null; this.es = null;
this.loadLogs(this.id); this.loadLogs(this.id);
this.flushBuffer = debounce(this.flushNow, 250, { maxWait: 1000 });
}, },
methods: { methods: {
loadLogs(id) { loadLogs(id) {
@@ -39,21 +40,20 @@ export default {
this.es.addEventListener("container-stopped", (e) => { this.es.addEventListener("container-stopped", (e) => {
this.es.close(); this.es.close();
this.buffer.push({ event: "container-stopped", message: "Container stopped", date: new Date() }); this.buffer.push({ event: "container-stopped", message: "Container stopped", date: new Date() });
flushNow(); this.flushBuffer();
this.flushBuffer.flush();
}); });
this.es.addEventListener("error", (e) => console.log("EventSource failed: " + JSON.stringify(e))); this.es.addEventListener("error", (e) => console.log("EventSource failed: " + JSON.stringify(e)));
const flushBuffer = debounce(() => flushNow(), 250, { maxWait: 1000 });
const flushNow = () => {
this.messages.push(...this.buffer);
this.buffer = [];
};
this.es.onmessage = (e) => { this.es.onmessage = (e) => {
this.buffer.push(this.parseMessage(e.data)); this.buffer.push(this.parseMessage(e.data));
flushBuffer(); this.flushBuffer();
}; };
this.$once("hook:beforeDestroy", () => this.es.close()); this.$once("hook:beforeDestroy", () => this.es.close());
}, },
flushNow() {
this.messages.push(...this.buffer);
this.buffer = [];
},
async loadOlderLogs() { async loadOlderLogs() {
if (this.messages.length < 300) return; if (this.messages.length < 300) return;