add more logs

osstotalsoft · Dec 6, 2023 · 9770062 · 9770062
1 parent 7ec2214
commit 9770062
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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: