Skip to content

K
k3s
Commit a7e2e227 authored by Dr. Stefan Schimanski's avatar Dr. Stefan Schimanski
Browse files
Options

Make ExecutorInfo role clear being a prototype

parent adfc63e7
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
contrib/mesos/pkg/scheduler/podtask/pod_task.go
View file @ a7e2e227
...@@ -152,12 +152,12 @@ func setCommandArgument(ei *mesos.ExecutorInfo, flag, value string, create bool) ...@@ -152,12 +152,12 @@ func setCommandArgument(ei *mesos.ExecutorInfo, flag, value string, create bool)
} }
} }
func (t *T) BuildTaskInfo(ei *mesos.ExecutorInfo) *mesos.TaskInfo { func (t *T) BuildTaskInfo(prototype *mesos.ExecutorInfo) *mesos.TaskInfo {
info := &mesos.TaskInfo{ info := &mesos.TaskInfo{
Name: proto.String(generateTaskName(&t.Pod)), Name: proto.String(generateTaskName(&t.Pod)),
TaskId: mutil.NewTaskID(t.ID), TaskId: mutil.NewTaskID(t.ID),
SlaveId: mutil.NewSlaveID(t.Spec.SlaveID), SlaveId: mutil.NewSlaveID(t.Spec.SlaveID),
Executor: proto.Clone(ei).(*mesos.ExecutorInfo), Executor: proto.Clone(prototype).(*mesos.ExecutorInfo),
Data: t.Spec.Data, Data: t.Spec.Data,
Resources: []*mesos.Resource{ Resources: []*mesos.Resource{
mutil.NewScalarResource("cpus", float64(t.Spec.CPU)), mutil.NewScalarResource("cpus", float64(t.Spec.CPU)),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment