|
|
|
@ -236,18 +236,19 @@ func (q *QuerierAPI) TailHandler(w http.ResponseWriter, r *http.Request) { |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
conn, err := upgrader.Upgrade(w, r, nil) |
|
|
|
|
tenantID, err := tenant.TenantID(r.Context()) |
|
|
|
|
if err != nil { |
|
|
|
|
level.Error(logger).Log("msg", "Error in upgrading websocket", "err", err) |
|
|
|
|
level.Warn(logger).Log("msg", "error getting tenant id", "err", err) |
|
|
|
|
serverutil.WriteError(httpgrpc.Errorf(http.StatusBadRequest, err.Error()), w) |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
tenantID, err := tenant.TenantID(r.Context()) |
|
|
|
|
conn, err := upgrader.Upgrade(w, r, nil) |
|
|
|
|
if err != nil { |
|
|
|
|
level.Error(logger).Log("msg", "error getting tenant id", "err", err) |
|
|
|
|
serverutil.WriteError(httpgrpc.Errorf(http.StatusBadRequest, err.Error()), w) |
|
|
|
|
level.Error(logger).Log("msg", "Error in upgrading websocket", "err", err) |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
level.Info(logger).Log("msg", "starting to tail logs", "tenant", tenantID, "selectors", req.Query) |
|
|
|
|
|
|
|
|
|
defer func() { |
|
|
|
|