2023-07-27 14:31:52 +09:00
|
|
|
<!--
|
|
|
|
SPDX-FileCopyrightText: syuilo and other misskey contributors
|
|
|
|
SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
-->
|
|
|
|
|
2020-01-30 04:37:25 +09:00
|
|
|
<template>
|
2023-05-19 20:52:15 +09:00
|
|
|
<div class="_gaps">
|
2023-01-09 09:42:11 +09:00
|
|
|
<div :class="$style.status">
|
2023-05-19 20:52:15 +09:00
|
|
|
<div :class="$style.statusItem" class="_panel"><div :class="$style.statusLabel">Process</div>{{ number(activeSincePrevTick) }}</div>
|
|
|
|
<div :class="$style.statusItem" class="_panel"><div :class="$style.statusLabel">Active</div>{{ number(active) }}</div>
|
|
|
|
<div :class="$style.statusItem" class="_panel"><div :class="$style.statusLabel">Waiting</div>{{ number(waiting) }}</div>
|
|
|
|
<div :class="$style.statusItem" class="_panel"><div :class="$style.statusLabel">Delayed</div>{{ number(delayed) }}</div>
|
2022-06-25 23:01:40 +09:00
|
|
|
</div>
|
2023-05-19 20:52:15 +09:00
|
|
|
<div :class="$style.charts">
|
|
|
|
<div :class="$style.chart">
|
|
|
|
<div :class="$style.chartTitle">Process</div>
|
2022-06-25 23:01:40 +09:00
|
|
|
<XChart ref="chartProcess" type="process"/>
|
2020-08-09 15:51:02 +09:00
|
|
|
</div>
|
2023-05-19 20:52:15 +09:00
|
|
|
<div :class="$style.chart">
|
|
|
|
<div :class="$style.chartTitle">Active</div>
|
2022-06-25 23:01:40 +09:00
|
|
|
<XChart ref="chartActive" type="active"/>
|
2021-04-22 22:29:33 +09:00
|
|
|
</div>
|
2023-05-19 20:52:15 +09:00
|
|
|
<div :class="$style.chart">
|
|
|
|
<div :class="$style.chartTitle">Delayed</div>
|
2022-06-25 23:01:40 +09:00
|
|
|
<XChart ref="chartDelayed" type="delayed"/>
|
|
|
|
</div>
|
2023-05-19 20:52:15 +09:00
|
|
|
<div :class="$style.chart">
|
|
|
|
<div :class="$style.chartTitle">Waiting</div>
|
2022-06-25 23:01:40 +09:00
|
|
|
<XChart ref="chartWaiting" type="waiting"/>
|
|
|
|
</div>
|
|
|
|
</div>
|
2023-05-19 20:52:15 +09:00
|
|
|
<MkFolder :defaultOpen="true" :max-height="250">
|
2023-01-09 09:42:11 +09:00
|
|
|
<template #icon><i class="ti ti-alert-triangle"></i></template>
|
|
|
|
<template #label>Errored instances</template>
|
|
|
|
<template #suffix>({{ number(jobs.reduce((a, b) => a + b[1], 0)) }} jobs)</template>
|
2023-06-01 17:19:46 +09:00
|
|
|
|
|
|
|
<div>
|
2023-01-09 09:42:11 +09:00
|
|
|
<div v-if="jobs.length > 0">
|
|
|
|
<div v-for="job in jobs" :key="job[0]">
|
|
|
|
<MkA :to="`/instance-info/${job[0]}`" behavior="window">{{ job[0] }}</MkA>
|
|
|
|
<span style="margin-left: 8px; opacity: 0.7;">({{ number(job[1]) }} jobs)</span>
|
|
|
|
</div>
|
2020-01-30 04:37:25 +09:00
|
|
|
</div>
|
2023-01-09 09:42:11 +09:00
|
|
|
<span v-else style="opacity: 0.5;">{{ i18n.ts.noJobs }}</span>
|
2020-03-21 00:21:33 +09:00
|
|
|
</div>
|
2023-01-09 09:42:11 +09:00
|
|
|
</MkFolder>
|
2021-04-22 22:29:33 +09:00
|
|
|
</div>
|
2020-01-30 04:37:25 +09:00
|
|
|
</template>
|
|
|
|
|
2022-05-18 01:31:04 +09:00
|
|
|
<script lang="ts" setup>
|
2022-06-25 23:01:40 +09:00
|
|
|
import { markRaw, onMounted, onUnmounted, ref } from 'vue';
|
|
|
|
import XChart from './queue.chart.chart.vue';
|
2023-09-19 16:37:43 +09:00
|
|
|
import number from '@/filters/number.js';
|
|
|
|
import * as os from '@/os.js';
|
|
|
|
import { useStream } from '@/stream.js';
|
|
|
|
import { i18n } from '@/i18n.js';
|
2023-01-09 09:42:11 +09:00
|
|
|
import MkFolder from '@/components/MkFolder.vue';
|
2022-06-25 23:01:40 +09:00
|
|
|
|
2023-05-15 19:08:46 +09:00
|
|
|
const connection = markRaw(useStream().useChannel('queueStats'));
|
2020-01-30 04:37:25 +09:00
|
|
|
|
2022-05-18 01:31:04 +09:00
|
|
|
const activeSincePrevTick = ref(0);
|
|
|
|
const active = ref(0);
|
|
|
|
const delayed = ref(0);
|
2022-06-25 23:01:40 +09:00
|
|
|
const waiting = ref(0);
|
2022-05-18 01:31:04 +09:00
|
|
|
const jobs = ref([]);
|
2023-01-03 13:37:32 +09:00
|
|
|
let chartProcess = $shallowRef<InstanceType<typeof XChart>>();
|
|
|
|
let chartActive = $shallowRef<InstanceType<typeof XChart>>();
|
|
|
|
let chartDelayed = $shallowRef<InstanceType<typeof XChart>>();
|
|
|
|
let chartWaiting = $shallowRef<InstanceType<typeof XChart>>();
|
2021-10-22 23:46:47 +09:00
|
|
|
|
2022-05-18 01:31:04 +09:00
|
|
|
const props = defineProps<{
|
2022-06-25 23:01:40 +09:00
|
|
|
domain: string;
|
2022-05-18 01:31:04 +09:00
|
|
|
}>();
|
2020-01-30 04:37:25 +09:00
|
|
|
|
2022-06-25 23:01:40 +09:00
|
|
|
const onStats = (stats) => {
|
|
|
|
activeSincePrevTick.value = stats[props.domain].activeSincePrevTick;
|
|
|
|
active.value = stats[props.domain].active;
|
|
|
|
delayed.value = stats[props.domain].delayed;
|
|
|
|
waiting.value = stats[props.domain].waiting;
|
|
|
|
|
|
|
|
chartProcess.pushData(stats[props.domain].activeSincePrevTick);
|
|
|
|
chartActive.pushData(stats[props.domain].active);
|
|
|
|
chartDelayed.pushData(stats[props.domain].delayed);
|
|
|
|
chartWaiting.pushData(stats[props.domain].waiting);
|
|
|
|
};
|
|
|
|
|
|
|
|
const onStatsLog = (statsLog) => {
|
|
|
|
const dataProcess = [];
|
|
|
|
const dataActive = [];
|
|
|
|
const dataDelayed = [];
|
|
|
|
const dataWaiting = [];
|
|
|
|
|
|
|
|
for (const stats of [...statsLog].reverse()) {
|
|
|
|
dataProcess.push(stats[props.domain].activeSincePrevTick);
|
|
|
|
dataActive.push(stats[props.domain].active);
|
|
|
|
dataDelayed.push(stats[props.domain].delayed);
|
|
|
|
dataWaiting.push(stats[props.domain].waiting);
|
|
|
|
}
|
|
|
|
|
|
|
|
chartProcess.setData(dataProcess);
|
|
|
|
chartActive.setData(dataActive);
|
|
|
|
chartDelayed.setData(dataDelayed);
|
|
|
|
chartWaiting.setData(dataWaiting);
|
|
|
|
};
|
|
|
|
|
2022-05-18 01:31:04 +09:00
|
|
|
onMounted(() => {
|
|
|
|
os.api(props.domain === 'inbox' ? 'admin/queue/inbox-delayed' : props.domain === 'deliver' ? 'admin/queue/deliver-delayed' : null, {}).then(result => {
|
|
|
|
jobs.value = result;
|
|
|
|
});
|
2020-01-30 04:37:25 +09:00
|
|
|
|
2022-06-25 23:01:40 +09:00
|
|
|
connection.on('stats', onStats);
|
|
|
|
connection.on('statsLog', onStatsLog);
|
|
|
|
connection.send('requestLog', {
|
2023-07-14 07:59:54 +09:00
|
|
|
id: Math.random().toString().substring(2, 10),
|
2022-06-25 23:01:40 +09:00
|
|
|
length: 200,
|
2022-05-18 01:31:04 +09:00
|
|
|
});
|
2020-01-30 04:37:25 +09:00
|
|
|
});
|
2022-06-25 23:01:40 +09:00
|
|
|
|
|
|
|
onUnmounted(() => {
|
|
|
|
connection.off('stats', onStats);
|
|
|
|
connection.off('statsLog', onStatsLog);
|
|
|
|
connection.dispose();
|
|
|
|
});
|
2020-01-30 04:37:25 +09:00
|
|
|
</script>
|
2021-04-22 22:29:33 +09:00
|
|
|
|
2023-05-19 20:52:15 +09:00
|
|
|
<style lang="scss" module>
|
|
|
|
.charts {
|
|
|
|
display: grid;
|
|
|
|
grid-template-columns: 1fr 1fr;
|
|
|
|
gap: 10px;
|
|
|
|
}
|
|
|
|
|
|
|
|
.chart {
|
|
|
|
min-width: 0;
|
|
|
|
padding: 16px;
|
|
|
|
background: var(--panel);
|
|
|
|
border-radius: var(--radius);
|
|
|
|
}
|
|
|
|
|
|
|
|
.chartTitle {
|
|
|
|
margin-bottom: 8px;
|
2023-01-09 09:42:11 +09:00
|
|
|
}
|
2021-04-22 22:29:33 +09:00
|
|
|
|
2023-01-09 09:42:11 +09:00
|
|
|
.status {
|
|
|
|
display: grid;
|
|
|
|
grid-template-columns: repeat(auto-fill, minmax(160px, 1fr));
|
|
|
|
grid-gap: 10px;
|
2023-05-19 20:52:15 +09:00
|
|
|
}
|
2023-01-09 09:42:11 +09:00
|
|
|
|
2023-05-19 20:52:15 +09:00
|
|
|
.statusItem {
|
|
|
|
padding: 12px 16px;
|
|
|
|
}
|
2023-01-09 09:42:11 +09:00
|
|
|
|
2023-05-19 20:52:15 +09:00
|
|
|
.statusLabel {
|
|
|
|
font-size: 80%;
|
|
|
|
opacity: 0.6;
|
2023-01-09 09:42:11 +09:00
|
|
|
}
|
2021-04-22 22:29:33 +09:00
|
|
|
</style>
|