Merge pull request #1491 from saschagrunert/events-interruptable

Make `crictl events` interruptable
kubernetes-sigs · Jul 17, 2024 · ac82070 · ac82070
2 parents a6a89f6 + e970686
commit ac82070
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cmd/crictl/events.go b/cmd/crictl/events.go
@@ -81,7 +81,9 @@ func Events(cliContext *cli.Context, client internalapi.RuntimeService) error {
 	containerEventsCh := make(chan *pb.ContainerEventResponse)
 	go func() {
 		logrus.Debug("getting container events")
-		err := client.GetContainerEvents(context.Background(), containerEventsCh, nil)
+		_, err := InterruptableRPC(nil, func(ctx context.Context) (any, error) {
+			return nil, client.GetContainerEvents(ctx, containerEventsCh, nil)
+		})
 		if err == io.EOF {
 			errCh <- nil
 			return