Blob Blame History Raw
diff --git a/src/datasources/redis/datasource.ts b/src/datasources/redis/datasource.ts
index 5980ffa..1d108a9 100644
--- a/src/datasources/redis/datasource.ts
+++ b/src/datasources/redis/datasource.ts
@@ -170,15 +170,14 @@ export class PCPRedisDatasource {
             }
         }
 
-        const sampleIntervalSec = 60; // guessed sample interval
+        const interval = query.intervalMs / 1000; // seconds
         // request a bigger time frame to fill the chart (otherwise left and right border of chart is empty)
         // because of the rate conversation of counters first datapoint is "lost" -> expand timeframe at the beginning
-        const start = Math.round(query.range.from.valueOf() / 1000) - 2 * sampleIntervalSec;
-        const finish = Math.round(query.range.to.valueOf() / 1000) + sampleIntervalSec;
-        const samples = Math.round((query.range.to.valueOf() - query.range.from.valueOf()) / query.intervalMs);
-        // const interval = query.interval;
+        const additionalTimeRange = Math.max(interval, 60); // 60s is the default sample interval of pmlogger
+        const start = Math.floor(query.range.from.valueOf() / 1000 - 2 * additionalTimeRange); // seconds
+        const finish = Math.ceil(query.range.to.valueOf() / 1000 + additionalTimeRange); // seconds
 
-        const instances = await this.pmSeriesSrv.getValues(seriesList, { start, finish, samples });
+        const instances = await this.pmSeriesSrv.getValues(seriesList, { start, finish, interval });
         const descriptions = await this.pmSeriesSrv.getDescriptions(seriesList);
         const metricNames = await this.pmSeriesSrv.getMetricNames(seriesList);
         const instanceValuesGroupedBySeries = _.groupBy(instances, "series");
-- 
2.21.1