mockkubeapiserver: set generation on objects

Aiming for a little bit more fidelity, also enables us to test
observedGeneration (in future).

Author: justinsb

mockkubeapiserver/patchresource.go

@@ -22,6 +22,7 @@ import (
 	"fmt"
 	"io"
 	"net/http"
+	"reflect"
 	"strconv"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -79,6 +80,9 @@ func (req *patchResource) Run(ctx context.Context, s *MockKubeAPIServer) error {
 		// TODO: Should we treat this like an apply to an empty object?
 
 		patched := body
+
+		patched.SetGeneration(1)
+
 		if err := resource.CreateObject(ctx, id, patched); err != nil {
 			return err
 		}
@@ -124,6 +128,13 @@ func (req *patchResource) Run(ctx context.Context, s *MockKubeAPIServer) error {
 		klog.Infof("skipping write, object not changed")
 		return req.writeResponse(existingObj)
 	} else {
+		bumpGeneration := !reflect.DeepEqual(existingObj.Object["spec"], updated.Object["spec"])
+		if bumpGeneration {
+			generation := updated.GetGeneration()
+			generation++
+			updated.SetGeneration(generation)
+		}
+
 		if err := resource.UpdateObject(ctx, id, updated); err != nil {
 			return err
 		}

mockkubeapiserver/putresource.go

@@ -89,6 +89,13 @@ func (req *putResource) Run(ctx context.Context, s *MockKubeAPIServer) error {
 		return req.writeResponse(original)
 	}
 
+	bumpGeneration := !reflect.DeepEqual(original.Object["spec"], updated.Object["spec"])
+	if bumpGeneration {
+		generation := updated.GetGeneration()
+		generation++
+		updated.SetGeneration(generation)
+	}
+
 	if err := resource.UpdateObject(ctx, id, updated); err != nil {
 		return err
 	}

mockkubeapiserver/storage/memorystorage/memorystorage.go

@@ -125,6 +125,8 @@ func (s *MemoryStorage) AddObject(obj *unstructured.Unstructured) error {
 		return fmt.Errorf("object group/version/kind %v not known", gvk)
 	}
 
+	obj.SetGeneration(1)
+
 	return resource.CreateObject(ctx, id, obj)
 }