github/skywalking-booster-ui
2
0
Fork 1
mirror of https://github.com/apache/skywalking-booster-ui.git synced 2025-05-12 15:52:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: split query

Browse Source
This commit is contained in:
Fine 2024-07-30 18:58:31 +08:00
parent b33fd94b7c
commit a5b1092968
1 changed files with 36 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/hooks/useExpressionsProcessor.ts
View File

@ -156,7 +156,7 @@ export async function useExpressionsQueryProcessor(config: Indexable) {
} }
export async function useExpressionsQueryPodsMetrics( export async function useExpressionsQueryPodsMetrics(
pods: Array<(Instance | Endpoint | Service) & Indexable>, allPods: Array<(Instance | Endpoint | Service) & Indexable>,
config: { config: {
expressions: string[]; expressions: string[];
subExpressions: string[]; subExpressions: string[];
@ -164,7 +164,7 @@ export async function useExpressionsQueryPodsMetrics(
}, },
scope: string, scope: string,
) { ) {
function expressionsGraphqlPods() { function expressionsGraphqlPods(pods: Array<(Instance | Endpoint | Service) & Indexable>) {
const metrics: string[] = []; const metrics: string[] = [];
const subMetrics: string[] = []; const subMetrics: string[] = [];
config.expressions = config.expressions || []; config.expressions = config.expressions || [];
@ -222,7 +222,10 @@ export async function useExpressionsQueryPodsMetrics(
return { queryStr, conditions }; return { queryStr, conditions };
} }
function expressionsPodsSource(resp: { errors: string; data: Indexable }): Indexable { function expressionsPodsSource(
resp: { errors: string; data: Indexable },
pods: Array<(Instance | Endpoint | Service) & Indexable>,
): Indexable {
if (resp.errors) { if (resp.errors) {
ElMessage.error(resp.errors); ElMessage.error(resp.errors);
return {}; return {};
@ -304,17 +307,39 @@ export async function useExpressionsQueryPodsMetrics(
return { data, names, subNames, metricConfigArr, metricTypesArr, expressionsTips, subExpressionsTips }; return { data, names, subNames, metricConfigArr, metricTypesArr, expressionsTips, subExpressionsTips };
} }
async function fetchPodsExpressionValues(pods: Array<(Instance | Endpoint | Service) & Indexable>) {
const dashboardStore = useDashboardStore(); const dashboardStore = useDashboardStore();
const params = await expressionsGraphqlPods(); const params = await expressionsGraphqlPods(pods);
const json = await dashboardStore.fetchMetricValue(params); const json = await dashboardStore.fetchMetricValue(params);
if (json.errors) { if (json.errors) {
ElMessage.error(json.errors); ElMessage.error(json.errors);
return {}; return {};
} }
const expressionParams = expressionsPodsSource(json); const expressionParams = expressionsPodsSource(json, pods);
return expressionParams; return expressionParams;
}
const result = [];
for (let i = 0; i < allPods.length; i += 20) {
result.push(allPods.slice(i, i + 20));
}
const promiseArr = result.map((d: Array<(Instance | Endpoint | Service) & Indexable>) =>
fetchPodsExpressionValues(d),
);
const responseList = await Promise.all(promiseArr);
let resp: Indexable = { data: [], expressionsTips: [], subExpressionsTips: [] };
for (const item of responseList) {
resp = {
...item,
data: [...resp.data, ...item.data],
expressionsTips: [...resp.expressionsTips, ...item.expressionsTips],
subExpressionsTips: [...resp.subExpressionsTips, ...item.subExpressionsTips],
};
}
return resp;
} }
export function useQueryTopologyExpressionsProcessor(metrics: string[], instances: (Call | Node)[]) { export function useQueryTopologyExpressionsProcessor(metrics: string[], instances: (Call | Node)[]) {