Skip to content

Commit

Permalink
fix: some issues in 1230 (#169)
Browse files Browse the repository at this point in the history
  • Loading branch information
xigongdaEricyang committed Dec 19, 2022
1 parent 63b2cf7 commit 4f8bc72
Show file tree
Hide file tree
Showing 15 changed files with 32 additions and 86 deletions.
5 changes: 3 additions & 2 deletions src/components/Charts/LineChart.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -119,10 +119,11 @@ function LineChart(props: IProps, ref) {
}
yMin.current = min;
yMax.current = max;
const tickInterval = Math.round((max - min) / 5);
return {
min: yMin.current,
max: yMax.current,
tickInterval: Math.round((max - min) / 5),
max: yMax.current + tickInterval,
tickInterval,
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/config/locale/en-US/metric_description.json
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,8 @@
"num_reclaimed_expired_sessions": "Number of expired sessions reclaimed by the server",
"num_added_jobs": "Number of tasks added",
"num_stoped_jobs": "Number of stopped tasks",
"commit_log_latency_us": "Raft commit log delay",
"commit_snapshot_latency_us": "Raft commit snapshot of time delay",
"commit_log_latency_us": "The latency of committing logs in Raft.",
"commit_snapshot_latency_us": "The latency of committing snapshots in Raft.",
"num_rpc_sent_to_storaged": "Number of RPC requests sent to Storaged",
"num_rpc_sent_to_storaged_failed": "Number of FAILED RPC requests sent to Storaged",
"num_agent_heartbeats": "The number of heartbeats for the AgentHBProcessor.",
Expand Down
6 changes: 3 additions & 3 deletions src/config/locale/zh-CN/metric_description.json
Original file line number Diff line number Diff line change
Expand Up @@ -46,9 +46,9 @@
"slow_query_latency_us": "慢查询平均延迟",
"num_added_jobs": "添加的任务数量",
"num_stoped_jobs": "停止的任务数量",
"commit_log_latency_us": "raft commit log延时",
"commit_snapshot_latency_us": "raft commit 快照延时",
"transfer_leader_latency_us": "raft 转移leader延时",
"commit_log_latency_us": "Raft 协议中 Commit 日志的延迟时间。",
"commit_snapshot_latency_us": "Raft 协议中 Commit 快照的延迟时间。",
"transfer_leader_latency_us": "Raft 协议中转移 Leader 的延迟时间。",
"num_rpc_sent_to_metad": "发给metad的rpc请求数量",
"num_rpc_sent_to_metad_failed": "发给metad的rpc请求失败的数量",
"num_rpc_sent_to_storaged": "发给storaged的rpc请求数量",
Expand Down
3 changes: 0 additions & 3 deletions src/pages/MachineDashboard/Cards/CPUCard.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,8 @@ import { MetricScene } from '@/utils/interface';

const mapState = (state: IRootState) => {
const { cpuStat, metricsFilterValues } = state.machine;
const { cpuBaseLine } = state.setting;
const { aliasConfig } = state.app;

return {
baseLine: cpuBaseLine,
data: getDataByType({
data: cpuStat,
type: metricsFilterValues.instanceList,
Expand Down
2 changes: 0 additions & 2 deletions src/pages/MachineDashboard/Cards/LoadCard.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,8 @@ import { MetricScene } from '@/utils/interface';

const mapState = (state: IRootState) => {
const { loadStat, metricsFilterValues } = state.machine;
const { loadBaseLine } = state.setting;
const { aliasConfig } = state.app;
return {
baseLine: loadBaseLine,
data: getDataByType({
data: loadStat,
type: metricsFilterValues.instanceList,
Expand Down
2 changes: 0 additions & 2 deletions src/pages/MachineDashboard/Cards/MemoryCard.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ import { MetricScene } from '@/utils/interface';

const mapState = (state: IRootState) => {
const { memoryStat, memorySizeStat, metricsFilterValues } = state.machine;
const { memoryBaseLine } = state.setting;
const { aliasConfig } = state.app;
return {
data: getDataByType({
Expand All @@ -17,7 +16,6 @@ const mapState = (state: IRootState) => {
aliasConfig,
}),
sizes: memorySizeStat,
baseLine: memoryBaseLine,
valueType: VALUE_TYPE.percentage,
loading:false,
};
Expand Down
2 changes: 0 additions & 2 deletions src/pages/MachineDashboard/Cards/NetworkIn.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,8 @@ import { MetricScene } from '@/utils/interface';

const mapState = (state: IRootState) => {
const { networkInStat, metricsFilterValues } = state.machine;
const { networkInBaseLine } = state.setting;
const { aliasConfig } = state.app;
return {
baseLine: networkInBaseLine,
data: getDataByType({
data: networkInStat,
type: metricsFilterValues.instanceList,
Expand Down
2 changes: 0 additions & 2 deletions src/pages/MachineDashboard/Cards/NetworkOut.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,8 @@ import { MetricScene } from '@/utils/interface';

const mapState = (state: IRootState) => {
const { networkOutStat, metricsFilterValues } = state.machine;
const { networkOutBaseLine } = state.setting;
const { aliasConfig } = state.app;
return {
baseLine: networkOutBaseLine,
data: getDataByType({
data: networkOutStat,
type: metricsFilterValues.instanceList,
Expand Down
4 changes: 0 additions & 4 deletions src/pages/MachineDashboard/Detail/index.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,6 @@ import { IMachineMetricOption } from '@/utils/interface';
import { RouteProps, useHistory } from 'react-router-dom';

const mapDispatch: any = (dispatch: IDispatch) => ({
asyncUpdateBaseLine: (key, value) =>
dispatch.setting.update({
[key]: value,
}),
updateMetricsFiltervalues: dispatch.machine.updateMetricsFiltervalues,
});

Expand Down
44 changes: 19 additions & 25 deletions src/pages/MachineDashboard/index.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -29,19 +29,10 @@ const mapDispatch: any = (dispatch: any) => ({
asyncGetDiskStatByRange: dispatch.machine.asyncGetDiskStatByRange,
asyncGetLoadByRange: dispatch.machine.asyncGetLoadByRange,
asyncGetNetworkStatByRange: dispatch.machine.asyncGetNetworkStatByRange,
asyncUpdateBaseLine: (key, value) =>
dispatch.setting.update({
[key]: value,
}),
updateMetricsFiltervalues: dispatch.machine.updateMetricsFiltervalues,
});

const mapState = (state: any) => ({
cpuBaseLine: state.setting.cpuBaseLine,
memoryBaseLine: state.setting.memoryBaseLine,
networkOutBaseLine: state.setting.networkOutBaseLine,
networkInBaseLine: state.setting.networkInBaseLine,
loadBaseLine: state.setting.loadBaseLine,
instanceList: state.machine.instanceList as any,
metricsFilterValues: state.machine.metricsFilterValues,
loading: state.loading.effects.machine.asyncGetMetricsData,
Expand All @@ -58,13 +49,15 @@ let pollingTimer: any;
function MachineDashboard(props: IProps) {

const { asyncGetMemorySizeStat, asyncGetDiskSizeStat, cluster, metricsFilterValues,
asyncUpdateBaseLine, asyncGetCPUStatByRange, asyncGetMemoryStatByRange, asyncGetDiskStatByRange,
asyncGetCPUStatByRange, asyncGetMemoryStatByRange, asyncGetDiskStatByRange,
asyncGetLoadByRange, asyncGetNetworkStatByRange, updateMetricsFiltervalues, instanceList,
loading,
} = props;

const [showLoading, setShowLoading] = useState<boolean>(false);

const [baseLineMap, setBaseLineMap] = useState<any>({})

useEffect(() => {
asyncGetMemorySizeStat(cluster?.id);
asyncGetDiskSizeStat(cluster?.id);
Expand Down Expand Up @@ -97,14 +90,15 @@ function MachineDashboard(props: IProps) {

const handleBaseLineChange = async (value, editPanelType) => {
const { baseLine, unit } = value;
await asyncUpdateBaseLine(
`${editPanelType}BaseLine`,
getBaseLineByUnit({
baseLine,
unit,
valueType: getValueType(editPanelType),
}),
);
const curBaseLine = getBaseLineByUnit({
baseLine,
unit,
valueType: getValueType(editPanelType),
});
setBaseLineMap({
...baseLineMap,
[`${editPanelType}BaseLine`]: curBaseLine
})
};

const getMachineStatus = () => {
Expand Down Expand Up @@ -196,8 +190,8 @@ function MachineDashboard(props: IProps) {
<Spin spinning={showLoading} wrapperClassName='machine-dashboard-spinning'>
<div className="machine-dashboard">
<div className='common-header' >
<MetricsFilterPanel
onChange={handleMetricsChange}
<MetricsFilterPanel
onChange={handleMetricsChange}
instanceList={instanceList}
values={metricsFilterValues}
onRefresh={handleRefreshData}
Expand All @@ -210,7 +204,7 @@ function MachineDashboard(props: IProps) {
viewPath={getViewPath("/machine/cpu")}
onConfigPanel={() => handleConfigPanel(MACHINE_TYPE.cpu)}
>
<CPUCard />
<CPUCard baseLine={baseLineMap[`${MACHINE_TYPE.cpu}BaseLine`]} />
</DashboardCard>
</Col>
<Col span={12}>
Expand All @@ -219,7 +213,7 @@ function MachineDashboard(props: IProps) {
viewPath={getViewPath("/machine/memory")}
onConfigPanel={() => handleConfigPanel(MACHINE_TYPE.memory)}
>
<MemoryCard />
<MemoryCard baseLine={baseLineMap[`${MACHINE_TYPE.memory}BaseLine`]} />
</DashboardCard>
</Col>
</Row>
Expand All @@ -230,7 +224,7 @@ function MachineDashboard(props: IProps) {
viewPath={getViewPath("/machine/load")}
onConfigPanel={() => handleConfigPanel(MACHINE_TYPE.load)}
>
<LoadCard />
<LoadCard baseLine={baseLineMap[`${MACHINE_TYPE.load}BaseLine`]} />
</DashboardCard>
</Col>
<Col span={12}>
Expand All @@ -251,7 +245,7 @@ function MachineDashboard(props: IProps) {
handleConfigPanel(MACHINE_TYPE.networkOut)
}
>
<NetworkOut />
<NetworkOut baseLine={baseLineMap[`${MACHINE_TYPE.networkOut}BaseLine`]} />
</DashboardCard>
</Col>
<Col span={12}>
Expand All @@ -262,7 +256,7 @@ function MachineDashboard(props: IProps) {
handleConfigPanel(MACHINE_TYPE.networkIn)
}
>
<NetworkIn />
<NetworkIn baseLine={baseLineMap[`${MACHINE_TYPE.networkIn}BaseLine`]} />
</DashboardCard>
</Col>
</Row>
Expand Down
8 changes: 4 additions & 4 deletions src/pages/MetricDetail/index.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,10 @@ const mapState = (state: IRootState) => ({
});

const mapDispatch: any = (dispatch: IDispatch) => ({
asyncUpdateBaseLine: (key, value) =>
dispatch.setting.update({
[key]: value,
}),
// asyncUpdateBaseLine: (key, value) =>
// dispatch.setting.update({
// [key]: value,
// }),
updateMetricsFiltervalues: dispatch.machine.updateMetricsFiltervalues,
updateServiceMetricsFiltervalues: dispatch.service.updateMetricsFiltervalues,
asyncFetchMachineMetricsData: dispatch.machine.asyncGetMetricsData,
Expand Down
4 changes: 0 additions & 4 deletions src/pages/ServiceDashboard/Detail/index.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,6 @@ const mapDispatch: any = (dispatch: IDispatch) => ({
asyncGetStatus: dispatch.service.asyncGetStatus,
asyncGetSpaces: dispatch.serviceMetric.asyncGetSpaces,
asyncFetchMetricsData: dispatch.service.asyncGetMetricsData,
asyncUpdateBaseLine: (key, value) =>
dispatch.machine.update({
[key]: value,
}),
updateMetricsFiltervalues: dispatch.service.updateMetricsFiltervalues,
});

Expand Down
1 change: 0 additions & 1 deletion src/store/models/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,4 @@ export { app } from './app';
export { machine } from './machine';
export { nebula } from './nebula';
export { service } from './service';
export { setting } from './setting';
export { serviceMetric } from './metric';
29 changes: 0 additions & 29 deletions src/store/models/setting.ts

This file was deleted.

2 changes: 1 addition & 1 deletion src/utils/metric.ts
Original file line number Diff line number Diff line change
Expand Up @@ -213,7 +213,7 @@ export const RawServiceMetrics = [

export const ServiceMetricValueTypeMap = {
[VALUE_TYPE.byte]: ["write_bytes_total", "memory_bytes_gauge", "read_bytes_total"],
[VALUE_TYPE.byteSecond]: ["memory_bytes_gauge"],
[VALUE_TYPE.byteSecond]: [],
[VALUE_TYPE.numberSecond]: ["cpu_seconds_total"]
}

Expand Down

0 comments on commit 4f8bc72

Please sign in to comment.