release: v0.2.4 — SIGTERM clean shutdown (k8s lifecycle)

Handle SIGTERM alongside SIGINT so a k8s DaemonSet pod shuts down cleanly (exit 0) on
termination instead of being SIGKILLed after the grace period; flush a final throughput
report on exit. Validated on KVM: SIGTERM -> exit 0 + 'stopped (final window)' log.

Author: RoyLin

CHANGELOG.md

@@ -2,6 +2,14 @@
 
 All notable changes to a3s-observer will be documented in this file.
 
+## [0.2.4] — clean shutdown (k8s lifecycle)
+
+### Changed
+
+- Handle **SIGTERM** (not just SIGINT) so a Kubernetes DaemonSet pod shuts down cleanly on
+  termination instead of being SIGKILLed after the grace period; flush a final throughput
+  report on exit. Validated on KVM: SIGTERM → exit 0 + final-window log.
+
 ## [0.2.3] — data-loss visibility
 
 ### Added

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-observer"
-version = "0.2.3"
+version = "0.2.4"
 edition = "2021"
 license = "MIT"
 description = "General-purpose, language-agnostic eBPF observability for AI agents (LLM calls, tools, files, network egress)."

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-observer-collector"
-version = "0.2.3"
+version = "0.2.4"
 edition = "2021"
 license = "MIT"
 description = "a3s-observer collector: loads the eBPF probes and exports enriched events."

a3s-observer-collector/Cargo.toml

@@ -113,12 +113,14 @@ async fn main() -> anyhow::Result<()> {
     );
 
     let mut sigint = tokio::signal::unix::signal(tokio::signal::unix::SignalKind::interrupt())?;
+    let mut sigterm = tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())?;
     let mut stats = Stats::default();
     let mut report = tokio::time::interval(Duration::from_secs(60));
     report.tick().await; // consume the immediate first tick
     loop {
         tokio::select! {
             _ = sigint.recv() => break,
+            _ = sigterm.recv() => break, // k8s sends SIGTERM on pod termination
             _ = report.tick() => {
                 let dropped: u64 = drops
                     .get(&0, 0)
@@ -259,7 +261,14 @@ async fn main() -> anyhow::Result<()> {
             }
         }
     }
-    tracing::info!("a3s-observer-collector: stopped");
+    tracing::info!(
+        exec = stats.exec,
+        egress = stats.egress,
+        dns = stats.dns,
+        file = stats.file,
+        llm = stats.llm,
+        "a3s-observer-collector: stopped (final window)"
+    );
     Ok(())
 }
 

a3s-observer-collector/src/main.rs

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-observer-common"
-version = "0.2.3"
+version = "0.2.4"
 edition = "2021"
 license = "MIT"
 description = "Shared no_std types crossing the eBPF <-> userspace boundary for a3s-observer."

a3s-observer-common/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "a3s-observer-ebpf"
-version = "0.2.3"
+version = "0.2.4"
 edition = "2021"
 license = "MIT"
 publish = false