Merge pull request #169 from kube-logging/feat/status-enhancements

feat: add problem reporting via resource status

Author: csatib02

.github/workflows/artifacts.yaml

@@ -133,12 +133,12 @@ jobs:
           DIGEST: ${{ steps.build.outputs.digest }}
           TAGS: ${{ steps.meta.outputs.tags }}
         run: |
-            for tag in ${TAGS[@]}; do
-              cosign verify "${tag}@${DIGEST}" \
-                --rekor-url "https://rekor.sigstore.dev/" \
-                --certificate-identity "https://github.com/${{ github.repository }}/.github/workflows/artifacts.yaml@${{ github.ref }}" \
-                --certificate-oidc-issuer "https://token.actions.githubusercontent.com" | jq
-            done
+          for tag in ${TAGS[@]}; do
+            cosign verify "${tag}@${DIGEST}" \
+              --rekor-url "https://rekor.sigstore.dev/" \
+              --certificate-identity "https://github.com/${{ github.repository }}/.github/workflows/artifacts.yaml@${{ github.ref }}" \
+              --certificate-oidc-issuer "https://token.actions.githubusercontent.com" | jq
+          done
 
       - name: Set image ref
         id: image-ref

Makefile

@@ -113,7 +113,7 @@ golangci-lint:
 
 .PHONY: test-e2e
 test-e2e: docker-build kind-cluster ## Run e2e tests
-	e2e/e2e_test.sh || (echo "E2E test failed"; exit 1)
+	e2e/e2e_test.sh && kind delete cluster --name $(KIND_CLUSTER) || (echo "E2E test failed"; exit 1)
 
 .PHONY: lint
 lint: golangci-lint ## Run golangci-lint

api/telemetry/v1alpha1/bridge_types.go

@@ -16,6 +16,9 @@ package v1alpha1
 
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	"github.com/kube-logging/telemetry-controller/pkg/resources/problem"
+	"github.com/kube-logging/telemetry-controller/pkg/sdk/model/state"
 )
 
 // BridgeSpec defines the desired state of Bridge
@@ -38,7 +41,28 @@ type BridgeSpec struct {
 }
 
 // BridgeStatus defines the observed state of Bridge
-type BridgeStatus struct{}
+type BridgeStatus struct {
+	State         state.State `json:"state,omitempty"`
+	Problems      []string    `json:"problems,omitempty"`
+	ProblemsCount int         `json:"problemsCount,omitempty"`
+}
+
+func (b *Bridge) GetProblems() []string {
+	return b.Status.Problems
+}
+
+func (b *Bridge) SetProblems(problems []string) {
+	b.Status.Problems = problems
+	b.Status.ProblemsCount = len(problems)
+}
+
+func (b *Bridge) AddProblem(probs ...string) {
+	problem.Add(b, probs...)
+}
+
+func (b *Bridge) ClearProblems() {
+	b.SetProblems([]string{})
+}
 
 //+kubebuilder:object:root=true
 //+kubebuilder:resource:scope=Cluster,categories=telemetry-all

api/telemetry/v1alpha1/collector_types.go

@@ -21,6 +21,7 @@ import (
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	"github.com/kube-logging/telemetry-controller/pkg/resources/problem"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model/state"
 )
 
@@ -95,8 +96,27 @@ func (c CollectorSpec) GetMemoryLimit() *resource.Quantity {
 
 // CollectorStatus defines the observed state of Collector
 type CollectorStatus struct {
-	Tenants []string    `json:"tenants,omitempty"`
-	State   state.State `json:"state,omitempty"`
+	Tenants       []string    `json:"tenants,omitempty"`
+	State         state.State `json:"state,omitempty"`
+	Problems      []string    `json:"problems,omitempty"`
+	ProblemsCount int         `json:"problemsCount,omitempty"`
+}
+
+func (c *Collector) GetProblems() []string {
+	return c.Status.Problems
+}
+
+func (c *Collector) SetProblems(problems []string) {
+	c.Status.Problems = problems
+	c.Status.ProblemsCount = len(problems)
+}
+
+func (c *Collector) AddProblem(probs ...string) {
+	problem.Add(c, probs...)
+}
+
+func (c *Collector) ClearProblems() {
+	c.SetProblems([]string{})
 }
 
 //+kubebuilder:object:root=true

api/telemetry/v1alpha1/output_types.go

@@ -18,6 +18,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	"github.com/kube-logging/telemetry-controller/pkg/resources/problem"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model/state"
 )
