Bläddra i källkod

Merge pull request #35896 from thaJeztah/fix-namespace-filtering

Fix event filter filtering on "or"
Lei Jitang 7 år sedan
förälder
incheckning
431d3d6756
1 ändrade filer med 3 tillägg och 2 borttagningar
  1. 3 2
      libcontainerd/client_daemon.go

+ 3 - 2
libcontainerd/client_daemon.go

@@ -715,8 +715,9 @@ func (c *client) processEventStream(ctx context.Context) {
 
 
 	eventStream, err = c.remote.EventService().Subscribe(ctx, &eventsapi.SubscribeRequest{
 	eventStream, err = c.remote.EventService().Subscribe(ctx, &eventsapi.SubscribeRequest{
 		Filters: []string{
 		Filters: []string{
-			"namespace==" + c.namespace,
-			"topic~=/tasks/",
+			// Filter on both namespace *and* topic. To create an "and" filter,
+			// this must be a single, comma-separated string
+			"namespace==" + c.namespace + ",topic~=|^/tasks/|",
 		},
 		},
 	}, grpc.FailFast(false))
 	}, grpc.FailFast(false))
 	if err != nil {
 	if err != nil {