fix: controller manager polling (#146)

* fix controller manager polling

* fix unit tests

Author: zreigz

pkg/controller/controller_manager.go

@@ -83,7 +83,8 @@ func (cm *ControllerManager) Start() error {
 		go func() {
 			defer controller.Do.ShutdownQueue()
 			defer controller.Do.WipeCache()
-			_ = wait.PollUntilContextTimeout(cm.ctx, cm.Refresh, time.Minute, true, func(ctx context.Context) (done bool, err error) {
+			//nolint:all
+			_ = wait.PollImmediateInfinite(cm.Refresh, func() (done bool, err error) {
 				return controller.Do.Poll(cm.ctx)
 			})
 		}()
@@ -94,7 +95,8 @@ func (cm *ControllerManager) Start() error {
 	}
 
 	go func() {
-		_ = wait.PollUntilContextTimeout(cm.ctx, cm.Refresh, time.Minute, true, func(ctx context.Context) (done bool, err error) {
+		//nolint:all
+		_ = wait.PollImmediateInfinite(cm.Refresh, func() (done bool, err error) {
 			return false, cm.Socket.Join()
 		})
 	}()

pkg/manifests/template/helm_test.go

@@ -19,6 +19,10 @@ var _ = Describe("Helm template", func() {
 	svc := &console.GetServiceDeploymentForAgent_ServiceDeployment{
 		Namespace: "default",
 		Name:      "test",
+		Cluster: &console.GetServiceDeploymentForAgent_ServiceDeployment_Cluster{
+			ID:   "123",
+			Name: "test",
+		},
 	}
 
 	r := gin.Default()

pkg/manifests/template/raw_test.go

@@ -25,6 +25,10 @@ var _ = Describe("Raw template", func() {
 					Value: name,
 				},
 			}
+			svc.Cluster = &console.GetServiceDeploymentForAgent_ServiceDeployment_Cluster{
+				ID:   "123",
+				Name: "test",
+			}
 			resp, err := NewRaw(dir).Render(svc, utilFactory)
 			Expect(err).NotTo(HaveOccurred())
 			Expect(len(resp)).To(Equal(1))