feat(cli): add UP-TO-DATE column to compute workloads

Surface rolling-update / restart progress in `datumctl compute workloads` by
showing updated/desired replica counts next to ready. UP-TO-DATE counts
instances on the latest template revision (status.updatedReplicas), so a roll
is visible as the count dips below desired and then recovers.

Includes a byte-identical copy of the UpdatedReplicas/ObservedGeneration
WorkloadDeployment status fields in api/v1alpha so the plugin can read them.
These fields are defined identically on the controller branch (PR #129); the
duplicate resolves cleanly once both land on main.

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

Author: scotwells

api/v1alpha/workloaddeployment_types.go

@@ -49,14 +49,28 @@ type WorkloadDeploymentStatus struct {
 	// The number of instances created
 	Replicas int32 `json:"replicas"`
 
-	// The number of instances which have the latest workload settings applied.
+	// The number of instances which have the latest workload settings applied
+	// and are programmed (a subset of UpdatedReplicas that are ready to serve).
 	CurrentReplicas int32 `json:"currentReplicas"`
 
+	// The number of instances updated to the latest template revision (their
+	// observed template hash matches the desired template), regardless of
+	// readiness. Lags Replicas during a rolling update or restart, then catches
+	// back up — making an in-progress roll observable.
+	UpdatedReplicas int32 `json:"updatedReplicas"`
+
 	// The desired number of instances
 	DesiredReplicas int32 `json:"desiredReplicas"`
 
 	// The number of instances which are ready.
 	ReadyReplicas int32 `json:"readyReplicas"`
+
+	// The most recent generation observed by the deployment controller. When
+	// this matches metadata.generation, the controller has reconciled the
+	// latest spec (e.g. a restart request).
+	//
+	// +kubebuilder:validation:Optional
+	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
 }
 
 const (

internal/cmd/compute/workloads/workloads.go

@@ -118,6 +118,7 @@ func runList(cmd *cobra.Command, _ []string) error {
 		health      string
 		healthShort string // first word, for filter comparison
 		readyStr    string
+		upToDateStr string
 		placements  string
 		image       string
 		age         string
@@ -137,9 +138,10 @@ func runList(cmd *cobra.Command, _ []string) error {
 		}
 
 		deps := deploysByWorkload[wUID]
-		var totalReady, totalDesired int32
+		var totalReady, totalUpdated, totalDesired int32
 		for _, d := range deps {
 			totalReady += d.Status.ReadyReplicas
+			totalUpdated += d.Status.UpdatedReplicas
 			totalDesired += d.Status.DesiredReplicas
 		}
 
@@ -169,13 +171,15 @@ func runList(cmd *cobra.Command, _ []string) error {
 		}
 
 		readyStr := fmt.Sprintf("%d/%d", totalReady, totalDesired)
+		upToDateStr := fmt.Sprintf("%d/%d", totalUpdated, totalDesired)
 		instType := wl.Spec.Template.Spec.Runtime.Resources.InstanceType
 
 		rows = append(rows, workloadRow{
 			name:        wl.Name,
 			health:      health,
 			healthShort: healthShort,
 			readyStr:    readyStr,
+			upToDateStr: upToDateStr,
 			placements:  placements,
 			image:       image,
 			age:         util.RelativeAge(wl.CreationTimestamp),
@@ -221,18 +225,18 @@ func runList(cmd *cobra.Command, _ []string) error {
 	tw := util.NewTabWriter(out)
 	if !noHeaders {
 		if wide {
-			fmt.Fprintf(tw, "NAME\tHEALTH\tREADY\tPLACEMENTS\tIMAGE\tAGE\tINSTANCE TYPE\n")
+			fmt.Fprintf(tw, "NAME\tHEALTH\tREADY\tUP-TO-DATE\tPLACEMENTS\tIMAGE\tAGE\tINSTANCE TYPE\n")
 		} else {
-			fmt.Fprintf(tw, "NAME\tHEALTH\tREADY\tPLACEMENTS\tIMAGE\tAGE\n")
+			fmt.Fprintf(tw, "NAME\tHEALTH\tREADY\tUP-TO-DATE\tPLACEMENTS\tIMAGE\tAGE\n")
 		}
 	}
 	for _, r := range rows {
 		if wide {
-			fmt.Fprintf(tw, "%s\t%s\t%s\t%s\t%s\t%s\t%s\n",
-				r.name, r.healthShort, r.readyStr, r.placements, r.image, r.age, r.instType)
+			fmt.Fprintf(tw, "%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\n",
+				r.name, r.healthShort, r.readyStr, r.upToDateStr, r.placements, r.image, r.age, r.instType)
 		} else {
-			fmt.Fprintf(tw, "%s\t%s\t%s\t%s\t%s\t%s\n",
-				r.name, r.healthShort, r.readyStr, r.placements, r.image, r.age)
+			fmt.Fprintf(tw, "%s\t%s\t%s\t%s\t%s\t%s\t%s\n",
+				r.name, r.healthShort, r.readyStr, r.upToDateStr, r.placements, r.image, r.age)
 		}
 	}
 	_ = tw.Flush()