diff --git a/pkg/operator/server.go b/pkg/operator/server.go index ad52b7e..c29508b 100644 --- a/pkg/operator/server.go +++ b/pkg/operator/server.go @@ -37,10 +37,15 @@ func (opsrv *operatorServer) WatchConfiguration(request *operatorv1.WatchConfigu } func (opsrv *operatorServer) WatchComponents(request *operatorv1.WatchComponentsRequest, stream operatorv1.RusiOperator_WatchComponentsServer) error { + + klog.V(4).InfoS("Starting streaming components") + c := make(chan rusiv1.Component) opsrv.ow.addComponentListener(c) defer opsrv.ow.removeComponentListener(c) + klog.V(4).InfoS("Starting consuming components channel") + for { select { case obj := <-c: