fix: watch ceph cluster only once

Signed-off-by: Artur Troian <[email protected]>

ceph.go

@@ -162,12 +162,11 @@ func (c *ceph) run() error {
 					topic := "ns/" + obj.Name + "/cephclusters"
 					switch evt.Type {
 					case watch.Added:
-						fallthrough
-					case watch.Modified:
 						WatchKubeObjects(c.ctx, pubsub, rc.CephV1().CephClusters(obj.Name), topic)
 						pubsub.AddSub(events, topic)
+					case watch.Modified:
 					case watch.Deleted:
-						pubsub.Unsub(events, "ns/"+obj.Name+"/cephclusters")
+						pubsub.Unsub(events, topic)
 					default:
 						break evtdone
 					}

main.go

@@ -276,6 +276,7 @@ func main() {
 
 		return group.Wait()
 	}
+
 	_ = app.RunContext(ctx, os.Args)
 }
 
@@ -307,7 +308,7 @@ func newRouter(log logr.Logger, apiTimeout, queryTimeout time.Duration) *mux.Rou
 			},
 		}
 
-		ctx, cancel := context.WithTimeout(req.Context(), 100*time.Second)
+		ctx, cancel := context.WithTimeout(req.Context(), queryTimeout)
 		datach := make(chan runner.Result, 1)
 		var wg sync.WaitGroup