Add support for TS.MRANGE LATEST

pkg/redis-time-series.go

@@ -98,14 +98,17 @@ func queryTsMRange(from int64, to int64, qm queryModel, client redisClient) back
 		return response
 	}
 
-	var args []interface{}
-	//args := []interface{}{strconv.FormatInt(from, 10), to}
+	var args = []interface{}{to}
+
+	if qm.Latest {
+		args = append(args, "LATEST")
+	}
 
 	// Execute command
 	if qm.Aggregation != "" {
-		args = []interface{}{to, "AGGREGATION", qm.Aggregation, qm.Bucket, "WITHLABELS", "FILTER", filter}
+		args = append(args, "AGGREGATION", qm.Aggregation, qm.Bucket, "WITHLABELS", "FILTER", filter)
 	} else {
-		args = []interface{}{to, qm.Bucket, "WITHLABELS", "FILTER", filter}
+		args = append(args, qm.Bucket, "WITHLABELS", "FILTER", filter)
 	}
 
 	if qm.TsGroupByLabel != "" {

pkg/types.go

@@ -48,6 +48,7 @@ type queryModel struct {
 	Command           string   `json:"command"`
 	Aggregation       string   `json:"aggregation"`
 	Bucket            int      `json:"bucket"`
+	Latest            bool     `json:"tsLatest"`
 	Legend            string   `json:"legend"`
 	Value             string   `json:"value"`
 	Section           string   `json:"section"`

src/components/QueryEditor/QueryEditor.tsx

@@ -206,6 +206,12 @@ export class QueryEditor extends PureComponent<Props> {
    */
   onAggregationChange = this.createSelectFieldHandler<AggregationValue>('aggregation');
 
+  /**
+   * LATEST change
+   */
+
+  onLatestChange = this.createSwitchFieldHandler('tsLatest');
+
   /**
    * ZRANGE Query change
    */
@@ -346,6 +352,7 @@ export class QueryEditor extends PureComponent<Props> {
       streamingDataType,
       tsGroupByLabel,
       tsReducer,
+      tsLatest,
     } = this.props.query;
     const { onRunQuery, datasource } = this.props;
 
@@ -755,11 +762,25 @@ export class QueryEditor extends PureComponent<Props> {
             </div>
           )}
 
+        {type === QueryTypeValue.TIMESERIES &&
+          command &&
+          CommandParameters.tsLatest.includes(command as RedisTimeSeries) && (
+            <div className="gf-form">
+              <Switch
+                label="Latest"
+                labelClass="width-8"
+                tooltip="If checked, will return the latest (incomplete bucket)."
+                checked={tsLatest || false}
+                onChange={this.onLatestChange}
+              />
+            </div>
+          )}
+
         <div className="gf-form">
           <Switch
             label="Streaming"
             labelClass="width-8"
-            tooltip="If checked, the datasource will stream data."
+            tooltip="If checked, the datasource will stream datas."
             checked={streaming || false}
             onChange={this.onStreamingChange}
           />

src/redis/command.ts

@@ -78,6 +78,7 @@ export const CommandParameters = {
   pyFunction: [RedisGears.PYEXECUTE],
   tsGroupBy: [RedisTimeSeries.MRANGE],
   tsReducer: [RedisTimeSeries.MRANGE],
+  tsLatest: [RedisTimeSeries.MRANGE],
   searchQuery: [RediSearch.SEARCH],
   offset: [RediSearch.SEARCH],
   returnFields: [RediSearch.SEARCH],

src/redis/types.ts

@@ -109,6 +109,8 @@ export interface RedisQuery extends DataQuery {
    */
   tsGroupByLabel?: string;
 
+  tsLatest?: boolean;
+
   /**
    * ZRANGE Query
    *