@ -11,7 +11,7 @@ import { DatasourceRequestOptions } from 'app/core/services/backend_srv';
import { TemplateSrv } from 'app/features/templating/template_srv' ;
import { TemplateSrv } from 'app/features/templating/template_srv' ;
import { safeStringifyValue , convertToWebSocketUrl } from 'app/core/utils/explore' ;
import { safeStringifyValue , convertToWebSocketUrl } from 'app/core/utils/explore' ;
import { lokiResultsToTableModel , processRangeQueryResponse , lokiStreamResultToDataFrame } from './result_transformer' ;
import { lokiResultsToTableModel , processRangeQueryResponse , lokiStreamResultToDataFrame } from './result_transformer' ;
import { parseQuery , getHighlighterExpressionsFromQuery } from './query_utils' ;
import { getHighlighterExpressionsFromQuery } from './query_utils' ;
// Types
// Types
import {
import {
@ -136,7 +136,7 @@ export class LokiDatasource extends DataSourceApi<LokiQuery, LokiOptions> {
) : Observable < DataQueryResponse > = > {
) : Observable < DataQueryResponse > = > {
const timeNs = this . getTime ( options . range . to , true ) ;
const timeNs = this . getTime ( options . range . to , true ) ;
const query = {
const query = {
query : parseQuery ( target . expr ) . query ,
query : target.expr ,
time : ` ${ timeNs + ( 1 e9 - ( timeNs % 1 e9 ) ) } ` ,
time : ` ${ timeNs + ( 1 e9 - ( timeNs % 1 e9 ) ) } ` ,
limit : Math.min ( options . maxDataPoints || Infinity , this . maxLines ) ,
limit : Math.min ( options . maxDataPoints || Infinity , this . maxLines ) ,
} ;
} ;
@ -158,7 +158,7 @@ export class LokiDatasource extends DataSourceApi<LokiQuery, LokiOptions> {
} ;
} ;
createRangeQuery ( target : LokiQuery , options : RangeQueryOptions ) : LokiRangeQueryRequest {
createRangeQuery ( target : LokiQuery , options : RangeQueryOptions ) : LokiRangeQueryRequest {
const { query } = parseQuery ( target . expr ) ;
const query = target . expr ;
let range : { start? : number ; end? : number ; step? : number } = { } ;
let range : { start? : number ; end? : number ; step? : number } = { } ;
if ( options . range ) {
if ( options . range ) {
const startNs = this . getTime ( options . range . from , false ) ;
const startNs = this . getTime ( options . range . from , false ) ;
@ -236,7 +236,7 @@ export class LokiDatasource extends DataSourceApi<LokiQuery, LokiOptions> {
} ;
} ;
createLiveTarget ( target : LokiQuery , options : { maxDataPoints? : number } ) : LokiLiveTarget {
createLiveTarget ( target : LokiQuery , options : { maxDataPoints? : number } ) : LokiLiveTarget {
const { query } = parseQuery ( target . expr ) ;
const query = target . expr ;
const baseUrl = this . instanceSettings . url ;
const baseUrl = this . instanceSettings . url ;
const params = serializeParams ( { query } ) ;
const params = serializeParams ( { query } ) ;