Misthios/grafana-zabbix
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Add name to triggers data frame, fixes #1441

Browse Source
This commit is contained in:
Alexander Zobnin
2023-03-21 12:51:05 +01:00
parent dd6798834a
commit 418fe7a70d
3 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/datasource/datasource.ts
View File

@@ -717,7 +717,7 @@ export class ZabbixDatasource extends DataSourceApi<ZabbixMetricsQuery, ZabbixDS
.then((problems) => problemsHandler.addTriggerHostProxy(problems, proxies));
return problemsPromises.then((problems) => {
const problemsDataFrame = problemsHandler.toDataFrame(problems);
const problemsDataFrame = problemsHandler.toDataFrame(problems, target);
return problemsDataFrame;
});
}

5
src/datasource/problemsHandler.ts
View File

@@ -1,7 +1,7 @@
import _ from 'lodash';
import * as utils from './utils';
import { DataFrame, Field, FieldType, ArrayVector } from '@grafana/data';
import { ZBXProblem, ZBXTrigger, ProblemDTO, ZBXEvent } from './types';
import { ZBXProblem, ZBXTrigger, ProblemDTO, ZBXEvent, ZabbixMetricsQuery } from './types';
export function joinTriggersWithProblems(problems: ZBXProblem[], triggers: ZBXTrigger[]): ProblemDTO[] {
const problemDTOList: ProblemDTO[] = [];
@@ -172,7 +172,7 @@ export function sortProblems(problems: ProblemDTO[], target) {
return problems;
}
export function toDataFrame(problems: any[]): DataFrame {
export function toDataFrame(problems: any[], query: ZabbixMetricsQuery): DataFrame {
const problemsField: Field<any> = {
name: 'Problems',
type: FieldType.other,
@@ -186,6 +186,7 @@ export function toDataFrame(problems: any[]): DataFrame {
const response: DataFrame = {
name: 'problems',
refId: query?.refId || 'A',
fields: [problemsField],
length: problems.length,
};

3
src/datasource/responseHandler.ts
View File

@@ -614,6 +614,7 @@ export function handleSLAResponse(itservice, slaProperty, slaObject) {
function handleTriggersResponse(triggers: ZBXTrigger[], groups: ZBXGroup[], timeRange: number[], target) {
if (!_.isArray(triggers)) {
// Handling count mode
let triggersCount = null;
try {
triggersCount = Number(triggers);
@@ -622,6 +623,7 @@ function handleTriggersResponse(triggers: ZBXTrigger[], groups: ZBXGroup[], time
}
const frame = new MutableDataFrame({
name: `Count ${target.refId}`,
refId: target.refId,
fields: [
{ name: TIME_SERIES_TIME_FIELD_NAME, type: FieldType.time, values: new ArrayVector([timeRange[1] * 1000]) },
@@ -634,6 +636,7 @@ function handleTriggersResponse(triggers: ZBXTrigger[], groups: ZBXGroup[], time
} else {
const stats = getTriggerStats(triggers);
const frame = new MutableDataFrame({
name: `Triggers ${target.refId}`,
refId: target.refId,
fields: [{ name: 'Host group', type: FieldType.string, values: new ArrayVector() }],
});