diff --git a/cmd/labelmaker/stream.go b/cmd/labelmaker/stream.go index bd761d3..4681606 100644 --- a/cmd/labelmaker/stream.go +++ b/cmd/labelmaker/stream.go @@ -100,6 +100,7 @@ func (srv *Server) SubscribeLabelsEndpoint(w http.ResponseWriter, r *http.Reques http.Error(w, fmt.Sprintf(`{"error": "InternalServerError", "message": "%s"}`, err.Error()), http.StatusInternalServerError) return } + // TODO: verify that this check is working (?) if cursor > high { w.Header().Set("Content-Type", "application/json") http.Error(w, fmt.Sprintf(`{"error": "FutureCursor", "message": "Current high cursor: %d"}`, high), http.StatusBadRequest)