karmada-io
/
karmada
mirror of https://github.com/karmada-io/karmada.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add pod replica interpreter 

Signed-off-by: whitewindmills <jayfantasyhjh@gmail.com>
This commit is contained in:
whitewindmills 2023-08-01 21:30:13 +08:00
parent d916d877a4
commit 10b644f317
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/resourceinterpreter/default/native/replica.go
View File

@ -3,6 +3,7 @@ package native
import (
appsv1 "k8s.io/api/apps/v1"
batchv1 "k8s.io/api/batch/v1"
corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/klog/v2"
@ -20,6 +21,7 @@ func getAllDefaultReplicaInterpreter() map[schema.GroupVersionKind]replicaInterp
s[appsv1.SchemeGroupVersion.WithKind(util.DeploymentKind)] = deployReplica
s[appsv1.SchemeGroupVersion.WithKind(util.StatefulSetKind)] = statefulSetReplica
s[batchv1.SchemeGroupVersion.WithKind(util.JobKind)] = jobReplica
s[corev1.SchemeGroupVersion.WithKind(util.PodKind)] = podReplica
return s
}
@ -72,3 +74,15 @@ func jobReplica(object *unstructured.Unstructured) (int32, *workv1alpha2.Replica
return replica, requirement, nil
}
func podReplica(object *unstructured.Unstructured) (int32, *workv1alpha2.ReplicaRequirements, error) {
pod := &corev1.Pod{}
err := helper.ConvertToTypedObject(object, pod)
if err != nil {
klog.Errorf("Failed to convert object(%s), err", object.GroupVersionKind().String(), err)
return 0, nil, err
}
// For Pod, its replica is always 1.
return 1, helper.GenerateReplicaRequirements(&corev1.PodTemplateSpec{Spec: pod.Spec}), nil
}