Optimize ReplicaSet calls, add cross-platform binaries, terse output fixes

Author: Abhaya Pattanaik

README.md

@@ -4,7 +4,7 @@ When an alert fires, one command should tell you everything: what's failing (fro
 
 80% of Kubernetes outages trace to recent changes ([Komodor, 2025](https://komodor.com/blog/komodor-2025-enterprise-kubernetes-report-finds-nearly-80-of-production-outages/)). Yet today, finding them is a slog. Kubectl events expire in an hour. ArgoCD shows syncs, not details. Slack becomes your search engine. Forty-five minutes later: someone found a ConfigMap edit.
 
-Our first release fills a gap: a unified change timeline across every resource type—images, ConfigMaps, Secrets, RBAC, HPA, NetworkPolicy, env vars, node events—in a single command. No open-source CLI has this today.
+Our first release fills a gap: a unified change timeline across common Kubernetes resource types—images, ConfigMaps, Secrets, RBAC, HPA, NetworkPolicy, env vars, node events—in a single command. No open-source CLI has this today.
 
 <!-- TODO: demo GIF -->
 <!-- ![kblame demo](docs/demo.gif) -->
@@ -29,7 +29,7 @@ Here's how we're building toward the full vision:
 
 | Version | Functionality | Status |
 |---------|---------|--------|
-| **V1** | What changed — unified change timeline across all resource types | Current |
+| **V1** | What changed — unified change timeline across common Kubernetes resource types | Current |
 | **V2** | What changed + what's failing — logs, confirmed alert correlation | Planned |
 | **V3** | What changed + what's failing + how they connect — dependency-aware correlation, persistent history via in-cluster controller | Planned |
 | **V4** | Multi-cluster, web UI, learned patterns | Planned |
@@ -62,11 +62,11 @@ kblame is different:
 
 | Platform | Architecture | Download | Status |
 |----------|--------------|----------|--------|
-| macOS | ARM64 (Apple Silicon) | [kblame-darwin-arm64](https://github.com/abcdedf/kblame/releases) | Available |
-| macOS | AMD64 (Intel) | Coming soon | Planned |
-| Linux | AMD64 | Coming soon | Planned |
-| Linux | ARM64 | Coming soon | Planned |
-| Windows | AMD64 | Coming soon | Planned |
+| macOS | ARM64 (Apple Silicon) | [kblame-darwin-arm64](https://github.com/abcdedf/kblame/releases/download/latest/kblame-darwin-arm64) | Available |
+| macOS | AMD64 (Intel) | [kblame-darwin-amd64](https://github.com/abcdedf/kblame/releases/download/latest/kblame-darwin-amd64) | Available |
+| Linux | AMD64 | [kblame-linux-amd64](https://github.com/abcdedf/kblame/releases/download/latest/kblame-linux-amd64) | Available |
+| Linux | ARM64 | [kblame-linux-arm64](https://github.com/abcdedf/kblame/releases/download/latest/kblame-linux-arm64) | Available |
+| Windows | AMD64 | [kblame-windows-amd64.exe](https://github.com/abcdedf/kblame/releases/download/latest/kblame-windows-amd64.exe) | Available |
 
 **From source** (requires Go 1.22+):
 ```bash

pkg/changes/collector.go

@@ -7,6 +7,8 @@ import (
 	"sync"
 	"time"
 
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
 	"github.com/abcdedf/kblame/internal/k8s"
 )
 
@@ -42,6 +44,27 @@ func (c *Collector) SetDetectorTimeout(d time.Duration) {
 func (c *Collector) Collect(ctx context.Context, namespace string, sinceTime time.Time) ([]Change, error) {
 	dets := RegisteredDetectors()
 
+	// Pre-fetch ReplicaSet data once for all RS-aware detectors, reducing
+	// redundant LIST calls from N to 1.
+	var rsAware []ReplicaSetAwareDetector
+	for _, d := range dets {
+		if rsd, ok := d.(ReplicaSetAwareDetector); ok {
+			rsAware = append(rsAware, rsd)
+		}
+	}
+	if len(rsAware) > 0 {
+		rsList, err := c.client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
+		if err != nil {
+			fmt.Fprintf(ioStderr, "warning: failed to pre-fetch replicasets: %v\n", err)
+			// Detectors will fall back to fetching individually.
+		} else {
+			deployRS := groupReplicaSetsByDeployment(rsList)
+			for _, rsd := range rsAware {
+				rsd.SetReplicaSetData(deployRS)
+			}
+		}
+	}
+
 	type result struct {
 		changes []Change
 		err     error
@@ -94,6 +117,11 @@ func (c *Collector) Collect(ctx context.Context, namespace string, sinceTime tim
 		}
 	}
 
+	// Clear pre-fetched data so detectors don't hold stale state.
+	for _, rsd := range rsAware {
+		rsd.SetReplicaSetData(nil)
+	}
+
 	// Sort by timestamp, newest first.
 	sort.Slice(allChanges, func(i, j int) bool {
 		return allChanges[i].Timestamp.After(allChanges[j].Timestamp)

pkg/changes/detector.go

@@ -25,6 +25,20 @@ type Detector interface {
 	Detect(ctx context.Context, client *k8s.Client, namespace string, since time.Time) ([]Change, error)
 }
 
+// ReplicaSetAwareDetector is an optional interface that detectors may implement
+// to receive pre-fetched ReplicaSet data. When the Collector detects that
+// multiple detectors need ReplicaSet data, it fetches the list once and injects
+// it into all implementors before calling Detect. This reduces redundant LIST
+// calls from N to 1.
+type ReplicaSetAwareDetector interface {
+	Detector
+	// SetReplicaSetData provides pre-fetched, grouped ReplicaSet data.
+	// The collector calls this before Detect. Implementations should store
+	// the data and use it instead of calling ListReplicaSets themselves.
+	// Passing nil clears any cached data.
+	SetReplicaSetData(data map[string][]rsInfo)
+}
+
 // registry holds all registered detectors. Access is guarded by mu.
 var (
 	mu        sync.RWMutex

pkg/changes/detector_envvar.go

@@ -9,12 +9,19 @@ import (
 	"github.com/abcdedf/kblame/internal/k8s"
 )
 
-// Compile-time interface check.
+// Compile-time interface checks.
 var _ Detector = (*envvarDetector)(nil)
+var _ ReplicaSetAwareDetector = (*envvarDetector)(nil)
 
 // envvarDetector detects environment variable changes by comparing consecutive
 // ReplicaSet revisions owned by the same Deployment.
-type envvarDetector struct{}
+type envvarDetector struct {
+	prefetchedRS map[string][]rsInfo
+}
+
+func (d *envvarDetector) SetReplicaSetData(data map[string][]rsInfo) {
+	d.prefetchedRS = data
+}
 
 func init() {
 	Register(&envvarDetector{})
@@ -27,14 +34,16 @@ func (d *envvarDetector) Description() string {
 }
 
 func (d *envvarDetector) Detect(ctx context.Context, client *k8s.Client, namespace string, since time.Time) ([]Change, error) {
-	rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
-	if err != nil {
-		warnf("%s: failed to list replicasets: %v", d.Name(), err)
-		return nil, nil
+	deployRS := d.prefetchedRS
+	if deployRS == nil {
+		rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
+		if err != nil {
+			warnf("%s: failed to list replicasets: %v", d.Name(), err)
+			return nil, nil
+		}
+		deployRS = groupReplicaSetsByDeployment(rsList)
 	}
 
-	deployRS := groupReplicaSetsByDeployment(rsList)
-
 	var changes []Change
 	for _, rss := range deployRS {
 		if len(rss) < 2 {

pkg/changes/detector_image.go

@@ -11,12 +11,19 @@ import (
 	"github.com/abcdedf/kblame/internal/k8s"
 )
 
-// Compile-time interface check.
+// Compile-time interface checks.
 var _ Detector = (*imageDetector)(nil)
+var _ ReplicaSetAwareDetector = (*imageDetector)(nil)
 
 // imageDetector detects container image changes by comparing consecutive
 // ReplicaSet revisions owned by the same Deployment.
-type imageDetector struct{}
+type imageDetector struct {
+	prefetchedRS map[string][]rsInfo
+}
+
+func (d *imageDetector) SetReplicaSetData(data map[string][]rsInfo) {
+	d.prefetchedRS = data
+}
 
 func init() {
 	Register(&imageDetector{})
@@ -29,14 +36,16 @@ func (d *imageDetector) Description() string {
 }
 
 func (d *imageDetector) Detect(ctx context.Context, client *k8s.Client, namespace string, since time.Time) ([]Change, error) {
-	rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
-	if err != nil {
-		warnf("%s: failed to list replicasets: %v", d.Name(), err)
-		return nil, nil
+	deployRS := d.prefetchedRS
+	if deployRS == nil {
+		rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
+		if err != nil {
+			warnf("%s: failed to list replicasets: %v", d.Name(), err)
+			return nil, nil
+		}
+		deployRS = groupReplicaSetsByDeployment(rsList)
 	}
 
-	deployRS := groupReplicaSetsByDeployment(rsList)
-
 	var changes []Change
 	for _, rss := range deployRS {
 		if len(rss) < 2 {

pkg/changes/detector_resource.go

@@ -12,12 +12,19 @@ import (
 	"github.com/abcdedf/kblame/internal/k8s"
 )
 
-// Compile-time interface check.
+// Compile-time interface checks.
 var _ Detector = (*resourceDetector)(nil)
+var _ ReplicaSetAwareDetector = (*resourceDetector)(nil)
 
 // resourceDetector detects resource request/limit changes (CPU, memory) by
 // comparing consecutive ReplicaSet revisions owned by the same Deployment.
-type resourceDetector struct{}
+type resourceDetector struct {
+	prefetchedRS map[string][]rsInfo
+}
+
+func (d *resourceDetector) SetReplicaSetData(data map[string][]rsInfo) {
+	d.prefetchedRS = data
+}
 
 func init() {
 	Register(&resourceDetector{})
@@ -30,14 +37,16 @@ func (d *resourceDetector) Description() string {
 }
 
 func (d *resourceDetector) Detect(ctx context.Context, client *k8s.Client, namespace string, since time.Time) ([]Change, error) {
-	rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
-	if err != nil {
-		warnf("%s: failed to list replicasets: %v", d.Name(), err)
-		return nil, nil
+	deployRS := d.prefetchedRS
+	if deployRS == nil {
+		rsList, err := client.ListReplicaSets(ctx, namespace, metav1.ListOptions{})
+		if err != nil {
+			warnf("%s: failed to list replicasets: %v", d.Name(), err)
+			return nil, nil
+		}
+		deployRS = groupReplicaSetsByDeployment(rsList)
 	}
 
-	deployRS := groupReplicaSetsByDeployment(rsList)
-
 	var changes []Change
 	for _, rss := range deployRS {
 		if len(rss) < 2 {