From f2c23021bb6cc11d77d283b526326f4a8ba6c3c0 Mon Sep 17 00:00:00 2001 From: Murat Kabilov Date: Thu, 17 Aug 2017 12:20:03 +0200 Subject: [PATCH] generate clusterEvent queue key in a separate function --- pkg/controller/controller.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index 8bc9632f6..eaf0a6a8c 100644 --- a/pkg/controller/controller.go +++ b/pkg/controller/controller.go @@ -6,6 +6,7 @@ import ( "github.com/Sirupsen/logrus" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/pkg/api/v1" "k8s.io/client-go/rest" "k8s.io/client-go/tools/cache" @@ -169,7 +170,7 @@ func (c *Controller) initController() { return "", fmt.Errorf("could not cast to ClusterEvent") } - return fmt.Sprintf("%s-%s", e.EventType, e.UID), nil + return queueClusterKey(e.EventType, e.UID), nil }) } @@ -206,3 +207,7 @@ func (c *Controller) runPostgresqlInformer(stopCh <-chan struct{}, wg *sync.Wait c.postgresqlInformer.Run(stopCh) } + +func queueClusterKey(eventType spec.EventType, uid types.UID) string { + return fmt.Sprintf("%s-%s", eventType, uid) +}