feat: show measurements database and retention policy wildcards (#22388)

* feat: show measurements database and retention policy wildcards

Closes #3318

CHANGELOG.md

@@ -136,6 +136,7 @@ v1.8.11 [unreleased]
 -	[#25082](https://github.com/influxdata/influxdb/pull/25082): fix: GROUP BY queries with offset that crosses a DST boundary fail.
 -	[#25146](https://github.com/influxdata/influxdb/pull/25146): fix: Store.validateArgs wrongfully overwriting start, end unix time
 -	[#25182](https://github.com/influxdata/influxdb/pull/25182): fix(tsi1): fix data race between appendEntry and FlushAndSync tsi1.(*LogFile)
+-	[#22388](https://github.com/influxdata/influxdb/pull/22388): feat: show measurements database and retention policy wildcards
 
 v1.8.10 [2021-10-11]
 -------------------

coordinator/internal/data.proto

@@ -33,8 +33,9 @@ message TaskManagerStatementResponse {
 }
 
 message MeasurementNamesRequest {
-    required string Database  = 1;
-    optional string Condition = 2;
+    required string Database        = 1;
+    optional string RetentionPolicy = 2;
+    optional string Condition       = 3;
 }
 
 message MeasurementNamesResponse {

coordinator/meta_executor.go

@@ -191,7 +191,7 @@ func (e *MetaExecutor) TaskManagerStatement(nodeID uint64, stmt influxql.Stateme
 	return resp.Result, resp.Err
 }
 
-func (e *MetaExecutor) MeasurementNames(nodeID uint64, database string, cond influxql.Expr) ([][]byte, error) {
+func (e *MetaExecutor) MeasurementNames(nodeID uint64, database string, retentionPolicy string, cond influxql.Expr) ([][]byte, error) {
 	conn, err := e.dial(nodeID)
 	if err != nil {
 		return nil, err
@@ -200,8 +200,9 @@ func (e *MetaExecutor) MeasurementNames(nodeID uint64, database string, cond inf
 
 	// Write request.
 	if err := EncodeTLV(conn, measurementNamesRequestMessage, &MeasurementNamesRequest{
-		Database:  database,
-		Condition: cond,
+		Database:        database,
+		RetentionPolicy: retentionPolicy,
+		Condition:       cond,
 	}); err != nil {
 		return nil, err
 	}

coordinator/rpc.go

@@ -255,8 +255,9 @@ func (r *TaskManagerStatementResponse) UnmarshalBinary(data []byte) error {
 
 // MeasurementNamesRequest represents a request to retrieve measurement names.
 type MeasurementNamesRequest struct {
-	Database  string
-	Condition influxql.Expr
+	Database        string
+	RetentionPolicy string
+	Condition       influxql.Expr
 }
 
 // MarshalBinary encodes r to a binary format.
@@ -266,8 +267,9 @@ func (r *MeasurementNamesRequest) MarshalBinary() ([]byte, error) {
 		condition = r.Condition.String()
 	}
 	return proto.Marshal(&internal.MeasurementNamesRequest{
-		Database:  proto.String(r.Database),
-		Condition: proto.String(condition),
+		Database:        proto.String(r.Database),
+		RetentionPolicy: proto.String(r.RetentionPolicy),
+		Condition:       proto.String(condition),
 	})
 }
 
@@ -279,6 +281,7 @@ func (r *MeasurementNamesRequest) UnmarshalBinary(data []byte) error {
 	}
 
 	r.Database = pb.GetDatabase()
+	r.RetentionPolicy = pb.GetRetentionPolicy()
 	if pb.GetCondition() != "" {
 		if condition, err := influxql.ParseExpr(pb.GetCondition()); err != nil {
 			return err

coordinator/service.go

@@ -609,7 +609,7 @@ func (s *Service) processMeasurementNamesRequest(conn net.Conn) {
 			return nil, err
 		}
 		// Return measurement names.
-		return s.TSDBStore.MeasurementNames(context.Background(), nil, req.Database, req.Condition)
+		return s.TSDBStore.MeasurementNames(context.Background(), nil, req.Database, req.RetentionPolicy, req.Condition)
 	}()
 	if err != nil {
 		s.Logger.Error("Error reading MeasurementNames request", zap.Error(err))