Handle SIGTERM in AMQP proxy for graceful pod termination

The Python AMQP proxy sidecar only handled KeyboardInterrupt (SIGINT),
not SIGTERM. Since kubelet sends SIGTERM to stop containers, the proxy
hung indefinitely preventing pod termination. Register a SIGTERM handler
that cancels all proxy tasks and catches the resulting CancelledError
during shutdown.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: lmiccini

internal/controller/rabbitmq/data/proxy.py

@@ -18,6 +18,7 @@
 import asyncio
 import argparse
 import logging
+import signal
 import struct
 import sys
 import ssl
@@ -909,14 +910,21 @@ async def main():
     # Start periodic stats
     stats_task = asyncio.create_task(periodic_stats(proxy, args.stats_interval))
 
+    # Handle SIGTERM (sent by kubelet) the same as SIGINT so the proxy
+    # shuts down gracefully instead of hanging until the
+    # terminationGracePeriodSeconds expires.
+    loop = asyncio.get_running_loop()
+    loop.add_signal_handler(signal.SIGTERM, server.close)
+
     try:
         async with server:
             await server.serve_forever()
-    except KeyboardInterrupt:
+    except (KeyboardInterrupt, asyncio.CancelledError):
         logger.info("Shutting down...")
     finally:
         stats_task.cancel()
         proxy.print_stats()
+        logger.info("Proxy stopped")
 
 
 if __name__ == '__main__':