@@ -165,8 +166,10 @@ type Fluentforward struct {
 
 // OutputStatus defines the observed state of Output
 type OutputStatus struct {
-	Tenant string      `json:"tenant,omitempty"`
-	State  state.State `json:"state,omitempty"`
+	Tenant        string      `json:"tenant,omitempty"`
+	State         state.State `json:"state,omitempty"`
+	Problems      []string    `json:"problems,omitempty"`
+	ProblemsCount int         `json:"problemsCount,omitempty"`
 }
 
 func (o *Output) GetTenant() string {
@@ -185,6 +188,23 @@ func (o *Output) SetState(state state.State) {
 	o.Status.State = state
 }
 
+func (o *Output) GetProblems() []string {
+	return o.Status.Problems
+}
+
+func (o *Output) SetProblems(problems []string) {
+	o.Status.Problems = problems
+	o.Status.ProblemsCount = len(problems)
+}
+
+func (o *Output) AddProblem(probs ...string) {
+	problem.Add(o, probs...)
+}
+
+func (o *Output) ClearProblems() {
+	o.SetProblems([]string{})
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 // +kubebuilder:printcolumn:name="Tenant",type=string,JSONPath=`.status.tenant`

api/telemetry/v1alpha1/subscription_types.go

@@ -17,6 +17,7 @@ package v1alpha1
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	"github.com/kube-logging/telemetry-controller/pkg/resources/problem"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model/state"
 )
@@ -37,9 +38,11 @@ type SubscriptionSpec struct {
 
 // SubscriptionStatus defines the observed state of Subscription
 type SubscriptionStatus struct {
-	Tenant  string           `json:"tenant,omitempty"`
-	Outputs []NamespacedName `json:"outputs,omitempty"`
-	State   state.State      `json:"state,omitempty"`
+	Tenant        string           `json:"tenant,omitempty"`
+	Outputs       []NamespacedName `json:"outputs,omitempty"`
+	State         state.State      `json:"state,omitempty"`
+	Problems      []string         `json:"problems,omitempty"`
+	ProblemsCount int              `json:"problemsCount,omitempty"`
 }
 
 func (s *Subscription) GetTenant() string {
@@ -58,6 +61,23 @@ func (s *Subscription) SetState(state state.State) {
 	s.Status.State = state
 }
 
+func (s *Subscription) GetProblems() []string {
+	return s.Status.Problems
+}
+
+func (s *Subscription) SetProblems(problems []string) {
+	s.Status.Problems = problems
+	s.Status.ProblemsCount = len(problems)
+}
+
+func (s *Subscription) AddProblem(probs ...string) {
+	problem.Add(s, probs...)
+}
+
+func (s *Subscription) ClearProblems() {
+	s.SetProblems([]string{})
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 // +kubebuilder:printcolumn:name="Tenant",type=string,JSONPath=`.status.tenant`

api/telemetry/v1alpha1/tenant_types.go

@@ -17,6 +17,7 @@ package v1alpha1
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	"github.com/kube-logging/telemetry-controller/pkg/resources/problem"
 	"github.com/kube-logging/telemetry-controller/pkg/sdk/model/state"
 )
 
@@ -122,6 +123,25 @@ type TenantStatus struct {
 	LogSourceNamespaces []string         `json:"logSourceNamespaces,omitempty"`
 	ConnectedBridges    []string         `json:"connectedBridges,omitempty"`
 	State               state.State      `json:"state,omitempty"`
+	Problems            []string         `json:"problems,omitempty"`
+	ProblemsCount       int              `json:"problemsCount,omitempty"`
+}
+
+func (t *Tenant) GetProblems() []string {
+	return t.Status.Problems
+}
+
+func (t *Tenant) SetProblems(problems []string) {
+	t.Status.Problems = problems
+	t.Status.ProblemsCount = len(problems)
+}
+
+func (t *Tenant) AddProblem(probs ...string) {
+	problem.Add(t, probs...)
+}
+
+func (t *Tenant) ClearProblems() {
+	t.SetProblems([]string{})
 }
 
 //+kubebuilder:object:root=true

api/telemetry/v1alpha1/zz_generated.deepcopy.go

@@ -1,6 +1,6 @@
 dependencies:
 - name: opentelemetry-operator
   repository: https://open-telemetry.github.io/opentelemetry-helm-charts
-  version: 0.93.0
-digest: sha256:9b0c09a70eabe6f91c21fd0abb215aa2a4f75b9b1f1f3c1c4fc4f2df1f940e31
-generated: "2025-08-24T17:37:58.969975368Z"
+  version: 0.95.3
+digest: sha256:4dc8397ec9fa96bb10ec36ee3c61ce32b46c1fc124e66c9c01343b43db57aa06
+generated: "2025-09-30T13:00:24.05559+02:00"

charts/telemetry-controller/Chart.lock

@@ -13,5 +13,5 @@ sources:
   - https://github.com/kube-logging/telemetry-controller
 dependencies:
   - name: opentelemetry-operator
-    version: 0.93.0
+    version: 0.95.3
     repository: https://open-telemetry.github.io/opentelemetry-helm-charts