2020-01-30 04:37:25 +09:00
|
|
|
<template>
|
2020-10-17 20:12:00 +09:00
|
|
|
<section class="_section">
|
2020-01-30 04:37:25 +09:00
|
|
|
<div class="_title"><slot name="title"></slot></div>
|
2020-08-09 15:51:02 +09:00
|
|
|
<div class="_content _table">
|
|
|
|
<div class="_row">
|
2020-10-17 20:12:00 +09:00
|
|
|
<div class="_cell"><div class="_label">Process</div>{{ number(activeSincePrevTick) }}</div>
|
|
|
|
<div class="_cell"><div class="_label">Active</div>{{ number(active) }}</div>
|
|
|
|
<div class="_cell"><div class="_label">Waiting</div>{{ number(waiting) }}</div>
|
|
|
|
<div class="_cell"><div class="_label">Delayed</div>{{ number(delayed) }}</div>
|
2020-08-09 15:51:02 +09:00
|
|
|
</div>
|
2020-01-30 04:37:25 +09:00
|
|
|
</div>
|
|
|
|
<div class="_content" style="margin-bottom: -8px;">
|
|
|
|
<canvas ref="chart"></canvas>
|
|
|
|
</div>
|
|
|
|
<div class="_content" style="max-height: 180px; overflow: auto;">
|
2020-03-21 00:21:33 +09:00
|
|
|
<div v-if="jobs.length > 0">
|
|
|
|
<div v-for="job in jobs" :key="job[0]">
|
2020-01-30 04:37:25 +09:00
|
|
|
<span>{{ job[0] }}</span>
|
2020-10-17 20:12:00 +09:00
|
|
|
<span style="margin-left: 8px; opacity: 0.7;">({{ number(job[1]) }} jobs)</span>
|
2020-01-30 04:37:25 +09:00
|
|
|
</div>
|
2020-03-21 00:21:33 +09:00
|
|
|
</div>
|
2020-12-26 10:47:36 +09:00
|
|
|
<span v-else style="opacity: 0.5;">{{ $ts.noJobs }}</span>
|
2020-01-30 04:37:25 +09:00
|
|
|
</div>
|
|
|
|
</section>
|
|
|
|
</template>
|
|
|
|
|
|
|
|
<script lang="ts">
|
2020-10-17 20:12:00 +09:00
|
|
|
import { defineComponent } from 'vue';
|
2020-01-30 04:37:25 +09:00
|
|
|
import Chart from 'chart.js';
|
2020-10-17 20:12:00 +09:00
|
|
|
import number from '../../filters/number';
|
2020-01-30 04:37:25 +09:00
|
|
|
|
|
|
|
const alpha = (hex, a) => {
|
|
|
|
const result = /^#?([a-f\d]{2})([a-f\d]{2})([a-f\d]{2})$/i.exec(hex)!;
|
|
|
|
const r = parseInt(result[1], 16);
|
|
|
|
const g = parseInt(result[2], 16);
|
|
|
|
const b = parseInt(result[3], 16);
|
|
|
|
return `rgba(${r}, ${g}, ${b}, ${a})`;
|
|
|
|
};
|
2021-03-23 17:30:14 +09:00
|
|
|
import * as os from '@client/os';
|
2020-01-30 04:37:25 +09:00
|
|
|
|
2020-10-17 20:12:00 +09:00
|
|
|
export default defineComponent({
|
2020-01-30 04:37:25 +09:00
|
|
|
props: {
|
|
|
|
domain: {
|
|
|
|
required: true
|
|
|
|
},
|
|
|
|
connection: {
|
|
|
|
required: true
|
|
|
|
},
|
|
|
|
},
|
|
|
|
|
|
|
|
data() {
|
|
|
|
return {
|
|
|
|
chart: null,
|
|
|
|
jobs: [],
|
|
|
|
activeSincePrevTick: 0,
|
|
|
|
active: 0,
|
|
|
|
waiting: 0,
|
|
|
|
delayed: 0,
|
|
|
|
}
|
|
|
|
},
|
|
|
|
|
|
|
|
mounted() {
|
|
|
|
this.fetchJobs();
|
|
|
|
|
2020-08-09 15:51:02 +09:00
|
|
|
// TODO: var(--panel)の色が暗いか明るいかで判定する
|
2020-12-19 10:55:52 +09:00
|
|
|
const gridColor = this.$store.state.darkMode ? 'rgba(255, 255, 255, 0.1)' : 'rgba(0, 0, 0, 0.1)';
|
2020-08-09 15:51:02 +09:00
|
|
|
|
2020-01-30 04:37:25 +09:00
|
|
|
Chart.defaults.global.defaultFontColor = getComputedStyle(document.documentElement).getPropertyValue('--fg');
|
|
|
|
|
|
|
|
this.chart = new Chart(this.$refs.chart, {
|
|
|
|
type: 'line',
|
|
|
|
data: {
|
|
|
|
labels: [],
|
|
|
|
datasets: [{
|
|
|
|
label: 'Process',
|
|
|
|
pointRadius: 0,
|
|
|
|
lineTension: 0,
|
|
|
|
borderWidth: 2,
|
|
|
|
borderColor: '#00E396',
|
|
|
|
backgroundColor: alpha('#00E396', 0.1),
|
|
|
|
data: []
|
|
|
|
}, {
|
|
|
|
label: 'Active',
|
|
|
|
pointRadius: 0,
|
|
|
|
lineTension: 0,
|
|
|
|
borderWidth: 2,
|
|
|
|
borderColor: '#00BCD4',
|
|
|
|
backgroundColor: alpha('#00BCD4', 0.1),
|
|
|
|
data: []
|
|
|
|
}, {
|
|
|
|
label: 'Waiting',
|
|
|
|
pointRadius: 0,
|
|
|
|
lineTension: 0,
|
|
|
|
borderWidth: 2,
|
|
|
|
borderColor: '#FFB300',
|
|
|
|
backgroundColor: alpha('#FFB300', 0.1),
|
|
|
|
data: []
|
|
|
|
}, {
|
|
|
|
label: 'Delayed',
|
|
|
|
pointRadius: 0,
|
|
|
|
lineTension: 0,
|
|
|
|
borderWidth: 2,
|
|
|
|
borderColor: '#E53935',
|
|
|
|
borderDash: [5, 5],
|
|
|
|
fill: false,
|
|
|
|
data: []
|
|
|
|
}]
|
|
|
|
},
|
|
|
|
options: {
|
|
|
|
aspectRatio: 3,
|
|
|
|
layout: {
|
|
|
|
padding: {
|
|
|
|
left: 0,
|
|
|
|
right: 0,
|
|
|
|
top: 8,
|
|
|
|
bottom: 0
|
|
|
|
}
|
|
|
|
},
|
|
|
|
legend: {
|
|
|
|
position: 'bottom',
|
|
|
|
labels: {
|
|
|
|
boxWidth: 16,
|
|
|
|
}
|
|
|
|
},
|
|
|
|
scales: {
|
|
|
|
xAxes: [{
|
|
|
|
gridLines: {
|
2020-08-09 15:51:02 +09:00
|
|
|
display: false,
|
|
|
|
color: gridColor,
|
|
|
|
zeroLineColor: gridColor,
|
2020-01-30 04:37:25 +09:00
|
|
|
},
|
|
|
|
ticks: {
|
|
|
|
display: false
|
|
|
|
}
|
|
|
|
}],
|
|
|
|
yAxes: [{
|
|
|
|
position: 'right',
|
2020-08-09 15:51:02 +09:00
|
|
|
gridLines: {
|
|
|
|
display: true,
|
|
|
|
color: gridColor,
|
|
|
|
zeroLineColor: gridColor,
|
|
|
|
},
|
2020-01-30 04:37:25 +09:00
|
|
|
ticks: {
|
|
|
|
display: false,
|
|
|
|
}
|
|
|
|
}]
|
|
|
|
},
|
|
|
|
tooltips: {
|
|
|
|
intersect: false,
|
|
|
|
mode: 'index',
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
this.connection.on('stats', this.onStats);
|
|
|
|
this.connection.on('statsLog', this.onStatsLog);
|
|
|
|
},
|
|
|
|
|
2020-10-17 20:12:00 +09:00
|
|
|
beforeUnmount() {
|
2020-01-30 04:37:25 +09:00
|
|
|
this.connection.off('stats', this.onStats);
|
|
|
|
this.connection.off('statsLog', this.onStatsLog);
|
|
|
|
},
|
|
|
|
|
|
|
|
methods: {
|
|
|
|
onStats(stats) {
|
|
|
|
this.activeSincePrevTick = stats[this.domain].activeSincePrevTick;
|
|
|
|
this.active = stats[this.domain].active;
|
|
|
|
this.waiting = stats[this.domain].waiting;
|
|
|
|
this.delayed = stats[this.domain].delayed;
|
|
|
|
this.chart.data.labels.push('');
|
|
|
|
this.chart.data.datasets[0].data.push(stats[this.domain].activeSincePrevTick);
|
|
|
|
this.chart.data.datasets[1].data.push(stats[this.domain].active);
|
|
|
|
this.chart.data.datasets[2].data.push(stats[this.domain].waiting);
|
|
|
|
this.chart.data.datasets[3].data.push(stats[this.domain].delayed);
|
|
|
|
if (this.chart.data.datasets[0].data.length > 200) {
|
|
|
|
this.chart.data.labels.shift();
|
|
|
|
this.chart.data.datasets[0].data.shift();
|
|
|
|
this.chart.data.datasets[1].data.shift();
|
|
|
|
this.chart.data.datasets[2].data.shift();
|
|
|
|
this.chart.data.datasets[3].data.shift();
|
|
|
|
}
|
|
|
|
this.chart.update();
|
|
|
|
},
|
|
|
|
|
|
|
|
onStatsLog(statsLog) {
|
2020-07-27 23:25:37 +09:00
|
|
|
for (const stats of [...statsLog].reverse()) {
|
2020-01-30 04:37:25 +09:00
|
|
|
this.onStats(stats);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
|
|
|
|
fetchJobs() {
|
2020-10-17 20:12:00 +09:00
|
|
|
os.api(this.domain === 'inbox' ? 'admin/queue/inbox-delayed' : this.domain === 'deliver' ? 'admin/queue/deliver-delayed' : null, {}).then(jobs => {
|
2020-01-30 04:37:25 +09:00
|
|
|
this.jobs = jobs;
|
|
|
|
});
|
|
|
|
},
|
2020-10-17 20:12:00 +09:00
|
|
|
|
|
|
|
number
|
2020-01-30 04:37:25 +09:00
|
|
|
}
|
|
|
|
});
|
|
|
|
</script>
|