proxy metadata requests to the default tenant if specified

README.md

@@ -56,6 +56,10 @@ timeout: 10s
 timeout_shutdown: 10s
 # Max number of parallel incoming HTTP requests to handle
 concurrency: 10
+# Whether to forward metrics metadata from Prometheus to Cortex
+# Since metadata requests have no timeseries in them - we cannot divide them into tenants
+# So the metadata requests will be sent to the default tenant only, if one is not defined - they will be dropped
+metadata: false
 
 tenant:
   # Which label to look for the tenant information

VERSION

@@ -1 +1 @@
-1.5.0
+1.6.0

config.go

@@ -19,6 +19,7 @@ type config struct {
 	Timeout         time.Duration
 	TimeoutShutdown time.Duration `yaml:"timeout_shutdown"`
 	Concurrency     int
+	Metadata        bool
 
 	Tenant struct {
 		Label       string

config.yml

@@ -6,6 +6,7 @@ log_level: debug
 timeout: 10s
 timeout_shutdown: 0s
 concurrency: 10
+metadata: false
 
 tenant:
   label: tenant

processor.go

@@ -113,19 +113,31 @@ func (p *processor) handle(ctx *fh.RequestCtx) {
 		return
 	}
 
+	clientIP := ctx.RemoteAddr()
+	reqID, _ := uuid.NewRandom()
+
 	if len(wrReqIn.Timeseries) == 0 {
 		// If there's metadata - just accept the request and drop it
 		if len(wrReqIn.Metadata) > 0 {
+			if p.cfg.Metadata && p.cfg.Tenant.Default != "" {
+				code, body, err := p.send(clientIP, reqID, p.cfg.Tenant.Default, wrReqIn)
+				if err != nil {
+					ctx.Error(err.Error(), fh.StatusInternalServerError)
+					p.Errorf("src=%s req_id=%s: unable to proxy metadata: %s", clientIP, reqID, err)
+					return
+				}
+
+				ctx.SetStatusCode(code)
+				ctx.SetBody(body)
+			}
+
 			return
 		}
 
 		ctx.Error("No timeseries found in the request", fh.StatusBadRequest)
 		return
 	}
 
-	clientIP := ctx.RemoteAddr()
-	reqID, _ := uuid.NewRandom()
-
 	m, err := p.createWriteRequests(wrReqIn)
 	if err != nil {
 		ctx.Error(err.Error(), fh.StatusBadRequest)