updating locks

Signed-off-by: Jaydip Gabani <[email protected]>
JaydipGabani · Nov 27, 2024 · 52a9d5d · 52a9d5d
1 parent b775a7a
commit 52a9d5d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pkg/pubsub/system.go b/pkg/pubsub/system.go
@@ -20,8 +20,8 @@ func NewSystem() *System {
 }
 
 func (s *System) Publish(_ context.Context, connection string, topic string, msg interface{}) error {
-	s.mux.RLock()
-	defer s.mux.RUnlock()
+	s.mux.Lock()
+	defer s.mux.Unlock()
 	if len(s.connections) > 0 {
 		if c, ok := s.connections[connection]; ok {
 			return c.Publish(context.Background(), msg, topic)

diff --git a/test/pubsub/pod_must_have_test.yaml b/test/pubsub/pod_must_have_test.yaml
@@ -6,6 +6,6 @@ spec:
   match:
     kinds:
     - apiGroups: [ "" ]
-      kinds: [ "Pod" ]
+      kinds: [ "Namespace" ]
   parameters:
     labels: [ "test" ]