Skip to content

Commit fee84b3

Browse files
committed
Fixing status update
1 parent 9d47810 commit fee84b3

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

internal/controller/flowcollector_controller.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ import (
1818

1919
flowslatest "github.com/netobserv/network-observability-operator/api/flowcollector/v1beta2"
2020
"github.com/netobserv/network-observability-operator/internal/controller/consoleplugin"
21+
"github.com/netobserv/network-observability-operator/internal/controller/constants"
2122
"github.com/netobserv/network-observability-operator/internal/controller/ebpf"
2223
"github.com/netobserv/network-observability-operator/internal/controller/loki"
2324
"github.com/netobserv/network-observability-operator/internal/controller/reconcilers"
@@ -67,7 +68,13 @@ func Start(ctx context.Context, mgr *manager.Manager) (manager.PostCreateHook, e
6768
}
6869

6970
if mgr.ClusterInfo.HasLokiStack() {
70-
builder.Watches(&lokiv1.LokiStack{}, &handler.EnqueueRequestForObject{})
71+
builder.Watches(
72+
&lokiv1.LokiStack{},
73+
handler.EnqueueRequestsFromMapFunc(func(_ context.Context, _ client.Object) []ctrl.Request {
74+
// When a LokiStack changes, trigger reconcile of the FlowCollector
75+
return []ctrl.Request{{NamespacedName: constants.FlowCollectorName}}
76+
}),
77+
)
7178
log.Info("LokiStack CRD detected")
7279
}
7380

0 commit comments

Comments
 (0)