Add LokiStack operator status integration

  Integrate with LokiStack operator to use its status conditions instead of querying the Loki status endpoint. This adds
  support for detecting Loki readiness through the operator's status API when available.

  Changes:
  - Add github.com/grafana/loki/operator/apis/loki dependency
  - Add LokiStackStatus field to Loki config
  - Check operator status in getLokiStatus before querying status URL
  - Prevent status URL usage when using Loki operator

Author: OlivierCazade

go.mod

@@ -63,6 +63,7 @@ require (
 	k8s.io/klog/v2 v2.130.1 // indirect
 	k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b // indirect
 	k8s.io/utils v0.0.0-20250604170112-4c0f3b243397 // indirect
+	sigs.k8s.io/controller-runtime v0.20.4 // indirect
 	sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 // indirect
 	sigs.k8s.io/randfill v1.0.0 // indirect
 	sigs.k8s.io/structured-merge-diff/v6 v6.3.0 // indirect

go.sum

@@ -233,6 +233,8 @@ k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b h1:MloQ9/bdJyIu9lb1PzujOP
 k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b/go.mod h1:UZ2yyWbFTpuhSbFhv24aGNOdoRdJZgsIObGBUaYVsts=
 k8s.io/utils v0.0.0-20250604170112-4c0f3b243397 h1:hwvWFiBzdWw1FhfY1FooPn3kzWuJ8tmbZBHi4zVsl1Y=
 k8s.io/utils v0.0.0-20250604170112-4c0f3b243397/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
+sigs.k8s.io/controller-runtime v0.20.4 h1:X3c+Odnxz+iPTRobG4tp092+CvBU9UK0t/bRf+n0DGU=
+sigs.k8s.io/controller-runtime v0.20.4/go.mod h1:xg2XB0K5ShQzAgsoujxuKN4LNXR2LfwwHsPj7Iaw+XY=
 sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 h1:gBQPwqORJ8d8/YNZWEjoZs7npUVDpVXUUOFfW6CgAqE=
 sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg=
 sigs.k8s.io/randfill v1.0.0 h1:JfjMILfT8A6RbawdsK2JXGBR5AQVfd+9TbzrlneTyrU=

pkg/config/loki.go

@@ -18,6 +18,7 @@ type Loki struct {
 	TokenPath          string            `yaml:"tokenPath,omitempty" json:"tokenPath,omitempty"`
 	SkipTLS            bool              `yaml:"skipTls,omitempty" json:"skipTls,omitempty"`
 	CAPath             string            `yaml:"caPath,omitempty" json:"caPath,omitempty"`
+	Status             string            `yaml:"status,omitempty" json:"status,omitempty"`
 	StatusSkipTLS      bool              `yaml:"statusSkipTls,omitempty" json:"statusSkipTls,omitempty"`
 	StatusCAPath       string            `yaml:"statusCaPath,omitempty" json:"statusCaPath,omitempty"`
 	StatusUserCertPath string            `yaml:"statusUserCertPath,omitempty" json:"statusUserCertPath,omitempty"`

pkg/handler/loki.go

@@ -198,6 +198,10 @@ func getLokiNamesForPrefix(cfg *config.Loki, lokiClient httpclient.Caller, filts
 }
 
 func (h *Handlers) getLokiStatus(r *http.Request) ([]byte, int, error) {
+	// Check if the status was provided by the operator
+	if h.Cfg.Loki.Status != "" {
+		return []byte(h.Cfg.Loki.Status), 200, nil
+	}
 	lokiClient := newLokiClient(&h.Cfg.Loki, r.Header, true)
 	baseURL := strings.TrimRight(h.Cfg.Loki.GetStatusURL(), "/")
 	return executeLokiQuery(fmt.Sprintf("%s/%s", baseURL, "ready"), lokiClient)
@@ -231,6 +235,10 @@ func (h *Handlers) LokiMetrics() func(w http.ResponseWriter, r *http.Request) {
 			writeError(w, http.StatusBadRequest, "Loki is disabled")
 			return
 		}
+		if h.Cfg.Loki.Status != nil {
+			writeError(w, http.StatusBadRequest, "Loki status URL is not usable with Loki operator")
+			return
+		}
 		lokiClient := newLokiClient(&h.Cfg.Loki, r.Header, true)
 		baseURL := strings.TrimRight(h.Cfg.Loki.GetStatusURL(), "/")
 
@@ -250,6 +258,10 @@ func (h *Handlers) LokiBuildInfos() func(w http.ResponseWriter, r *http.Request)
 			writeError(w, http.StatusBadRequest, "Loki is disabled")
 			return
 		}
+		if h.Cfg.Loki.Status != nil {
+			writeError(w, http.StatusBadRequest, "Loki status URL is not usable with Loki operator")
+			return
+		}
 		lokiClient := newLokiClient(&h.Cfg.Loki, r.Header, true)
 		baseURL := strings.TrimRight(h.Cfg.Loki.GetStatusURL(), "/")
 
@@ -264,6 +276,10 @@ func (h *Handlers) LokiBuildInfos() func(w http.ResponseWriter, r *http.Request)
 }
 
 func (h *Handlers) fetchLokiConfig(cl httpclient.Caller, output any) error {
+	if h.Cfg.Loki.Status != nil {
+		return fmt.Errorf("loki status url is not usable with Loki operator")
+	}
+
 	baseURL := strings.TrimRight(h.Cfg.Loki.GetStatusURL(), "/")
 
 	resp, _, err := executeLokiQuery(fmt.Sprintf("%s/%s", baseURL, "config"), cl)

vendor/modules.txt

@@ -500,6 +500,8 @@ k8s.io/utils/clock
 k8s.io/utils/internal/third_party/forked/golang/net
 k8s.io/utils/net
 k8s.io/utils/ptr
+# sigs.k8s.io/controller-runtime v0.20.4
+## explicit; go 1.23.0
 # sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8
 ## explicit; go 1.23
 sigs.k8s.io/json