-
Notifications
You must be signed in to change notification settings - Fork 11.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
PromQueryBuilder: Query builder and components that can be shared wit…
…h a loki query builder and others (#42854)
- Loading branch information
Showing
65 changed files
with
3,884 additions
and
41 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
188 changes: 188 additions & 0 deletions
188
public/app/plugins/datasource/loki/querybuilder/LokiQueryModeller.test.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,188 @@ | ||
| import { LokiQueryModeller } from './LokiQueryModeller'; | ||
| import { LokiOperationId } from './types'; | ||
|
|
||
| describe('LokiQueryModeller', () => { | ||
| const modeller = new LokiQueryModeller(); | ||
|
|
||
| it('Can query with labels only', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [], | ||
| }) | ||
| ).toBe('{app="grafana"}'); | ||
| }); | ||
|
|
||
| it('Can query with pipeline operation json', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.Json, params: [] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | json'); | ||
| }); | ||
|
|
||
| it('Can query with pipeline operation logfmt', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.Logfmt, params: [] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | logfmt'); | ||
| }); | ||
|
|
||
| it('Can query with line filter contains operation', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LineContains, params: ['error'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} |= `error`'); | ||
| }); | ||
|
|
||
| it('Can query with line filter contains operation with empty params', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LineContains, params: [''] }], | ||
| }) | ||
| ).toBe('{app="grafana"}'); | ||
| }); | ||
|
|
||
| it('Can query with line filter contains not operation', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LineContainsNot, params: ['error'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} != `error`'); | ||
| }); | ||
|
|
||
| it('Can query with line regex filter', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LineMatchesRegex, params: ['error'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} |~ `error`'); | ||
| }); | ||
|
|
||
| it('Can query with line not matching regex', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LineMatchesRegexNot, params: ['error'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} !~ `error`'); | ||
| }); | ||
|
|
||
| it('Can query with label filter expression', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LabelFilter, params: ['__error__', '=', 'value'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | __error__="value"'); | ||
| }); | ||
|
|
||
| it('Can query with label filter expression using greater than operator', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LabelFilter, params: ['count', '>', 'value'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | count > value'); | ||
| }); | ||
|
|
||
| it('Can query no formatting errors operation', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.LabelFilterNoErrors, params: [] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | __error__=""'); | ||
| }); | ||
|
|
||
| it('Can query with unwrap operation', () => { | ||
| expect( | ||
| modeller.renderQuery({ | ||
| labels: [{ label: 'app', op: '=', value: 'grafana' }], | ||
| operations: [{ id: LokiOperationId.Unwrap, params: ['count'] }], | ||
| }) | ||
| ).toBe('{app="grafana"} | unwrap count'); | ||
| }); | ||
|
|
||
| describe('On add operation handlers', () => { | ||
| it('When adding function without range vector param should automatically add rate', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('sum'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations[0].id).toBe('rate'); | ||
| expect(result.operations[1].id).toBe('sum'); | ||
| }); | ||
|
|
||
| it('When adding function without range vector param should automatically add rate after existing pipe operation', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [{ id: 'json', params: [] }], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('sum'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations[0].id).toBe('json'); | ||
| expect(result.operations[1].id).toBe('rate'); | ||
| expect(result.operations[2].id).toBe('sum'); | ||
| }); | ||
|
|
||
| it('When adding a pipe operation after a function operation should add pipe operation first', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [{ id: 'rate', params: [] }], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('json'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations[0].id).toBe('json'); | ||
| expect(result.operations[1].id).toBe('rate'); | ||
| }); | ||
|
|
||
| it('When adding a pipe operation after a line filter operation', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [{ id: '__line_contains', params: ['error'] }], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('json'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations[0].id).toBe('__line_contains'); | ||
| expect(result.operations[1].id).toBe('json'); | ||
| }); | ||
|
|
||
| it('When adding a line filter operation after format operation', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [{ id: 'json', params: [] }], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('__line_contains'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations[0].id).toBe('__line_contains'); | ||
| expect(result.operations[1].id).toBe('json'); | ||
| }); | ||
|
|
||
| it('When adding a rate it should not add another rate', () => { | ||
| const query = { | ||
| labels: [], | ||
| operations: [], | ||
| }; | ||
|
|
||
| const def = modeller.getOperationDef('rate'); | ||
| const result = def.addOperationHandler(def, query, modeller); | ||
| expect(result.operations.length).toBe(1); | ||
| }); | ||
| }); | ||
| }); |
Oops, something went wrong.