Function vpaResourcePolicyForResource

pkg/vpa/vpa.go:420–444

vpaResourcePolicyForResource get the resource's annotation for the vpa pod resource policy key/value and the value is the json definition of the pod resource policy

(obj runtime.Object)

// vpaResourcePolicyForResource get the resource's annotation for the vpa pod resource policy
// key/value and the value is the json definition of the pod resource policy
func vpaResourcePolicyForResource(obj runtime.Object) (*vpav1.PodResourcePolicy, bool) {
	explicit := false

	resourcePolicyStr := ""
	accessor, _ := meta.Accessor(obj)
	if val, ok := accessor.GetAnnotations()[utils.VpaResourcePolicyAnnotation]; ok {
		resourcePolicyStr = val
	} else if val, ok := accessor.GetLabels()[utils.VpaResourcePolicyAnnotation]; ok {
		resourcePolicyStr = val
	}

	if resourcePolicyStr == "" {
		return nil, explicit
	}

	explicit = true
	resourcePol := vpav1.PodResourcePolicy{}
	err := json.NewDecoder(bytes.NewReader([]byte(resourcePolicyStr))).Decode(&resourcePol)
	if err != nil {
		klog.Error(err.Error())
		return nil, explicit
	}

	return &resourcePol, explicit
}

// vpaMinReplicas sets the VPA minimum replicas required for eviction
func vpaMinReplicasForResource(obj runtime.Object) (*int32, bool) {