sandbox add scaleexpectation for create pod

Signed-off-by: liheng <liheng.zms@alibaba-inc.com>

Author: zmberg

pkg/controller/sandbox/core/common_control.go

@@ -31,6 +31,7 @@ import (
 
 	agentsv1alpha1 "github.com/openkruise/agents/api/v1alpha1"
 	"github.com/openkruise/agents/pkg/utils"
+	"github.com/openkruise/agents/pkg/utils/expectations"
 	"github.com/openkruise/agents/pkg/utils/inplaceupdate"
 )
 
@@ -304,9 +305,10 @@ func (r *commonControl) createPod(ctx context.Context, box *agentsv1alpha1.Sandb
 		})
 	}
 	pod.Spec.Volumes = append(pod.Spec.Volumes, volumes...)
-
+	ScaleExpectation.ExpectScale(GetControllerKey(box), expectations.Create, box.Name)
 	err := r.Create(ctx, pod)
 	if err != nil && !errors.IsAlreadyExists(err) {
+		ScaleExpectation.ObserveScale(GetControllerKey(box), expectations.Create, box.Name)
 		logger.Error(err, "create pod failed")
 		return nil, err
 	}

pkg/controller/sandbox/core/util.go

@@ -23,6 +23,8 @@ import (
 	agentsv1alpha1 "github.com/openkruise/agents/api/v1alpha1"
 	"github.com/openkruise/agents/pkg/utils"
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/types"
+	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 // HashSandbox calculates the hash value using sandbox.spec.template
@@ -58,3 +60,7 @@ func GeneratePVCName(templateName, sandboxName string) (string, error) {
 
 	return name, nil
 }
+
+func GetControllerKey(obj client.Object) string {
+	return types.NamespacedName{Namespace: obj.GetNamespace(), Name: obj.GetName()}.String()
+}